You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "yiwei93 (Jira)" <ji...@apache.org> on 2022/11/04 06:20:00 UTC
[jira] [Created] (FLINK-29881) when Fetch results in sql gateway, the result using open api is different from using restful api
yiwei93 created FLINK-29881:
-------------------------------
Summary: when Fetch results in sql gateway, the result using open api is different from using restful api
Key: FLINK-29881
URL: https://issues.apache.org/jira/browse/FLINK-29881
Project: Flink
Issue Type: Bug
Components: Table SQL / Gateway
Affects Versions: 1.16.0
Reporter: yiwei93
use restful api , fetch result from
{code:java}
http://hermes02:8083/v1/sessions/9a8fcf37-73e5-43ca-bcc3-d44d8b71a24c/operations/b40085c1-a2c5-42f4-80e7-0971c5ef9710/result/0{code}
the result is
{code:java}
{
"results": {
"columns": [
{
"name": "localtimestamp",
"logicalType": {
"type": "TIMESTAMP_WITHOUT_TIME_ZONE",
"nullable": false,
"precision": 3
},
"comment": null
}
],
"data": [
{
"kind": "INSERT",
"fields": [
"2022-11-04T11:41:40.036"
]
}
]
},
"resultType": "PAYLOAD",
"nextResultUri": "/v1/sessions/9a8fcf37-73e5-43ca-bcc3-d44d8b71a24c/operations/b40085c1-a2c5-42f4-80e7-0971c5ef9710/result/1"
}{code}
use api to fetch ,the code is
{code:java}
ApiClient client = new ApiClient();
client.setHost("hermes02");
client.setPort(8083);
client.setScheme("http");
defaultApi = new DefaultApi(client);
OpenSessionRequestBody openSessionRequestBody = new OpenSessionRequestBody();
OpenSessionResponseBody openSessionResponseBody = defaultApi.openSession(openSessionRequestBody);
SessionHandle sessionHandle = new SessionHandle().identifier(UUID.fromString(openSessionResponseBody.getSessionHandle()));
ExecuteStatementRequestBody executeStatementRequestBody = new ExecuteStatementRequestBody().statement("select localtimestamp");
ExecuteStatementResponseBody executeStatementResponseBody = defaultApi.executeStatement(sessionHandle.getIdentifier(), executeStatementRequestBody);
FetchResultsResponseBody fetchResultsResponseBody = defaultApi.fetchResults(sessionHandle.getIdentifier(), UUID.fromString(executeStatementResponseBody.getOperationHandle()), 0L);{code}
the result is
{code:java}
class FetchResultsResponseBody {
results: class ResultSet {
resultType: null
nextToken: null
resultSchema: null
data: []
}
resultType: NOT_READY
nextResultUri: /v1/sessions/9a8fcf37-73e5-43ca-bcc3-d44d8b71a24c/operations/b40085c1-a2c5-42f4-80e7-0971c5ef9710/result/0
}{code}
--
This message was sent by Atlassian Jira
(v8.20.10#820010)