Hi flink team, I am implementing a flink job, whic...
# troubleshooting
l
Hi flink team, I am implementing a flink job, which reads avro data from our s3 bucket, and encountered this error in the job. Not sure how to deal with this issue. Can I get some help for this? Thanks!
Copy code
2023-09-05 23:35:39,789 ERROR org.apache.flink.runtime.entrypoint.ClusterEntrypoint        [] - Could not start cluster entrypoint KubernetesApplicationClusterEntrypoint.
org.apache.flink.runtime.entrypoint.ClusterEntrypointException: Failed to initialize the cluster entrypoint KubernetesApplicationClusterEntrypoint.
	at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:255) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:729) [flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.kubernetes.entrypoint.KubernetesApplicationClusterEntrypoint.main(KubernetesApplicationClusterEntrypoint.java:86) [flink-dist-1.17.0.jar:1.17.0]
Caused by: org.apache.flink.util.FlinkRuntimeException: java.lang.IllegalStateException: Delegation token provider with service name {} has multiple implementations [s3]
	at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.lambda$loadProviders$0(DefaultDelegationTokenManager.java:151) ~[flink-dist-1.17.0.jar:1.17.0]
	at java.util.Iterator.forEachRemaining(Unknown Source) ~[?:?]
	at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.loadProviders(DefaultDelegationTokenManager.java:156) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.<init>(DefaultDelegationTokenManager.java:111) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.security.token.DefaultDelegationTokenManagerFactory.create(DefaultDelegationTokenManagerFactory.java:50) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:392) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:282) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:232) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:229) ~[flink-dist-1.17.0.jar:1.17.0]
	... 2 more
Caused by: java.lang.IllegalStateException: Delegation token provider with service name {} has multiple implementations [s3]
	at org.apache.flink.util.Preconditions.checkState(Preconditions.java:215) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.lambda$loadProviders$0(DefaultDelegationTokenManager.java:133) ~[flink-dist-1.17.0.jar:1.17.0]
	at java.util.Iterator.forEachRemaining(Unknown Source) ~[?:?]
	at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.loadProviders(DefaultDelegationTokenManager.java:156) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.<init>(DefaultDelegationTokenManager.java:111) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.security.token.DefaultDelegationTokenManagerFactory.create(DefaultDelegationTokenManagerFactory.java:50) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:392) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:282) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:232) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28) ~[flink-dist-1.17.0.jar:1.17.0]
	at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:229) ~[flink-dist-1.17.0.jar:1.17.0]