This is an automated email from the ASF dual-hosted git repository. chesnay pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/master by this push: new 8bd2b10 [hotfix][DataStream] Remove redundant call to StreamConfig#setCheckpointStorage 8bd2b10 is described below commit 8bd2b10f32ebb913175a371a9c4becadb31af746 Author: est08zw <766215...@qq.com> AuthorDate: Wed Apr 21 17:00:35 2021 +0800 [hotfix][DataStream] Remove redundant call to StreamConfig#setCheckpointStorage --- .../org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java | 1 - 1 file changed, 1 deletion(-) diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java index a14fc15..425350a 100644 --- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java +++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java @@ -722,7 +722,6 @@ public class StreamingJobGraphGenerator { config.setStateBackend(streamGraph.getStateBackend()); config.setCheckpointStorage(streamGraph.getCheckpointStorage()); config.setSavepointDir(streamGraph.getSavepointDirectory()); - config.setCheckpointStorage(streamGraph.getCheckpointStorage()); config.setGraphContainingLoops(streamGraph.isIterative()); config.setTimerServiceProvider(streamGraph.getTimerServiceProvider()); config.setCheckpointingEnabled(checkpointCfg.isCheckpointingEnabled());