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 <[email protected]> Authored: Wed Oct 19 15:21:17 2016 +0200 Committer: Ufuk Celebi <[email protected]> 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; } }
