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())