[flink] branch master updated: [FLINK-32441] Fix DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore (#22879)

[srichter]

This is an automated email from the ASF dual-hosted git repository.

srichter pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 0c787f522ed [FLINK-32441] Fix 
DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore (#22879)
0c787f522ed is described below

commit 0c787f522ed5983a902554a00edaa81bdb622480
Author: Stefan Richter <srich...@apache.org>
AuthorDate: Tue Jun 27 14:49:51 2023 +0200

    [FLINK-32441] Fix 
DefaultSchedulerTest#testTriggerCheckpointAndCompletedAfterStore (#22879)
---
 .../java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java   | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git 
a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java
 
b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java
index 1635cb41d79..81fa4ea31ac 100644
--- 
a/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java
+++ 
b/flink-runtime/src/test/java/org/apache/flink/runtime/scheduler/DefaultSchedulerTest.java
@@ -891,7 +891,7 @@ public class DefaultSchedulerTest extends TestLogger {
         final long checkpointId =
                 
checkpointCoordinator.getPendingCheckpoints().keySet().iterator().next();
         OneShotLatch latch = new OneShotLatch();
-        executor.execute(
+        mainThreadExecutor.execute(
                 () -> {
                     try {
                         final AcknowledgeCheckpoint acknowledgeCheckpoint =