You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ja...@apache.org on 2021/03/04 12:46:25 UTC

[flink] branch master updated (40e5c27 -> 7a91157)

This is an automated email from the ASF dual-hosted git repository.

jark pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from 40e5c27  [FLINK-21553][table-runtime-blink] Copy record if needed when flush window buffer records to state
     add 7a91157  [FLINK-18789][sql-client] Use TableEnvironment#executeSql method to execute insert statement in sql client

No new revisions were added by this update.

Summary of changes:
 flink-table/flink-sql-client/pom.xml               |  8 +++
 .../apache/flink/table/client/cli/CliClient.java   | 13 ++--
 .../flink/table/client/gateway/Executor.java       | 10 ---
 .../client/gateway/ProgramTargetDescriptor.java    | 52 ---------------
 .../client/gateway/local/ExecutionContext.java     | 23 +++++--
 .../table/client/gateway/local/LocalExecutor.java  | 72 ---------------------
 .../flink/table/client/cli/CliClientTest.java      | 29 ++++-----
 .../flink/table/client/cli/CliResultViewTest.java  |  7 ---
 .../flink/table/client/cli/TestingExecutor.java    |  7 ---
 .../table/client/cli/utils/TestTableResult.java    | 12 +++-
 .../client/gateway/local/LocalExecutorITCase.java  | 73 +++++++---------------
 .../org/apache/flink/table/utils/PrintUtils.java   |  2 +-
 12 files changed, 85 insertions(+), 223 deletions(-)
 delete mode 100644 flink-table/flink-sql-client/src/main/java/org/apache/flink/table/client/gateway/ProgramTargetDescriptor.java