You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by ma...@apache.org on 2022/03/02 13:49:21 UTC
[flink] branch master updated (8510567 -> 449d968)
This is an automated email from the ASF dual-hosted git repository.
mapohl pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from 8510567 [FLINK-26398][docs] Adding docs for Kinesis Firehose table api
add 449d968 [FLINK-26286][kubernetes] Introduce idempotent KubernetesStateHandleStore.
No new revisions were added by this update.
Summary of changes:
.../KubernetesStateHandleStore.java | 444 +++++++++++++++------
.../KubernetesStateHandleStoreTest.java | 389 +++++++++++++++++-
.../persistence/TestingLongStateHandleHelper.java | 33 +-
.../zookeeper/ZooKeeperStateHandleStoreTest.java | 22 +-
4 files changed, 730 insertions(+), 158 deletions(-)