From b35d052a2f412ea11c2920f19d089b3a78853072 Mon Sep 17 00:00:00 2001 From: Hong Teoh Date: Mon, 4 Nov 2024 07:48:11 +0000 Subject: [PATCH] Fix test --- .../FanOutKinesisShardSplitReaderTest.java | 22 ------------------- 1 file changed, 22 deletions(-) diff --git a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSplitReaderTest.java b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSplitReaderTest.java index 0ab51c65..e065d4d2 100644 --- a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/flink/connector/kinesis/source/reader/fanout/FanOutKinesisShardSplitReaderTest.java +++ b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/test/java/org/apache/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 =