You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by al...@apache.org on 2019/09/18 07:53:32 UTC
[flink] 03/08: [hotfix] Remove unused dumpStreamingPlanAsJSON from
StreamingPlan
This is an automated email from the ASF dual-hosted git repository.
aljoscha pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git
commit 8733eb852ba9ff6e20909173db913d682bf32012
Author: Aljoscha Krettek <al...@apache.org>
AuthorDate: Thu Sep 5 12:09:22 2019 +0200
[hotfix] Remove unused dumpStreamingPlanAsJSON from StreamingPlan
---
.../apache/flink/optimizer/plan/StreamingPlan.java | 6 ------
.../apache/flink/streaming/api/graph/StreamGraph.java | 19 -------------------
2 files changed, 25 deletions(-)
diff --git a/flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/StreamingPlan.java b/flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/StreamingPlan.java
index bc11d18..f3fe632 100644
--- a/flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/StreamingPlan.java
+++ b/flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/StreamingPlan.java
@@ -23,9 +23,6 @@ import org.apache.flink.runtime.jobgraph.JobGraph;
import javax.annotation.Nullable;
-import java.io.File;
-import java.io.IOException;
-
/**
* Abstract class representing Flink Streaming plans.
*/
@@ -45,7 +42,4 @@ public abstract class StreamingPlan implements FlinkPlan {
public abstract JobGraph getJobGraph(@Nullable JobID jobID);
public abstract String getStreamingPlanAsJSON();
-
- public abstract void dumpStreamingPlanAsJSON(File file) throws IOException;
-
}
diff --git a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
index 94b686f..f4741fb 100644
--- a/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
+++ b/flink-streaming-java/src/main/java/org/apache/flink/streaming/api/graph/StreamGraph.java
@@ -55,10 +55,6 @@ import org.slf4j.LoggerFactory;
import javax.annotation.Nullable;
-import java.io.File;
-import java.io.FileOutputStream;
-import java.io.IOException;
-import java.io.PrintWriter;
import java.util.ArrayList;
import java.util.Collection;
import java.util.HashMap;
@@ -735,19 +731,4 @@ public class StreamGraph extends StreamingPlan {
throw new RuntimeException("JSON plan creation failed", e);
}
}
-
- @Override
- public void dumpStreamingPlanAsJSON(File file) throws IOException {
- PrintWriter pw = null;
- try {
- pw = new PrintWriter(new FileOutputStream(file), false);
- pw.write(getStreamingPlanAsJSON());
- pw.flush();
-
- } finally {
- if (pw != null) {
- pw.close();
- }
- }
- }
}