From c3b8931313ee4355571cfb9e53968eb756854435 Mon Sep 17 00:00:00 2001 From: Hong Teoh Date: Fri, 1 Nov 2024 17:29:30 +0000 Subject: [PATCH] Swap to v1 --- .../flink/connector/kinesis/source/KinesisStreamsSource.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java index ea57fc4e..40f9fce8 100644 --- a/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java +++ b/flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java @@ -46,8 +46,8 @@ import org.apache.flink.connector.kinesis.source.proxy.StreamProxy; import org.apache.flink.connector.kinesis.source.reader.KinesisStreamsRecordEmitter; import org.apache.flink.connector.kinesis.source.reader.KinesisStreamsSourceReader; +import org.apache.flink.connector.kinesis.source.reader.fanout.FanOutKinesisShardSplitReader; import org.apache.flink.connector.kinesis.source.reader.fanout.StreamConsumerRegistrar; -import org.apache.flink.connector.kinesis.source.reader.fanoutv2.FanOutKinesisShardSplitReader; import org.apache.flink.connector.kinesis.source.reader.polling.PollingKinesisShardSplitReader; import org.apache.flink.connector.kinesis.source.serialization.KinesisDeserializationSchema; import org.apache.flink.connector.kinesis.source.split.KinesisShardSplit;