This is an automated email from the ASF dual-hosted git repository. gary pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/flink.git
commit d24e20b8b1ac8bf5207ac8f153eeead914bed834 Author: Gary Yao <g...@apache.org> AuthorDate: Wed Mar 13 18:44:32 2019 +0100 [hotfix][runtime] Delete unused methods from ExecutionGraph Delete methods: - getRequiredClasspaths() - getRequiredJarFiles() --- .../runtime/executiongraph/ExecutionGraph.java | 21 --------------------- 1 file changed, 21 deletions(-) diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java index ff7e123..93e54e9 100644 --- a/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java +++ b/flink-runtime/src/main/java/org/apache/flink/runtime/executiongraph/ExecutionGraph.java @@ -83,7 +83,6 @@ import javax.annotation.Nonnull; import javax.annotation.Nullable; import java.io.IOException; -import java.net.URL; import java.util.ArrayList; import java.util.Arrays; import java.util.Collection; @@ -602,26 +601,6 @@ public class ExecutionGraph implements AccessExecutionGraph { // Properties and Status of the Execution Graph // -------------------------------------------------------------------------------------------- - /** - * Returns a list of BLOB keys referring to the JAR files required to run this job. - * - * @return list of BLOB keys referring to the JAR files required to run this job - */ - public Collection<PermanentBlobKey> getRequiredJarFiles() { - return jobInformation.getRequiredJarFileBlobKeys(); - } - - /** - * Returns a list of classpaths referring to the directories/JAR files required to run this job. - * - * @return list of classpaths referring to the directories/JAR files required to run this job - */ - public Collection<URL> getRequiredClasspaths() { - return jobInformation.getRequiredClasspathURLs(); - } - - // -------------------------------------------------------------------------------------------- - public void setJsonPlan(String jsonPlan) { this.jsonPlan = jsonPlan; }