This is an automated email from the ASF dual-hosted git repository.
hangxiang pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
from ad8bbb49a5a [hotfix] Fix YARN ContainerId.getId Deprecated Used.
add 739bd337c65 [FLINK-34979][State] Implement State Future and related
utilities
No new revisions were added by this update.
Summary of changes:
.../api/common/state/v2/StateFutureUtils.java | 50 -----
.../flink/core/state/CompletedStateFuture.java | 74 +++++++
.../flink/core/state/InternalStateFuture.java | 19 +-
.../apache/flink/core/state/StateFutureImpl.java | 173 +++++++++++++++
.../apache/flink/core/state/StateFutureUtils.java | 108 ++++++++++
.../apache/flink/core/state/StateFutureTest.java | 239 +++++++++++++++++++++
6 files changed, 605 insertions(+), 58 deletions(-)
delete mode 100644
flink-core-api/src/main/java/org/apache/flink/api/common/state/v2/StateFutureUtils.java
create mode 100644
flink-core/src/main/java/org/apache/flink/core/state/CompletedStateFuture.java
copy
flink-streaming-java/src/main/java/org/apache/flink/streaming/runtime/operators/sink/committables/CheckpointCommittableManager.java
=>
flink-core/src/main/java/org/apache/flink/core/state/InternalStateFuture.java
(63%)
create mode 100644
flink-core/src/main/java/org/apache/flink/core/state/StateFutureImpl.java
create mode 100644
flink-core/src/main/java/org/apache/flink/core/state/StateFutureUtils.java
create mode 100644
flink-core/src/test/java/org/apache/flink/core/state/StateFutureTest.java
