Repository: flink Updated Branches: refs/heads/master a612b9966 -> 436c3335b
[hotfix] Fix ArchivedExecutionGraphTest Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/436c3335 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/436c3335 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/436c3335 Branch: refs/heads/master Commit: 436c3335b83979b9a278e480b3278bed71081322 Parents: a612b99 Author: zentol <ches...@apache.org> Authored: Fri Oct 14 14:54:00 2016 +0200 Committer: zentol <ches...@apache.org> Committed: Fri Oct 14 14:54:35 2016 +0200 ---------------------------------------------------------------------- .../executiongraph/ArchivedExecutionGraphTest.java | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/436c3335/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraphTest.java ---------------------------------------------------------------------- diff --git a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraphTest.java b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraphTest.java index d0566d9..aac2d00 100644 --- a/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraphTest.java +++ b/flink-runtime/src/test/java/org/apache/flink/runtime/executiongraph/ArchivedExecutionGraphTest.java @@ -31,7 +31,6 @@ import org.apache.flink.runtime.akka.AkkaUtils; import org.apache.flink.runtime.checkpoint.CompletedCheckpoint; import org.apache.flink.runtime.checkpoint.StandaloneCheckpointIDCounter; import org.apache.flink.runtime.checkpoint.StandaloneCompletedCheckpointStore; -import org.apache.flink.runtime.checkpoint.savepoint.HeapSavepointStore; import org.apache.flink.runtime.checkpoint.stats.CheckpointStats; import org.apache.flink.runtime.checkpoint.stats.CheckpointStatsTracker; import org.apache.flink.runtime.checkpoint.stats.JobCheckpointStats; @@ -42,6 +41,7 @@ import org.apache.flink.runtime.executiongraph.restart.NoRestartStrategy; import org.apache.flink.runtime.jobgraph.JobStatus; 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.testingUtils.TestingUtils; import org.apache.flink.util.SerializedValue; import org.junit.BeforeClass; @@ -110,12 +110,13 @@ public class ArchivedExecutionGraphTest { 100, 100, 1, + ExternalizedCheckpointSettings.none(), Collections.<ExecutionJobVertex>emptyList(), Collections.<ExecutionJobVertex>emptyList(), Collections.<ExecutionJobVertex>emptyList(), new StandaloneCheckpointIDCounter(), - new StandaloneCompletedCheckpointStore(1, null), - new HeapSavepointStore(), + new StandaloneCompletedCheckpointStore(1), + null, new TestCheckpointStatsTracker()); Map<AccumulatorRegistry.Metric, Accumulator<?, ?>> flinkAccumulators = new HashMap<>(); @@ -379,6 +380,11 @@ public class ArchivedExecutionGraphTest { } @Override + public String getExternalPath() { + return null; + } + + @Override public long getMinDuration() { return 2; }
