Skip to content

Commit

Permalink
[FLINK-22464][runtime][tests] Disable a test failing with AdaptiveSch…
Browse files Browse the repository at this point in the history
…eduler tracked in FLINK-22464
  • Loading branch information
rmetzger committed May 25, 2021
1 parent d67064d commit 80ad5b3
Showing 1 changed file with 3 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -46,6 +46,7 @@
import org.apache.flink.streaming.api.datastream.DataStream;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.streaming.util.TestStreamEnvironment;
import org.apache.flink.testutils.junit.FailsWithAdaptiveScheduler;
import org.apache.flink.util.SerializedValue;
import org.apache.flink.util.TestLogger;
import org.apache.flink.util.function.TriFunction;
Expand All @@ -54,6 +55,7 @@
import org.junit.AfterClass;
import org.junit.BeforeClass;
import org.junit.Test;
import org.junit.experimental.categories.Category;

import javax.annotation.Nullable;

Expand Down Expand Up @@ -124,6 +126,7 @@ public void testOperatorEventLostNoReaderFailure() throws Exception {
* additionally a failure on the reader that triggers recovery.
*/
@Test
@Category(FailsWithAdaptiveScheduler.class) // FLINK-22464
public void testOperatorEventLostWithReaderFailure() throws Exception {
final int[] eventsToLose = new int[] {1, 3};

Expand Down

0 comments on commit 80ad5b3

Please sign in to comment.