From c0e8c55a687b5f64c54c1eac3c83f63642f44d82 Mon Sep 17 00:00:00 2001
From: Thomas Groh <tgroh@google.com>
Date: Tue, 6 Feb 2018 09:19:21 -0800
Subject: [PATCH] Sickbay Kinesis ShardReadersPoolTest

shouldStopReadersPoolAlsoWhenExceptionsOccurDuringStopping is quite
flaky, due to missing mock interactions.
---
 .../org/apache/beam/sdk/io/kinesis/ShardReadersPoolTest.java    | 2 ++
 1 file changed, 2 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..fb941006005a 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;
@@ -230,6 +231,7 @@ public void shouldStopReadersPoolWhenLastShardReaderStopped() throws Exception {
   }
 
   @Test
+  @Ignore("BEAM-3598")
   public void shouldStopReadersPoolAlsoWhenExceptionsOccurDuringStopping() throws Exception {
     when(firstIterator.readNextBatch()).thenThrow(KinesisShardClosedException.class);
     when(firstIterator.findSuccessiveShardRecordIterators())