This is an automated email from the ASF dual-hosted git repository.
xtsong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from cc9b30bdacf [FLINK-27292][docs-zh] Translate the "Data Type
Extraction" section of "Data Types" to Chinese. This closes #20316
add f4edb9a0921 [hotfix][sql-gateway]Add RestConfigUtils to test rest
endpoint
add 6e095d33427 [hotfix][sql-gateway]Add default timeout for
AbstractSqlGatewayRestHandler
add 687e0622221 [FLINK-28161][sql-gateway]Introduce the session related
API for REST endpoint
No new revisions were added by this update.
Summary of changes:
.../table/gateway/rest/SqlGatewayRestEndpoint.java | 41 +++++-
.../handler/AbstractSqlGatewayRestHandler.java | 5 +-
.../rest/handler/session/CloseSessionHandler.java | 70 +++++++++
.../handler/session/GetSessionConfigHandler.java | 69 +++++++++
.../rest/handler/session/OpenSessionHandler.java | 67 +++++++++
.../session/TriggerSessionHeartbeatHandler.java | 69 +++++++++
.../rest/header/session/CloseSessionHeaders.java | 79 ++++++++++
.../header/session/GetSessionConfigHeaders.java | 79 ++++++++++
.../rest/header/session/OpenSessionHeaders.java | 78 ++++++++++
.../session/TriggerSessionHeartbeatHeaders.java | 79 ++++++++++
.../message/session/CloseSessionResponseBody.java | 42 ++++++
.../session/GetSessionConfigResponseBody.java | 45 ++++++
.../message/session/OpenSessionRequestBody.java | 62 ++++++++
.../message/session/OpenSessionResponseBody.java | 42 ++++++
.../session/SessionHandleIdPathParameter.java | 49 ++++++
.../message/session/SessionMessageParameters.java | 52 +++++++
.../table/gateway/rest/RestAPIITTestBase.java | 107 ++++++++++++++
.../table/gateway/rest/SessionCaseITTest.java | 164 +++++++++++++++++++++
.../gateway/rest/SqlGatewayRestEndpointITCase.java | 60 ++------
.../gateway/rest/SqlGatewayRestEndpointTest.java | 4 +-
.../table/gateway/rest/util/RestConfigUtils.java | 65 ++++++++
21 files changed, 1272 insertions(+), 56 deletions(-)
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/session/CloseSessionHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/session/GetSessionConfigHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/session/OpenSessionHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/handler/session/TriggerSessionHeartbeatHandler.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/session/CloseSessionHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/session/GetSessionConfigHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/session/OpenSessionHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/header/session/TriggerSessionHeartbeatHeaders.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/session/CloseSessionResponseBody.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/session/GetSessionConfigResponseBody.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/session/OpenSessionRequestBody.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/session/OpenSessionResponseBody.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/session/SessionHandleIdPathParameter.java
create mode 100644
flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/message/session/SessionMessageParameters.java
create mode 100644
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/RestAPIITTestBase.java
create mode 100644
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/SessionCaseITTest.java
create mode 100644
flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/rest/util/RestConfigUtils.java
