restart strategy
-
CheckPoint 예제flink 2021. 5. 19. 22:42
문제 Stream WordCount 예제에 CheckPoint 를 적용해 본다. Code import org.apache.flink.api.common.restartstrategy.RestartStrategies import org.apache.flink.api.java.utils.ParameterTool import org.apache.flink.streaming.api.CheckpointingMode import org.apache.flink.streaming.api.environment.CheckpointConfig.ExternalizedCheckpointCleanup import org.apache.flink.streaming.api.scala._ object CheckPointExample { ..