Hi,这个应该是FLINK-31839已经确定的ISSUE,在1.17.1中已经修复了,可以参考: https://issues.apache.org/jira/browse/FLINK-31839
On Sat, May 6, 2023 at 5:00 PM maker_d...@foxmail.com < maker_d...@foxmail.com> wrote: > flink version:flink-1.17.0 > k8s application模式模式 > > 已经在flink-conf中禁用delegation token: > security.delegation.tokens.enabled: false > > 程序原本是1.13版本开发,正常使用,升级flink版本为1.17.0之后无法启动。 > 起初没有禁用delegation token,JobManager无法启动,禁用delegation > token后JobManager可以正常启动,TaskManager报错如下: > > 2023-05-06 16:52:45,720 INFO > org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository > [] - Delegation token receiver s3 loaded and initialized > 2023-05-06 16:52:45,722 INFO > org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository > [] - Delegation token receiver s3 loaded and initialized > 2023-05-06 16:52:45,723 ERROR > org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository > [] - Failed to initialize delegation token receiver s3 > java.lang.IllegalStateException: Delegation token receiver 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.DelegationTokenReceiverRepository.lambda$loadReceivers$0(DelegationTokenReceiverRepository.java:75) > ~[flink-dist-1.17.0.jar:1.17.0] > at java.util.Iterator.forEachRemaining(Unknown Source) ~[?:?] > at > org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository.loadReceivers(DelegationTokenReceiverRepository.java:98) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository.<init>(DelegationTokenReceiverRepository.java:60) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.startTaskManagerRunnerServices(TaskManagerRunner.java:245) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.start(TaskManagerRunner.java:293) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManager(TaskManagerRunner.java:486) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.lambda$runTaskManagerProcessSecurely$5(TaskManagerRunner.java:530) > ~[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.taskexecutor.TaskManagerRunner.runTaskManagerProcessSecurely(TaskManagerRunner.java:530) > [flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.kubernetes.taskmanager.KubernetesTaskExecutorRunner.runTaskManagerSecurely(KubernetesTaskExecutorRunner.java:66) > [flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.kubernetes.taskmanager.KubernetesTaskExecutorRunner.main(KubernetesTaskExecutorRunner.java:46) > [flink-dist-1.17.0.jar:1.17.0] > 2023-05-06 16:52:45,729 ERROR > org.apache.flink.runtime.taskexecutor.TaskManagerRunner [] - > Terminating TaskManagerRunner with exit code 1. > org.apache.flink.util.FlinkException: Failed to start the > TaskManagerRunner. > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManager(TaskManagerRunner.java:488) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.lambda$runTaskManagerProcessSecurely$5(TaskManagerRunner.java:530) > ~[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.taskexecutor.TaskManagerRunner.runTaskManagerProcessSecurely(TaskManagerRunner.java:530) > [flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.kubernetes.taskmanager.KubernetesTaskExecutorRunner.runTaskManagerSecurely(KubernetesTaskExecutorRunner.java:66) > [flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.kubernetes.taskmanager.KubernetesTaskExecutorRunner.main(KubernetesTaskExecutorRunner.java:46) > [flink-dist-1.17.0.jar:1.17.0] > Caused by: org.apache.flink.util.FlinkRuntimeException: > java.lang.IllegalStateException: Delegation token receiver with service > name {} has multiple implementations [s3] > at > org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository.lambda$loadReceivers$0(DelegationTokenReceiverRepository.java:93) > ~[flink-dist-1.17.0.jar:1.17.0] > at java.util.Iterator.forEachRemaining(Unknown Source) ~[?:?] > at > org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository.loadReceivers(DelegationTokenReceiverRepository.java:98) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository.<init>(DelegationTokenReceiverRepository.java:60) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.startTaskManagerRunnerServices(TaskManagerRunner.java:245) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.start(TaskManagerRunner.java:293) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManager(TaskManagerRunner.java:486) > ~[flink-dist-1.17.0.jar:1.17.0] > ... 5 more > Caused by: java.lang.IllegalStateException: Delegation token receiver 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.DelegationTokenReceiverRepository.lambda$loadReceivers$0(DelegationTokenReceiverRepository.java:75) > ~[flink-dist-1.17.0.jar:1.17.0] > at java.util.Iterator.forEachRemaining(Unknown Source) ~[?:?] > at > org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository.loadReceivers(DelegationTokenReceiverRepository.java:98) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.security.token.DelegationTokenReceiverRepository.<init>(DelegationTokenReceiverRepository.java:60) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.startTaskManagerRunnerServices(TaskManagerRunner.java:245) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.start(TaskManagerRunner.java:293) > ~[flink-dist-1.17.0.jar:1.17.0] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManager(TaskManagerRunner.java:486) > ~[flink-dist-1.17.0.jar:1.17.0] > ... 5 more > > > > maker_d...@foxmail.com > -- Best, Hangxiang.