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 <[email protected]>
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();