From df95de637befa5c251d0bc4fc63b6a9cf280ab4f Mon Sep 17 00:00:00 2001 From: Kenneth Knowles Date: Mon, 5 Feb 2018 19:18:38 -0800 Subject: [PATCH] Sickbay flaky KinesisIO tests --- .../org/apache/beam/sdk/io/kinesis/ShardReadersPoolTest.java | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/ShardReadersPoolTest.java b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/ShardReadersPoolTest.java index f25b684a3270..77eab4a533d2 100644 --- a/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/ShardReadersPoolTest.java +++ b/sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/ShardReadersPoolTest.java @@ -35,6 +35,7 @@ import java.util.List; import java.util.concurrent.TimeUnit; import org.junit.Before; +import org.junit.Ignore; import org.junit.Test; import org.junit.runner.RunWith; import org.mockito.Mock; @@ -158,6 +159,7 @@ public void shouldInterruptKinesisReadingAndStopShortly() } @Test + @Ignore("https://issues.apache.org/jira/browse/BEAM-3599") public void shouldInterruptPuttingRecordsToQueueAndStopShortly() throws TransientKinesisException, KinesisShardClosedException { when(firstIterator.readNextBatch()).thenReturn(asList(a, b, c)); @@ -230,6 +232,7 @@ public void shouldStopReadersPoolWhenLastShardReaderStopped() throws Exception { } @Test + @Ignore("https://issues.apache.org/jira/browse/BEAM-3598") public void shouldStopReadersPoolAlsoWhenExceptionsOccurDuringStopping() throws Exception { when(firstIterator.readNextBatch()).thenThrow(KinesisShardClosedException.class); when(firstIterator.findSuccessiveShardRecordIterators()) @@ -256,6 +259,7 @@ public void shouldReturnAbsentOptionalWhenStartedWithNoIterators() throws Except } @Test + @Ignore("https://issues.apache.org/jira/browse/BEAM-3605") public void shouldForgetClosedShardIterator() throws Exception { when(firstIterator.readNextBatch()).thenThrow(KinesisShardClosedException.class); when(firstIterator.findSuccessiveShardRecordIterators())