You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by sr...@apache.org on 2019/04/30 09:26:49 UTC
[flink] branch release-1.8 updated: [hotfix] Fix compile error from
rebase of FLINK-12296]
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....@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();