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

Posted to commits@flink.apache.org by tr...@apache.org on 2021/08/30 09:00:42 UTC

[flink] branch master updated (1d38803 -> d505e6e)

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

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


    from 1d38803  [FLINK-23833][coordination] Rename IntermediateResult#notifyPartitionChanged to IntermediateResult#clearCacheForConsumedPartitionGroup
     add bad537d  [FLINK-9925][tests] Harden ClientTest by making handler shareable
     add d505e6e  [FLINK-9925] Rework Client to encapsulate concurrency of single connection

No new revisions were added by this update.

Summary of changes:
 .../flink/queryablestate/network/Client.java       | 477 ++------------------
 .../queryablestate/network/ServerConnection.java   | 490 +++++++++++++++++++++
 .../flink/queryablestate/network/ClientTest.java   | 145 +++---
 3 files changed, 584 insertions(+), 528 deletions(-)
 create mode 100644 flink-queryable-state/flink-queryable-state-client-java/src/main/java/org/apache/flink/queryablestate/network/ServerConnection.java