Swap to v1

apache · Nov 1, 2024 · c3b8931 · c3b8931
1 parent 0b0387d
commit c3b8931
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java b/...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;