[flink] branch master updated (d336dad9345 -> 1534ea75161)

[sh...@apache.org]

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 d336dad9345 [FLINK-30755][runtime] Remove legacy codes of marking not support speculative executions
     add 1534ea75161 [FLINK-29945][sql-client] Supports to submit SQL to an embedded SQL Gateway in the SQL Client

No new revisions were added by this update.

Summary of changes:
 .../delegation/hive/HiveOperationExecutor.java     |   2 +-
 flink-table/flink-sql-client/pom.xml               |  16 +
 .../org/apache/flink/table/client/SqlClient.java   |  86 +++-
 .../apache/flink/table/client/cli/CliClient.java   | 453 +++++----------------
 .../flink/table/client/cli/CliOptionsParser.java   |   7 +-
 .../apache/flink/table/client/cli/CliStrings.java  |  12 +-
 .../flink/table/client/cli/SqlCompleter.java       |   2 +-
 .../table/client/cli/parser/ClientParser.java      | 199 ---------
 .../parser/{StatementType.java => Command.java}    |  20 +-
 .../table/client/cli/parser/SqlCommandParser.java  |  17 +-
 .../client/cli/parser/SqlCommandParserImpl.java    | 137 ++++++-
 .../client/cli/parser/SqlMultiLineParser.java      |  28 +-
 .../flink/table/client/gateway/ClientResult.java   | 113 +++++
 .../flink/table/client/gateway/Executor.java       |  91 +----
 .../flink/table/client/gateway/ExecutorImpl.java   | 432 ++++++++++++++++++++
 .../table/client/gateway/ResultDescriptor.java     |   7 +-
 .../client/gateway/context/DefaultContext.java     | 144 -------
 .../client/gateway/context/ExecutionContext.java   | 181 --------
 .../client/gateway/context/SessionContext.java     | 305 --------------
 .../client/gateway/local/LocalContextUtils.java    |  56 +--
 .../table/client/gateway/local/LocalExecutor.java  | 302 --------------
 .../local/result/ChangelogCollectResult.java       |   4 +-
 .../gateway/local/result/CollectResultBase.java    |  10 +-
 .../result/MaterializedCollectBatchResult.java     |   6 +-
 .../result/MaterializedCollectResultBase.java      |   4 +-
 .../result/MaterializedCollectStreamResult.java    |   6 +-
 .../apache/flink/table/client/SqlClientTest.java   |   2 +-
 .../flink/table/client/cli/CliClientITCase.java    |  35 +-
 .../flink/table/client/cli/CliClientTest.java      | 250 +++---------
 .../flink/table/client/cli/CliResultViewTest.java  |   6 +-
 .../table/client/cli/CliTableauResultViewTest.java |  27 +-
 ...rserTest.java => SqlCommandParserImplTest.java} |  74 ++--
 .../table/client/cli/utils/TestTableResult.java    | 130 ------
 .../client/gateway/context/SessionContextTest.java | 230 -----------
 .../table/client/gateway/local/DependencyTest.java | 314 --------------
 ...ExecutorITCase.java => ExecutorImplITCase.java} | 314 +++++++++++---
 .../local/result/ChangelogCollectResultTest.java   |  19 +-
 .../result/MaterializedCollectBatchResultTest.java |  17 +-
 .../MaterializedCollectStreamResultTest.java       |  19 +-
 .../client/gateway/utils/SimpleCatalogFactory.java | 133 ------
 .../table/client/util/CliClientTestUtils.java      |  50 +++
 .../table/client/util/TestHiveCatalogFactory.java  | 124 ++++++
 .../org.apache.flink.table.factories.Factory       |   5 +-
 .../src/test/resources/sql/catalog_database.q      |   9 +-
 .../src/test/resources/sql/function.q              |  30 +-
 .../src/test/resources/sql/insert.q                |  12 +-
 .../src/test/resources/sql/module.q                |   3 +-
 .../src/test/resources/sql/select.q                |  16 +-
 .../flink-sql-client/src/test/resources/sql/set.q  | 186 +++++----
 .../src/test/resources/sql/statement_set.q         |  34 +-
 .../src/test/resources/sql/table.q                 | 226 +++++++---
 .../flink-sql-client/src/test/resources/sql/view.q |  27 +-
 .../src/test/resources/sql_multi/statement_set.q   |  34 +-
 flink-table/flink-sql-gateway/pom.xml              |   6 -
 .../org/apache/flink/table/gateway/SqlGateway.java |  27 +-
 .../table/gateway/rest/SqlGatewayRestEndpoint.java |   8 +-
 .../header/session/ConfigureSessionHeaders.java    |   2 +-
 .../header/statement/CompleteStatementHeaders.java |   2 +-
 .../operation/OperationStatusResponseBody.java     |   2 +
 .../message/session/CloseSessionResponseBody.java  |   2 +
 .../session/ConfigureSessionRequestBody.java       |   6 +
 .../session/GetSessionConfigResponseBody.java      |   2 +
 .../message/session/OpenSessionRequestBody.java    |   2 +
 .../message/session/OpenSessionResponseBody.java   |   2 +
 .../statement/CompleteStatementRequestBody.java    |   2 +
 .../statement/CompleteStatementResponseBody.java   |   2 +
 .../statement/ExecuteStatementRequestBody.java     |   6 +
 .../message/util/GetApiVersionResponseBody.java    |   2 +
 .../rest/message/util/GetInfoResponseBody.java     |   2 +
 .../SqlGatewayRestEndpointUtils.java}              |  33 +-
 .../gateway/service/SqlGatewayServiceImpl.java     |   1 +
 .../gateway/service/context/DefaultContext.java    |  65 ++-
 .../service/operation/OperationExecutor.java       |  36 +-
 .../gateway/service/session/SessionManager.java    |   2 +-
 .../table/gateway/rest/SessionRelatedITCase.java   |   2 +-
 .../SqlGatewayRestEndpointStatementITCase.java     |   4 +-
 .../table/gateway/rest/StatementRelatedITCase.java |   2 +-
 .../rest/util/SqlGatewayRestEndpointExtension.java |   8 +-
 .../rest/util/SqlGatewayRestEndpointTestUtils.java |  14 -
 .../service/context/SessionContextTest.java        |   7 +-
 .../service/session/SessionManagerTest.java        |   8 +-
 .../service/utils/SqlGatewayServiceExtension.java  |   5 +-
 82 files changed, 2035 insertions(+), 3193 deletions(-)
 delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/parser/ClientParser.java
 rename flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/cli/parser/{StatementType.java => Command.java} (65%)
 create mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ClientResult.java
 create mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ExecutorImpl.java
 delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/DefaultContext.java
 delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/ExecutionContext.java
 delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/context/SessionContext.java
 delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/LocalExecutor.java
 rename flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/parser/{ClientParserTest.java => SqlCommandParserImplTest.java} (60%)
 delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/cli/utils/TestTableResult.java
 delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/context/SessionContextTest.java
 delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/DependencyTest.java
 rename flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/local/{LocalExecutorITCase.java => ExecutorImplITCase.java} (67%)
 delete mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/gateway/utils/SimpleCatalogFactory.java
 create mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/util/CliClientTestUtils.java
 create mode 100644 flink-table/flink-sql-client/src/test/java/org/apache/flink/table/client/util/TestHiveCatalogFactory.java
 copy flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/rest/{message/session/CloseSessionResponseBody.java => util/SqlGatewayRestEndpointUtils.java} (51%)