获取SQL结果

功能介绍

在MRS集群中查询SparkSql和SparkScript两种类型作业的SQL语句运行完成后返回的查询结果。

URI

• URI格式

  GET /v2/{project_id}/clusters/{cluster_id}/job-executions/{job_execution_id}/sql-result

• 参数说明

  表1 URI参数说明

  名称	是否必选	说明
  project_id	是	项目编号。获取方法，请参见获取项目ID。
  cluster_id	是	集群ID。获取方法，请参见获取集群ID。
  job_execution_id	是	作业ID。获取方法，请参见获取作业ID。

请求消息

请求参数

无。

响应参数

示例

• 请求示例

  {
  	"job_name": "111",
  	"job_type": "SparkSql",
  	"arguments": [
               "create table src_wordcount (id int,name string);
                show tables;
                insert INTO src_wordcount VALUES (1, 'a');
                insert INTO src_wordcount VALUES (2, 'b');SELECT * FROM src_wordcount;"
                    ],
  	"properties": {}
  }

• 响应示例
  • 成功示例

    {
    	"sql_results": {
    		"0": [{
    			"result": "succeed"
    		}],
    		"1": [{
    			"database": "default",
    			"isTemporary": "false",
    			"tableName": "src_wordcount"
    		}],
    		"2": [{
    			"result": "succeed"
    		}],
    		"3": [{
    			"result": "succeed"
    		}],
    		"4": [{
    			"name": "a",
    			"id": "1"
    		}, {
    			"name": "b",
    			"id": "2"
    		}]
    	}
    }

  • 失败示例

    {
    "error_msg":"收集SQL作业结果失败",
    "error_code":"0172"
    }

状态码

状态码请参见状态码。