[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user asfgit closed the pull request at: https://github.com/apache/flink/pull/6313 ---

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202130806 --- Diff: flink-runtime/src/test/java/org/apache/flink/runtime/state/ttl/StateBackendTestContext.java --- @@ -0,0 +1,120 @@ +/* + * Licensed

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202103083 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java --- @@ -240,7 +243,7 @@ private boolean

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user azagrebin commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202081209 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java --- @@ -240,7 +243,7 @@ private boolean

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202058484 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapKeyedStateBackend.java --- @@ -240,7 +243,7 @@ private boolean

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202057089 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java --- @@ -93,7 +94,7 @@ private static

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202056626 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/filesystem/FsStateBackend.java --- @@ -93,7 +94,7 @@ private static

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202042548 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlMapState.java --- @@ -84,52 +86,89 @@ public boolean contains(UK key)

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user azagrebin commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202041863 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlMapState.java --- @@ -84,52 +86,89 @@ public boolean contains(UK key) throws

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user azagrebin commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202040710 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java --- @@ -92,6 +93,10 @@ @Nullable private String

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202036711 --- Diff: flink-runtime/src/main/java/org/apache/flink/runtime/state/ttl/TtlMapState.java --- @@ -84,52 +86,89 @@ public boolean contains(UK key)

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

Github user StefanRRichter commented on a diff in the pull request: https://github.com/apache/flink/pull/6313#discussion_r202032512 --- Diff: flink-core/src/main/java/org/apache/flink/api/common/state/StateDescriptor.java --- @@ -92,6 +93,10 @@ @Nullable private

[GitHub] flink pull request #6313: [FLINK-9701] Add TTL in state descriptors

GitHub user azagrebin opened a pull request: https://github.com/apache/flink/pull/6313 [FLINK-9701] Add TTL in state descriptors ## What is the purpose of the change This PR activates TTL feature in state descriptors. ## Brief change log - add method