flink-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From u..@apache.org
Subject flink git commit: [hotfix] Fix JobSubmitTest
Date Wed, 19 Oct 2016 13:21:31 GMT
Repository: flink
Updated Branches:
  refs/heads/master 398bd9b31 -> ebcedc454


[hotfix] Fix JobSubmitTest


Project: http://git-wip-us.apache.org/repos/asf/flink/repo
Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/ebcedc45
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/ebcedc45
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/ebcedc45

Branch: refs/heads/master
Commit: ebcedc454295c350bc2a2a3ae8cac2abd54baa4f
Parents: 398bd9b
Author: Ufuk Celebi <uce@apache.org>
Authored: Wed Oct 19 15:21:17 2016 +0200
Committer: Ufuk Celebi <uce@apache.org>
Committed: Wed Oct 19 15:21:17 2016 +0200

----------------------------------------------------------------------
 .../java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java   | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/flink/blob/ebcedc45/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java
----------------------------------------------------------------------
diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java
b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java
index 4ea3628..6ec27e5 100644
--- a/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java
+++ b/flink-runtime/src/test/java/org/apache/flink/runtime/jobmanager/JobSubmitTest.java
@@ -35,6 +35,7 @@ import org.apache.flink.runtime.instance.ActorGateway;
 import org.apache.flink.runtime.jobgraph.JobGraph;
 import org.apache.flink.runtime.jobgraph.JobVertex;
 import org.apache.flink.runtime.jobgraph.JobVertexID;
+import org.apache.flink.runtime.jobgraph.tasks.ExternalizedCheckpointSettings;
 import org.apache.flink.runtime.jobgraph.tasks.JobSnapshottingSettings;
 import org.apache.flink.runtime.leaderretrieval.LeaderRetrievalService;
 import org.apache.flink.runtime.messages.JobManagerMessages;
@@ -220,7 +221,7 @@ public class JobSubmitTest {
 
 		JobGraph jg = new JobGraph("test job", jobVertex);
 		jg.setSnapshotSettings(new JobSnapshottingSettings(vertexIdList, vertexIdList, vertexIdList,
-			5000, 5000, 0L, 10));
+			5000, 5000, 0L, 10, ExternalizedCheckpointSettings.none()));
 		return jg;
 	}
 }


Mime
View raw message