Myasuka commented on code in PR #24417: URL: https://github.com/apache/flink/pull/24417#discussion_r1508693480
########## docs/content/docs/dev/datastream/fault-tolerance/state.md: ########## @@ -610,19 +610,20 @@ StateTtlConfig ttlConfig = StateTtlConfig import org.apache.flink.api.common.state.StateTtlConfig val ttlConfig = StateTtlConfig - .newBuilder(Time.seconds(1)) - .cleanupInRocksdbCompactFilter(1000, Time.hours(1)) + .newBuilder(Duration.ofSeconds(1)) + .cleanupInRocksdbCompactFilter(1000, Duration.ofHours(1)) .build ``` {{< /tab >}} {{< tab "Python" >}} ```python +from pyflink.common import Duration from pyflink.common.time import Time Review Comment: As we use new interface of `Duration`, we don't need this `import` anymore. ########## docs/content/docs/dev/datastream/fault-tolerance/state.md: ########## @@ -491,7 +491,7 @@ import org.apache.flink.api.common.state.StateTtlConfig; import org.apache.flink.api.common.time.Time; Review Comment: We don't need this import anymore. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: issues-unsubscr...@flink.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org