[runtime] Remove redundant JobType property from JobGraph.

VonRosenchild · Apr 29, 2015 · 0fceb11 · 0fceb11
1 parent 4cb5b72
commit 0fceb11
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 14 deletions.
diff --git a/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java b/flink-runtime/src/main/java/org/apache/flink/runtime/jobgraph/JobGraph.java
@@ -76,10 +76,6 @@ public class JobGraph implements Serializable {
 
  private ScheduleMode scheduleMode = ScheduleMode.FROM_SOURCES;
 
- public enum JobType {STREAMING, BATCH}
-
- private JobType jobType = JobType.BATCH;
-
  private boolean checkpointingEnabled = false;
 
  private long checkpointingInterval = 10000;
@@ -262,15 +258,6 @@ public int getNumberOfVertices() {
  return this.taskVertices.size();
  }
 
-
- public void setJobType(JobType jobType) {
- this.jobType = jobType;
- }
-
- public JobType getJobType() {
- return jobType;
- }
-
  public void setCheckpointingEnabled(boolean checkpointingEnabled) {
  this.checkpointingEnabled = checkpointingEnabled;
  }

diff --git a/...g-core/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java b/...g-core/src/main/java/org/apache/flink/streaming/api/graph/StreamingJobGraphGenerator.java
@@ -78,7 +78,6 @@ public JobGraph createJobGraph(String jobName) {
 
  // Turn lazy scheduling off
  jobGraph.setScheduleMode(ScheduleMode.ALL);
- jobGraph.setJobType(JobGraph.JobType.STREAMING);
  jobGraph.setCheckpointingEnabled(streamGraph.isCheckpointingEnabled());
  jobGraph.setCheckpointingInterval(streamGraph.getCheckpointingInterval());