Skip to content

Commit ce2882b

Browse files
committed
[hotfix] make SplitFetcherManager honor job configuration
1 parent b55dec1 commit ce2882b

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)