Krish Narukulla
03/15/2023, 6:56 PM2023-03-15 18:45:43,383 INFO org.apache.flink.runtime.taskmanager.Task [] - Attempting to cancel task Source: ics_raw[1] -> (Calc[2] -> Calc[3] -> sink_kafka[4]: Writer -> sink_kafka[4]: Committer, Calc[5]) (28/32)#3754 (7a8b9af226cd4e016196e035ecd2d11a_e3dfc0d7e9ecd8a43f85f0b68ebf3b80_27_3754).
2023-03-15 18:45:43,383 INFO org.apache.flink.runtime.taskmanager.Task [] - Task Source: ics_raw[1] -> (Calc[2] -> Calc[3] -> sink_kafka[4]: Writer -> sink_kafka[4]: Committer, Calc[5]) (28/32)#3754 is already in state FAILED
2023-03-15 18:45:43,383 WARN org.apache.flink.runtime.taskmanager.Task [] - Source: ics_raw[1] -> (Calc[2] -> Calc[3] -> sink_kafka[4]: Writer -> sink_kafka[4]: Committer, Calc[5]) (32/32)#3754 (7a8b9af226cd4e016196e035ecd2d11a_e3dfc0d7e9ecd8a43f85f0b68ebf3b80_31_3754) switched from DEPLOYING to FAILED with failure cause: java.lang.IllegalStateException: The library registration references a different set of library BLOBs than previous registrations for this job:
old:[p-72449e261468158ece284f84d3d13d5995e23b89-295012ce09be8c6d30610c99e0563bf1]
new:[p-72449e261468158ece284f84d3d13d5995e23b89-14ef7154e3312d2ce68d9fb6776e5b7f]
at org.apache.flink.runtime.execution.librarycache.BlobLibraryCacheManager$ResolvedClassLoader.verifyClassLoader(BlobLibraryCacheManager.java:419)Krish Narukulla
03/16/2023, 7:12 AM