You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by tz...@apache.org on 2017/09/22 09:45:05 UTC
[2/3] flink git commit: [FLINK-7600] [kinesis] Shorten credential
update delay to avoid updateCredentials Exception
[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/6c1a9465
Tree: http://git-wip-us.apache.org/repos/asf/flink/tree/6c1a9465
Diff: http://git-wip-us.apache.org/repos/asf/flink/diff/6c1a9465
Branch: refs/heads/master
Commit: 6c1a946562ec8ac4825b871aefdec040cc02aaf2
Parents: 637dde8
Author: Bowen Li <bo...@gmail.com>
Authored: Thu Sep 7 14:36:28 2017 -0700
Committer: Tzu-Li (Gordon) Tai <tz...@apache.org>
Committed: Fri Sep 22 11:43:54 2017 +0200
----------------------------------------------------------------------
.../streaming/connectors/kinesis/util/KinesisConfigUtil.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/flink/blob/6c1a9465/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
----------------------------------------------------------------------
diff --git a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
index 70975db..cadde8d 100644
--- a/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
+++ b/flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
@@ -194,6 +194,11 @@ public class KinesisConfigUtil {
kpc.setCredentialsProvider(AWSUtil.getCredentialsProvider(config));
+ // 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.
+ kpc.setCredentialsRefreshDelay(100);
+
// Because of bug https://github.com/awslabs/amazon-kinesis-producer/issues/124
// KPL cannot set ThreadingModel and ThreadPoolSize using Java reflection
// Thus we have to set them explicitly