This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c1d0e99 [FLINK-8949] Add dedicated watermarks metric retrieval
endpoint (#10238)
add 99c1aa3 [FLINK-14840] Add unit tests for exception behaviour of SQL
cli executor
add d480e25 [FLINK-14840] Use Executor interface in SQL cli
No new revisions were added by this update.
Summary of changes:
.../client/config/entries/DeploymentEntry.java | 5 +
.../client/gateway/ProgramTargetDescriptor.java | 40 +-----
.../client/gateway/local/ExecutionContext.java | 110 ++++++++------
.../table/client/gateway/local/LocalExecutor.java | 53 ++++---
.../client/gateway/local/ProgramDeployer.java | 159 +++++----------------
.../table/client/gateway/local/ResultStore.java | 19 ++-
.../local/result/ChangelogCollectStreamResult.java | 13 +-
.../gateway/local/result/CollectStreamResult.java | 93 +++++++-----
.../client/gateway/local/result/DynamicResult.java | 2 +-
.../result/MaterializedCollectBatchResult.java | 88 ++++++++----
.../result/MaterializedCollectStreamResult.java | 13 +-
.../flink/table/client/cli/CliClientTest.java | 2 +-
.../client/gateway/local/EnvironmentTest.java | 1 +
.../client/gateway/local/ExecutionContextTest.java | 1 +
.../client/gateway/local/LocalExecutorITCase.java | 145 ++++++++++++++++---
.../MaterializedCollectStreamResultTest.java | 6 +-
.../test/resources/test-sql-client-defaults.yaml | 2 +-
17 files changed, 436 insertions(+), 316 deletions(-)
