Repository: flink Updated Branches: refs/heads/release-1.3 571cda729 -> 37ded17a6
[FLINK-7600] [kinesis] Shorten credential update delay to avoid updateCredentials Exception The updateCredentials delay is an ignorable warning that occurs due to the fact that the default credential update delay is longer than the await termination timeout when shutting down KPL. See https://github.com/awslabs/amazon-kinesis-producer/issues/10 for details. This closes #4657. Project: http://git-wip-us.apache.org/repos/asf/flink/repo Commit: http://git-wip-us.apache.org/repos/asf/flink/commit/cc0de848 Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/cc0de848 Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/cc0de848 Branch: refs/heads/release-1.3 Commit: cc0de8486b2c83bf03da0f8115df4b5ff72f6ed6 Parents: 571cda7 Author: Bowen Li <bowenl...@gmail.com> Authored: Thu Sep 7 14:36:28 2017 -0700 Committer: Tzu-Li (Gordon) Tai <tzuli...@apache.org> Committed: Fri Sep 22 11:50:22 2017 +0200 ---------------------------------------------------------------------- .../streaming/connectors/kinesis/FlinkKinesisProducer.java | 5 +++++ 1 file changed, 5 insertions(+) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/flink/blob/cc0de848/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java ---------------------------------------------------------------------- diff --git a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java index 579bd6b..1cca822 100644 --- a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java +++ b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java @@ -181,6 +181,11 @@ public class FlinkKinesisProducer<OUT> extends RichSinkFunction<OUT> { ProducerConfigConstants.AGGREGATION_MAX_COUNT, producerConfig.getAggregationMaxCount(), LOG)); } + // we explicitly lower the credential refresh delay (default is 5 seconds) + // to avoid a ignorable interruption warning that occurs when shutting down the + // KPL client. See https://github.com/awslabs/amazon-kinesis-producer/issues/10. + producerConfig.setCredentialsRefreshDelay(100); + producer = new KinesisProducer(producerConfig); callback = new FutureCallback<UserRecordResult>() { @Override
