Skip to content

Commit 4293702

Browse files
committed
[hotfix][Connectors/Kinesis] Pass source configuration to SplitFetcherManager
1 parent b55dec1 commit 4293702

File tree

1 file changed

+2
-1
lines changed

1 file changed

+2
-1
lines changed

flink-connector-aws/flink-connector-aws-kinesis-streams/src/main/java/org/apache/flink/connector/kinesis/source/KinesisStreamsSource.java

+2-1
Original file line numberDiff line numberDiff line change
@@ -167,7 +167,8 @@ public SourceReader<T, KinesisShardSplit> createReader(SourceReaderContext reade
167167
new KinesisStreamsRecordEmitter<>(deserializationSchema);
168168
return new KinesisStreamsSourceReader<>(
169169
new SingleThreadFetcherManager<>(
170-
getKinesisShardSplitReaderSupplier(sourceConfig, shardMetricGroupMap)),
170+
getKinesisShardSplitReaderSupplier(sourceConfig, shardMetricGroupMap),
171+
sourceConfig),
171172
recordEmitter,
172173
sourceConfig,
173174
readerContext,

0 commit comments

Comments
 (0)