[flink] branch master updated: [hotfix][DataStream] Remove redundant call to StreamConfig#setCheckpointStorage

[chesnay]

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());