[jira] [Created] (FLINK-29881) when Fetch results in sql gateway, the result using open api is different from using restful api

[yiwei93 (Jira)]

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)