This is an automated email from the ASF dual-hosted git repository. srichter pushed a commit to branch release-1.8 in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.8 by this push: new 4d1605b [hotfix] Fix compile error from rebase of FLINK-12296] 4d1605b is described below commit 4d1605bf52ec03b5e01d0bb950f279a3e6da9471 Author: Stefan Richter <s.rich...@data-artisans.com> AuthorDate: Tue Apr 30 11:26:34 2019 +0200 [hotfix] Fix compile error from rebase of FLINK-12296] --- .../org/apache/flink/test/state/StatefulOperatorChainedTaskTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-tests/src/test/java/org/apache/flink/test/state/StatefulOperatorChainedTaskTest.java b/flink-tests/src/test/java/org/apache/flink/test/state/StatefulOperatorChainedTaskTest.java index 5651929..c3e1ba9 100644 --- a/flink-tests/src/test/java/org/apache/flink/test/state/StatefulOperatorChainedTaskTest.java +++ b/flink-tests/src/test/java/org/apache/flink/test/state/StatefulOperatorChainedTaskTest.java @@ -176,7 +176,7 @@ public class StatefulOperatorChainedTaskTest { testHarness.getTaskStateManager().setWaitForReportLatch(new OneShotLatch()); - while (!streamTask.triggerCheckpoint(checkpointMetaData, CheckpointOptions.forCheckpointWithDefaultLocation(), false)) {} + while (!streamTask.triggerCheckpoint(checkpointMetaData, CheckpointOptions.forCheckpointWithDefaultLocation())) {} testHarness.getTaskStateManager().getWaitForReportLatch().await(); long reportedCheckpointId = testHarness.getTaskStateManager().getReportedCheckpointId();