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
