fixup: remove mailbox for async calls

apache · Sep 3, 2021 · 510c0e1 · 510c0e1
1 parent 1db15a9
commit 510c0e1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/...streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java b/...streaming-java/src/test/java/org/apache/flink/streaming/runtime/tasks/StreamTaskTest.java
@@ -1299,8 +1299,8 @@ protected void finishTask() throws Exception {
                                         CheckpointStorageLocationReference.getDefault()),
                                 new CheckpointMetricsBuilder()),
                 "test");
-        executor.execute(() -> harness.streamTask.notifyCheckpointAbortAsync(1), "test");
-        executor.execute(() -> harness.streamTask.notifyCheckpointCompleteAsync(2), "test");
+        harness.streamTask.notifyCheckpointAbortAsync(1);
+        harness.streamTask.notifyCheckpointCompleteAsync(2);
 
         harness.processAll();