This is an automated email from the ASF dual-hosted git repository.
sewen pushed a change to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git.
from bbae6a1 [FLINK-23802][kinesis][efo] Request next record from the
Flink source thread rather than the AWS SDK response thread. Increase Read
Timeout to 6m, higher than the maximum Shard subscription duration (5m) and
enable TCP keep alive.
add b477faf [FLINK-22211][datastream] Only log exceptions if job has been
initialized
No new revisions were added by this update.
Summary of changes:
.../streaming/api/operators/collect/CollectResultFetcher.java | 10 +++++++++-
1 file changed, 9 insertions(+), 1 deletion(-)
