[flink] branch master updated: [FLINK-24793][tests] Skip DefaultSchedulerLocalRecoveryITCase when testing AdaptiveScheduler

[zhuzh]

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

zhuzh 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 130db38  [FLINK-24793][tests] Skip DefaultSchedulerLocalRecoveryITCase 
when testing AdaptiveScheduler
130db38 is described below

commit 130db3830a9dc9173b2afd8f22e577c9711812bc
Author: Zhu Zhu <reed...@gmail.com>
AuthorDate: Mon Nov 8 15:08:19 2021 +0800

    [FLINK-24793][tests] Skip DefaultSchedulerLocalRecoveryITCase when testing 
AdaptiveScheduler
    
    This closes #17710.
---
 .../flink/test/runtime/DefaultSchedulerLocalRecoveryITCase.java       | 4 ++++
 1 file changed, 4 insertions(+)

diff --git 
a/flink-tests/src/test/java/org/apache/flink/test/runtime/DefaultSchedulerLocalRecoveryITCase.java
 
b/flink-tests/src/test/java/org/apache/flink/test/runtime/DefaultSchedulerLocalRecoveryITCase.java
index b63b0fc..2f16fe7 100644
--- 
a/flink-tests/src/test/java/org/apache/flink/test/runtime/DefaultSchedulerLocalRecoveryITCase.java
+++ 
b/flink-tests/src/test/java/org/apache/flink/test/runtime/DefaultSchedulerLocalRecoveryITCase.java
@@ -40,9 +40,11 @@ import 
org.apache.flink.runtime.minicluster.MiniClusterConfiguration;
 import org.apache.flink.runtime.scheduler.DefaultScheduler;
 import org.apache.flink.runtime.testutils.CommonTestUtils;
 import org.apache.flink.runtime.testutils.WaitingCancelableInvokable;
+import org.apache.flink.testutils.junit.FailsWithAdaptiveScheduler;
 import org.apache.flink.util.TestLogger;
 
 import org.junit.Test;
+import org.junit.experimental.categories.Category;
 
 import java.io.IOException;
 import java.time.Duration;
@@ -61,11 +63,13 @@ public class DefaultSchedulerLocalRecoveryITCase extends 
TestLogger {
     private static final long TIMEOUT = 10_000L;
 
     @Test
+    @Category(FailsWithAdaptiveScheduler.class) // FLINK-21450
     public void testLocalRecoveryFull() throws Exception {
         testLocalRecoveryInternal("full");
     }
 
     @Test
+    @Category(FailsWithAdaptiveScheduler.class) // FLINK-21450
     public void testLocalRecoveryRegion() throws Exception {
         testLocalRecoveryInternal("region");
     }