[STORM-4069] java.lang.ClassCastException for Trident-based Topology

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 2.6.0, 2.6.1, 2.6.2
• Fix Version/s: 2.6.4
• Assignee: Richard Zowalla
• Reporter: Richard Zowalla
• Created: 09/Aug/24 17:49
• Updated: 31/Aug/24 21:48
• Resolved: 31/Aug/24 21:48

Description

Copied from the mailing list:

 

Upgraded our storm versions to 2.6.3 but having issues on startup. Here is the error log:

2024-08-07 09:30:22.749 o.a.s.u.Utils Thread-22-$mastercoord-bg0-executor[1, 1] [ERROR] Async loop died!

java.lang.ClassCastException: class java.lang.Integer cannot be cast to class java.lang.Long (java.lang.Integer and java.lang.Long are in module java.base of loader 'bootstrap')

  at org.apache.storm.trident.topology.MasterBatchCoordinator.getStoredCurrTransaction(MasterBatchCoordinator.java:235) ~[storm-client-2.6.3.jar:2.6.3]

  at org.apache.storm.trident.topology.MasterBatchCoordinator.open(MasterBatchCoordinator.java:87) ~[storm-client-2.6.3.jar:2.6.3]

  at org.apache.storm.executor.spout.SpoutExecutor.init(SpoutExecutor.java:142) ~[storm-client-2.6.3.jar:2.6.3]

  at org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:152) ~[storm-client-2.6.3.jar:2.6.3]

  at org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:50) ~[storm-client-2.6.3.jar:2.6.3]

  at org.apache.storm.utils.Utils$1.run(Utils.java:393) [storm-client-2.6.3.jar:2.6.3]

  at java.base/java.lang.Thread.run(Thread.java:840) [?:?]

2024-08-07 09:30:22.756 o.a.s.e.e.ReportError Thread-22-$mastercoord-bg0-executor[1, 1] [ERROR] Error

java.lang.RuntimeException: java.lang.ClassCastException: class java.lang.Integer cannot be cast to class java.lang.Long (java.lang.Integer and java.lang.Long are in module java.base of loader 'bootstrap')

  at org.apache.storm.utils.Utils$1.run(Utils.java:413) ~[storm-client-2.6.3.jar:2.6.3]

  at java.base/java.lang.Thread.run(Thread.java:840) [?:?]

Caused by: java.lang.ClassCastException: class java.lang.Integer cannot be cast to class java.lang.Long (java.lang.Integer and java.lang.Long are in module java.base of loader 'bootstrap')

  at org.apache.storm.trident.topology.MasterBatchCoordinator.getStoredCurrTransaction(MasterBatchCoordinator.java:235) ~[storm-client-2.6.3.jar:2.6.3]

  at org.apache.storm.trident.topology.MasterBatchCoordinator.open(MasterBatchCoordinator.java:87) ~[storm-client-2.6.3.jar:2.6.3]

  at org.apache.storm.executor.spout.SpoutExecutor.init(SpoutExecutor.java:142) ~[storm-client-2.6.3.jar:2.6.3]

  at org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:152) ~[storm-client-2.6.3.jar:2.6.3]

  at org.apache.storm.executor.spout.SpoutExecutor.call(SpoutExecutor.java:50) ~[storm-client-2.6.3.jar:2.6.3]

  at org.apache.storm.utils.Utils$1.run(Utils.java:393) ~[storm-client-2.6.3.jar:2.6.3]

  ... 1 more

2024-08-07 09:30:22.788 o.a.s.u.Utils Thread-22-$mastercoord-bg0-executor[1, 1] [ERROR] Halting process: Worker died