Github user asfgit closed the pull request at:
https://github.com/apache/flink/pull/6277
---
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6277#discussion_r201272235
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfiguration.java
---
@@ -93,4 +97,82 @@ public Time getTtl() {
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6277#discussion_r201264096
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfiguration.java
---
@@ -93,4 +97,82 @@ public Time getTtl() {
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6277#discussion_r201257564
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfiguration.java
---
@@ -93,4 +97,82 @@ public Time getTtl() {
Github user yanghua commented on a diff in the pull request:
https://github.com/apache/flink/pull/6277#discussion_r201229057
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfiguration.java
---
@@ -93,4 +97,82 @@ public Time getTtl() {
Github user bowenli86 commented on a diff in the pull request:
https://github.com/apache/flink/pull/6277#discussion_r201216406
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfiguration.java
---
@@ -93,4 +97,82 @@ public Time getTtl() {
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6277#discussion_r200950760
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfiguration.java
---
@@ -93,4 +101,59 @@ public Time getTtl() {
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6277#discussion_r200974407
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfiguration.java
---
@@ -93,4 +101,59 @@ public Time getTtl() {
Github user azagrebin commented on a diff in the pull request:
https://github.com/apache/flink/pull/6277#discussion_r200949235
--- Diff:
flink-core/src/main/java/org/apache/flink/api/common/state/StateTtlConfiguration.java
---
@@ -61,7 +61,15 @@
private final
GitHub user yanghua opened a pull request:
https://github.com/apache/flink/pull/6277
[FLINK-9511] Implement TTL config
## What is the purpose of the change
*This pull request refactors TTL config and create a builder to build it.*
## Brief change log
10 matches
Mail list logo