Hi,
With flink 1.11.1 version, taskmanager initialization is failing with below
error. Could you please help to debug the issue.
log":"[main] org.apache.flink.runtime.io.network.netty.NettyConfig NettyConfig
[server address: /0.0.0.0, server port: 4121, ssl enabled: false, memory
segment size (bytes): 32768, transport type: AUTO, number of server threads: 4
(manual), number of client threads: 4 (manual), server connect backlog: 0 (use
Netty's default), client connect timeout (sec): 120, send/receive buffer size
(bytes): 0 (use Netty's default)]"}
log":"[main] org.apache.flink.runtime.taskexecutor.TaskManagerRunner
TaskManager initialization failed."}
java.lang.NoSuchFieldError: FORCE_PARTITION_RELEASE_ON_CONSUMPTION
at
org.apache.flink.runtime.taskmanager.NettyShuffleEnvironmentConfiguration.fromConfiguration(NettyShuffleEnvironmentConfiguration.java:221)
~[flink-dist_2.11-1.11.1.jar:1.11.1]
at
org.apache.flink.runtime.io.network.NettyShuffleServiceFactory.createShuffleEnvironment(NettyShuffleServiceFactory.java:61)
~[flink-dist_2.11-1.11.1.jar:1.11.1]
at
org.apache.flink.runtime.io.network.NettyShuffleServiceFactory.createShuffleEnvironment(NettyShuffleServiceFactory.java:49)
~[flink-dist_2.11-1.11.1.jar:1.11.1]
at
org.apache.flink.runtime.taskexecutor.TaskManagerServices.createShuffleEnvironment(TaskManagerServices.java:373)
~[flink-dist_2.11-1.11.1.jar:1.11.1]
at
org.apache.flink.runtime.taskexecutor.TaskManagerServices.fromConfiguration(TaskManagerServices.java:270)
~[flink-dist_2.11-1.11.1.jar:1.11.1]
at
org.apache.flink.runtime.taskexecutor.TaskManagerRunner.startTaskManager(TaskManagerRunner.java:375)
~[flink-dist_2.11-1.11.1.jar:1.11.1]
at
org.apache.flink.runtime.taskexecutor.TaskManagerRunner.<init>(TaskManagerRunner.java:157)
~[flink-dist_2.11-1.11.1.jar:1.11.1]
at
org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManager(TaskManagerRunner.java:305)
~[flink-dist_2.11-1.11.1.jar:1.11.1]
at
org.apache.flink.runtime.taskexecutor.TaskManagerRunner.lambda$runTaskManagerSecurely$2(TaskManagerRunner.java:320)
~[flink-dist_2.11-1.11.1.jar:1.11.1]
at java.security.AccessController.doPrivileged(Native Method) ~[?:?]
at javax.security.auth.Subject.doAs(Subject.java:423) ~[?:?]
at
org.apache.hadoop.security.UserGroupInformation.doAs(UserGroupInformation.java:1692)
~[flink-shaded-hadoop-2-uber-2.6.5-7.0.jar:2.6.5-7.0]
at
org.apache.flink.runtime.security.contexts.HadoopSecurityContext.runSecured(HadoopSecurityContext.java:41)
~[flink-dist_2.11-1.11.1.jar:1.11.1]
at
org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManagerSecurely(TaskManagerRunner.java:319)
[flink-dist_2.11-1.11.1.jar:1.11.1]
at
org.apache.flink.runtime.taskexecutor.TaskManagerRunner.main(TaskManagerRunner.java:297)
[flink-dist_2.11-1.11.1.jar:1.11.1]
Thanks,
Suchithra
