[FLINK-7600] shorten delay of KinesisProducerConfiguration.setCredentialsRefreshDelay() to avoid updateCredentials Exception

• Type: Bug
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.3.2
• Fix Version/s: 1.3.4, 1.4.0
• Component/s: Connectors / Kinesis
• Assignee: Bowen Li
• Reporter: Bowen Li
• Created: 07/Sep/17 21:34
• Updated: 12/Mar/18 15:47
• Resolved: 12/Mar/18 15:47

Description

we saw the following warning in Flink log:

2017-08-11 02:33:24,473 WARN  org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.producer.Daemon  - Exception during updateCredentials
java.lang.InterruptedException: sleep interrupted
	at java.lang.Thread.sleep(Native Method)
	at org.apache.flink.kinesis.shaded.com.amazonaws.services.kinesis.producer.Daemon$5.run(Daemon.java:316)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
	at java.util.concurrent.FutureTask.run(FutureTask.java:266)
	at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
	at java.lang.Thread.run(Thread.java:748)

According to discussion in https://github.com/awslabs/amazon-kinesis-producer/issues/10, setting the delay to 100 will fix this issue

Issue Links

• links to: GitHub Pull Request #4657