You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sh...@apache.org on 2023/01/12 11:41:57 UTC
[flink] branch master updated (5cb434c36da -> 6a15b7e9b24)
This is an automated email from the ASF dual-hosted git repository.
shengkai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from 5cb434c36da [FLINK-14023][python] Support accessing job parameters in Python user-defined functions
add 6a15b7e9b24 [FLINK-29950][sql-gateway] Refactor ResultSet to an interface
No new revisions were added by this update.
Summary of changes:
.../hive/util/OperationExecutorFactory.java | 13 +-
.../endpoint/hive/HiveServer2EndpointITCase.java | 4 +-
.../flink/table/gateway/api/results/ResultSet.java | 98 ++++-----------
.../results/{ResultSet.java => ResultSetImpl.java} | 115 +++++++++---------
.../gateway/service/SqlGatewayServiceImpl.java | 4 +-
.../service/operation/OperationExecutor.java | 69 +++++------
.../service/operation/OperationManager.java | 6 +-
.../gateway/service/result/NotReadyResult.java | 75 ++++++++++++
.../gateway/service/result/ResultFetcher.java | 132 +++++++++++++++++++--
.../table/gateway/rest/OperationRelatedITCase.java | 4 +-
.../rest/serde/ResultInfoJsonSerDeTest.java | 9 +-
.../gateway/service/SqlGatewayServiceITCase.java | 104 ++++------------
.../service/SqlGatewayServiceStatementITCase.java | 114 ++++++++++++++++++
.../service/operation/OperationManagerTest.java | 11 +-
.../gateway/service/result/ResultFetcherTest.java | 8 +-
.../service/utils/SqlGatewayServiceTestUtil.java | 87 ++++++++++++++
16 files changed, 572 insertions(+), 281 deletions(-)
copy flink-table/flink-sql-gateway-api/src/main/java/org/apache/flink/table/gateway/api/results/{ResultSet.java => ResultSetImpl.java} (57%)
create mode 100644 flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/result/NotReadyResult.java
create mode 100644 flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/utils/SqlGatewayServiceTestUtil.java