This is an automated email from the ASF dual-hosted git repository.
kurt pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e62a04a [FLINK-14651][runtime] Enable DefaultScheduler by default
add c4acb6f [FLINK-14672][sql-client] Make Executor stateful in sql client
No new revisions were added by this update.
Summary of changes:
.../org/apache/flink/table/client/SqlClient.java | 55 +-
.../table/client/cli/CliChangelogResultView.java | 2 +-
.../apache/flink/table/client/cli/CliClient.java | 60 ++-
.../flink/table/client/cli/CliResultView.java | 2 +-
.../flink/table/client/cli/CliTableResultView.java | 2 +-
.../flink/table/client/cli/SqlCompleter.java | 9 +-
.../flink/table/client/config/Environment.java | 4 +
.../flink/table/client/gateway/Executor.java | 109 ++--
.../flink/table/client/gateway/SessionContext.java | 103 +---
.../client/gateway/local/ExecutionContext.java | 560 ++++++++++-----------
.../table/client/gateway/local/LocalExecutor.java | 341 +++++++------
.../client/gateway/local/ProgramDeployer.java | 2 +-
.../table/client/gateway/local/ResultStore.java | 22 +-
.../flink/table/client/cli/CliClientTest.java | 105 ++--
.../flink/table/client/cli/CliResultViewTest.java | 84 ++--
.../table/client/gateway/local/DependencyTest.java | 3 +-
.../client/gateway/local/ExecutionContextTest.java | 63 +--
.../client/gateway/local/LocalExecutorITCase.java | 249 +++++----
.../table/api/internal/TableEnvironmentImpl.java | 2 +-
19 files changed, 933 insertions(+), 844 deletions(-)
