[hotfix][tests] Fix the compile issue caused by constructor change of…

… CheckpointBarrierUnaligner
is · Jun 9, 2020 · 892e1c3 · 892e1c3
1 parent a80dc5a
commit 892e1c3
Showing 1 changed file with 4 additions and 4 deletions.
diff --git a/...a/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnalignerTest.java b/...a/src/test/java/org/apache/flink/streaming/runtime/io/CheckpointBarrierUnalignerTest.java
@@ -525,7 +525,7 @@ public void testConcurrentProcessBarrierAndNotifyBarrierReceived() throws Except
  public void testProcessCancellationBarrierAfterNotifyBarrierReceived() throws Exception {
  final ValidatingCheckpointInvokable invokable = new ValidatingCheckpointInvokable();
  final CheckpointBarrierUnaligner handler = new CheckpointBarrierUnaligner(
- new int[] { 1 }, ChannelStateWriter.NO_OP, "test", invokable);
+ new int[] { 1 }, TestSubtaskCheckpointCoordinator.INSTANCE, "test", invokable);
 
  ThreadSafeUnaligner unaligner = handler.getThreadSafeUnaligner();
  // should trigger respective checkpoint
@@ -548,7 +548,7 @@ public void testProcessCancellationBarrierAfterNotifyBarrierReceived() throws Ex
  public void testProcessCancellationBarrierAfterProcessBarrier() throws Exception {
  final ValidatingCheckpointInvokable invokable = new ValidatingCheckpointInvokable();
  final CheckpointBarrierUnaligner handler = new CheckpointBarrierUnaligner(
- new int[] { 1 }, ChannelStateWriter.NO_OP, "test", invokable);
+ new int[] { 1 }, TestSubtaskCheckpointCoordinator.INSTANCE, "test", invokable);
 
  // should trigger respective checkpoint
  handler.processBarrier(buildCheckpointBarrier(DEFAULT_CHECKPOINT_ID), 0);
@@ -565,7 +565,7 @@ public void testProcessCancellationBarrierAfterProcessBarrier() throws Exception
  public void testProcessCancellationBarrierBeforeProcessAndReceiveBarrier() throws Exception {
  final ValidatingCheckpointInvokable invokable = new ValidatingCheckpointInvokable();
  final CheckpointBarrierUnaligner handler = new CheckpointBarrierUnaligner(
- new int[] { 1 }, ChannelStateWriter.NO_OP, "test", invokable);
+ new int[] { 1 }, TestSubtaskCheckpointCoordinator.INSTANCE, "test", invokable);
 
  handler.processCancellationBarrier(new CancelCheckpointMarker(DEFAULT_CHECKPOINT_ID));
 
@@ -610,7 +610,7 @@ public void testEndOfStreamWithPendingCheckpoint() throws Exception {
  final int numberOfChannels = 2;
  final ValidatingCheckpointInvokable invokable = new ValidatingCheckpointInvokable();
  final CheckpointBarrierUnaligner handler = new CheckpointBarrierUnaligner(
- new int[] { numberOfChannels }, ChannelStateWriter.NO_OP, "test", invokable);
+ new int[] { numberOfChannels }, TestSubtaskCheckpointCoordinator.INSTANCE, "test", invokable);
 
  ThreadSafeUnaligner unaligner = handler.getThreadSafeUnaligner();
  // should trigger respective checkpoint