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

Posted to commits@flink.apache.org by dw...@apache.org on 2020/01/21 13:20:20 UTC

[flink] branch master updated (c4c2169 -> 8d85f85)

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

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


    from c4c2169  [FLINK-15601] Remove unused constant field NUM_STOP_CALL_TRIES in Execution (#10906)
     add 8d85f85  [FLINK-15686][sql-client] Use old type system in CollectStreamTableSink

No new revisions were added by this update.

Summary of changes:
 .../gateway/local/CollectStreamTableSink.java      | 21 ++++++++---
 .../table/client/gateway/local/ResultStore.java    |  7 +---
 .../local/result/ChangelogCollectStreamResult.java |  4 +--
 .../gateway/local/result/CollectStreamResult.java  | 12 +------
 .../client/gateway/local/result/DynamicResult.java |  7 ----
 .../result/MaterializedCollectBatchResult.java     | 14 ++------
 .../result/MaterializedCollectStreamResult.java    |  6 +---
 .../client/gateway/local/LocalExecutorITCase.java  | 42 +++++++++++-----------
 .../MaterializedCollectStreamResultTest.java       | 10 ------
 9 files changed, 44 insertions(+), 79 deletions(-)