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/30 14:09:28 UTC
[flink] branch master updated (5f5abb69187 -> c9e87fe410c)

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 5f5abb69187 Revert "[FLINK-19699][e2e] Collect dmesg output after tests"
     add c9e87fe410c [FLINK-30692][sql-client] Introduce SingleSessionManager to support REMOVE JAR syntax (#21771)

No new revisions were added by this update.

Summary of changes:
 .../endpoint/hive/HiveServer2EndpointITCase.java   |   5 +-
 .../org/apache/flink/table/client/SqlClient.java   |  46 +++--
 .../apache/flink/table/client/cli/CliStrings.java  |  39 ----
 .../flink/table/client/gateway/Executor.java       |  10 +
 .../flink/table/client/gateway/ExecutorImpl.java   |   6 +-
 .../client/gateway/local/DefaultContextUtils.java  |  26 +--
 .../client/gateway/local/SingleSessionManager.java | 186 ++++++++++++++++++
 .../flink/table/client/cli/CliClientITCase.java    |   4 +-
 .../client/gateway/local/ExecutorImplITCase.java   |   4 +-
 .../src/test/resources/sql/function.q              |  28 +--
 .../flink-sql-client/src/test/resources/sql/set.q  |  30 ++-
 .../org/apache/flink/table/gateway/SqlGateway.java |  53 ++----
 .../gateway/service/context/DefaultContext.java    |  31 ++-
 .../gateway/service/context/SessionContext.java    |  67 ++++---
 .../service/operation/OperationExecutor.java       |  12 +-
 .../gateway/service/session/SessionManager.java    | 207 +++------------------
 ...SessionManager.java => SessionManagerImpl.java} |  38 ++--
 .../gateway/service/SqlGatewayServiceITCase.java   |   6 +-
 ...anagerTest.java => SessionManagerImplTest.java} |   8 +-
 .../service/utils/SqlGatewayServiceExtension.java  |  16 +-
 20 files changed, 419 insertions(+), 403 deletions(-)
 create mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/local/SingleSessionManager.java
 copy flink-table/flink-sql-gateway/src/main/java/org/apache/flink/table/gateway/service/session/{SessionManager.java => SessionManagerImpl.java} (90%)
 rename flink-table/flink-sql-gateway/src/test/java/org/apache/flink/table/gateway/service/session/{SessionManagerTest.java => SessionManagerImplTest.java} (94%)