Fix test

apache · Nov 4, 2024 · b35d052 · b35d052
1 parent 720fad3
commit b35d052
Showing 1 changed file with 0 additions and 22 deletions.
diff --git a/...pache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSplitReaderTest.java b/...pache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSplitReaderTest.java
@@ -131,28 +131,6 @@ public void testSplitWithExpiredShardHandledAsCompleted() throws Exception {
         assertThat(retrievedRecords.finishedSplits()).containsExactly(TEST_SHARD_ID);
     }
 
-    @Test
-    public void testSingleAssignedSplitAllConsumed() throws Exception {
-        // Given Kinesis configured with single shard
-        testAsyncStreamProxy =
-                FakeKinesisFanOutBehaviorsFactory.boundedShard()
-                        .withBatchCount(10)
-                        .withRecordsPerBatch(5)
-                        .build();
-        splitReader =
-                new FanOutKinesisShardSplitReader(
-                        testAsyncStreamProxy,
-                        CONSUMER_ARN,
-                        shardMetricGroupMap,
-                        TEST_SUBSCRIPTION_TIMEOUT);
-        splitReader.handleSplitsChanges(
-                new SplitsAddition<>(Collections.singletonList(getTestSplit(TEST_SHARD_ID))));
-
-        // When consume all records
-        // Then we consume all 50 records
-        consumeAllRecordsFromKinesis(splitReader, 50);
-    }
-
     @Test
     public void testWakeUpIsNoOp() {
         splitReader =