This is an automated email from the ASF dual-hosted git repository.
twalthr pushed a change to branch release-1.9
in repository https://gitbox.apache.org/repos/asf/flink.git.
from e5e1c11 [FLINK-13487][tests] Wait until TE has registerd at JM
new 5e1ae61 [table-api-java] Postpone check for Blink planner in
StreamTableEnvironment
new efa6cab [FLINK-13273][table-planner-blink] Allow retrieving
StreamGraph from Blink executor
new 8b9b1e2 [hotfix][table-planner-blink] Update Blink's auto-complete
hints
new d88eb0f [hotfix][table-planner-blink] Update Blink's
ExpressionReducer classloading to Flink's behavior
new 6b8c5e0 [FLINK-13273][sql-client] Allow switching planners in SQL
Client
new 48bc4b1 [hotfix][table] Add missing annotations to factories
The 6 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
docs/dev/table/sqlClient.md | 53 ++++++-----
flink-end-to-end-tests/run-nightly-tests.sh | 3 +-
.../test-scripts/test_sql_client.sh | 17 ++--
.../flink-sql-client/conf/sql-client-defaults.yaml | 40 ++++----
flink-table/flink-sql-client/pom.xml | 12 +++
.../client/config/entries/ExecutionEntry.java | 90 +++++++++++++++---
.../flink/table/client/gateway/SessionContext.java | 8 +-
.../gateway/local/CollectBatchTableSink.java | 19 ++--
.../gateway/local/CollectStreamTableSink.java | 8 +-
.../client/gateway/local/ExecutionContext.java | 104 ++++++++++++++++++---
.../table/client/gateway/local/LocalExecutor.java | 3 +-
.../table/client/gateway/local/ResultStore.java | 2 +-
.../client/gateway/local/EnvironmentTest.java | 3 +-
.../client/gateway/local/ExecutionContextTest.java | 2 +
.../client/gateway/local/LocalExecutorITCase.java | 26 +++++-
.../test/resources/test-sql-client-defaults.yaml | 15 +--
.../java/internal/StreamTableEnvironmentImpl.java | 12 +--
.../table/factories/BatchTableSinkFactory.java | 2 +
.../table/factories/BatchTableSourceFactory.java | 2 +
.../table/factories/StreamTableSinkFactory.java | 2 +
.../table/factories/StreamTableSourceFactory.java | 2 +
.../table/planner/delegation/BatchExecutor.java | 6 +-
.../table/planner/delegation/ExecutorBase.java | 14 ++-
.../table/planner/delegation/StreamExecutor.java | 5 +-
.../table/planner/calcite/FlinkPlannerImpl.scala | 2 +-
.../table/planner/codegen/ExpressionReducer.scala | 2 +-
tools/travis/splits/split_misc.sh | 3 +-
27 files changed, 336 insertions(+), 121 deletions(-)
