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%)
