[STORM-3609] ClassCastException when credentials are updated for ICredentialsListener spout/bolt instances

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.0.0, 2.1.0
• Fix Version/s: 2.2.0, 2.1.1
• Labels: pull-request-available
• Assignee: Ethan Li
• Reporter: Ethan Li
• Created: 26/Mar/20 22:24
• Updated: 01/Jul/20 14:07
• Resolved: 30/Mar/20 15:05

Description

2020-03-26 21:04:38.526 o.a.s.u.Utils Thread-14-spout-executor[2, 2] [ERROR] Async loop died!
java.lang.RuntimeException: java.lang.ClassCastException: org.apache.storm.generated.Credentials cannot be cast to java.util.Map
	at org.apache.storm.executor.Executor.accept(Executor.java:291) ~[storm-client-2.2.0.y.jar:2.2.0.y]
	at org.apache.storm.utils.JCQueue.consumeImpl(JCQueue.java:131) ~[storm-client-2.2.0.y.jar:2.2.0.y]
	at org.apache.storm.utils.JCQueue.consume(JCQueue.java:111) ~[storm-client-2.2.0.y.jar:2.2.0.y]
	at org.apache.storm.utils.JCQueue.consume(JCQueue.java:102) ~[storm-client-2.2.0.y.jar:2.2.0.y]
	at org.apache.storm.executor.spout.SpoutExecutor$2.call(SpoutExecutor.java:170) ~[storm-client-2.2.0.y.jar:2.2.0.y]
	at org.apache.storm.executor.spout.SpoutExecutor$2.call(SpoutExecutor.java:159) ~[storm-client-2.2.0.y.jar:2.2.0.y]
	at org.apache.storm.utils.Utils$1.run(Utils.java:433) [storm-client-2.2.0.y.jar:2.2.0.y]
	at java.lang.Thread.run(Thread.java:748) [?:1.8.0_242]
Caused by: java.lang.ClassCastException: org.apache.storm.generated.Credentials cannot be cast to java.util.Map
	at org.apache.storm.executor.spout.SpoutExecutor.tupleActionFn(SpoutExecutor.java:303) ~[storm-client-2.2.0.y.jar:2.2.0.y]
	at org.apache.storm.executor.Executor.accept(Executor.java:287) ~[storm-client-2.2.0.y.jar:2.2.0.y]
	... 7 more

note: "2.2.0.y" is our internal version, which is master branch.

Issue Links

• links to: GitHub Pull Request #3239