Hello, We have been facing this weird issue, where we are getting below exception and the job is getting restarted with new task managers. We are using flink 1.17. Same job works fine with lower number of task managers. (<10)
java.lang.IllegalStateException: The library registration references a different set of library BLOBs than previous registrations for this job: old:[p-ecf88f3c5c35842d7bca235cfd7592c53f9fdbe0-e06122dd51cccba866932318dc031d68] new:[p-ecf88f3c5c35842d7bca235cfd7592c53f9fdbe0-7651f69109 c915ac830aa42ce2ab67f0] at org.apache.flink.runtime.execution.librarycache. BlobLibraryCacheManager$ResolvedClassLoader.verifyClassLoader( BlobLibraryCacheManager.java:419) at org.apache.flink.runtime.execution.librarycache. BlobLibraryCacheManager$ResolvedClassLoader.access$500( BlobLibraryCacheManager.java:359) at org.apache.flink.runtime.execution.librarycache. BlobLibraryCacheManager$LibraryCacheEntry.getOrResolveClassLoader( BlobLibraryCacheManager.java:235) at org.apache.flink.runtime.execution.librarycache. BlobLibraryCacheManager$LibraryCacheEntry.access$1100( BlobLibraryCacheManager.java:202) at org.apache.flink.runtime.execution.librarycache. BlobLibraryCacheManager$DefaultClassLoaderLease.getOrResolveClassLoader( BlobLibraryCacheManager.java:336) at org.apache.flink.runtime.taskmanager.Task.createUserCodeClassloader(Task .java:1041) at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:624) at org.apache.flink.runtime.taskmanager.Task.run(Task.java:562) at java.base/java.lang.Thread.run(Unknown Source) Thanks, Prashant
