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();

Reply via email to