Gabor Somogyi created FLINK-31839: ------------------------------------- Summary: It's not possible to add flink-s3-fs-hadoop and flink-s3-fs-presto plugins at the same time Key: FLINK-31839 URL: https://issues.apache.org/jira/browse/FLINK-31839 Project: Flink Issue Type: Bug Components: API / Core Affects Versions: 1.17.0 Reporter: Gabor Somogyi
{code:java} 2023-04-07 09:18:32,814 [main] ERROR org.apache.flink.runtime.security.token.DefaultDelegationTokenManager [] - Failed to initialize delegation token provider s3 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 java.security.AccessController.doPrivileged(Native Method) ~[?:?] at javax.security.auth.Subject.doAs(Unknown Source) [?:?] at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1844) [hadoop-common-2.8.5.jar:?] at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) [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] at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:729) [flink-dist-1.17.0.jar:1.17.0] at org.apache.flink.container.entrypoint.StandaloneApplicationClusterEntryPoint.main(StandaloneApplicationClusterEntryPoint.java:82) [flink-dist-1.17.0.jar:1.17.0] 2023-04-07 09:18:32,824 [main] INFO org.apache.flink.runtime.entrypoint.ClusterEntrypoint [] - Shutting StandaloneApplicationClusterEntryPoint down with application status FAILED. Diagnostics 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) at java.base/java.util.Iterator.forEachRemaining(Unknown Source) at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.loadProviders(DefaultDelegationTokenManager.java:156) at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.<init>(DefaultDelegationTokenManager.java:111) at org.apache.flink.runtime.security.token.DefaultDelegationTokenManagerFactory.create(DefaultDelegationTokenManagerFactory.java:50) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.initializeServices(ClusterEntrypoint.java:392) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runCluster(ClusterEntrypoint.java:282) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.lambda$startCluster$1(ClusterEntrypoint.java:232) at java.base/java.security.AccessController.doPrivileged(Native Method) at java.base/javax.security.auth.Subject.doAs(Unknown Source) at org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1844) at org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.startCluster(ClusterEntrypoint.java:229) at org.apache.flink.runtime.entrypoint.ClusterEntrypoint.runClusterEntrypoint(ClusterEntrypoint.java:729) at org.apache.flink.container.entrypoint.StandaloneApplicationClusterEntryPoint.main(StandaloneApplicationClusterEntryPoint.java:82) 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) at org.apache.flink.runtime.security.token.DefaultDelegationTokenManager.lambda$loadProviders$0(DefaultDelegationTokenManager.java:133) ... 14 more {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)