我尝试在本地(Win 10 平台)上启动 flink(v1.15.0)作为独立集群,但任务管理器无法启动,导致可用任务槽数为零。
已经关注过诸如this之类的链接,但问题仍然存在。
请查找如下日志:
错误 StatusLogger 重新配置失败:在“null”中的“null”处找不到“30946e09”的配置 错误 StatusLogger 重新配置失败:在“null”中的“null”处找不到“3e2059ae”的配置 22:11:46.825 [main] 错误 org.apache.flink.runtime.taskexecutor.TaskManagerRunner - 终止 TaskManagerRunner,退出代码为 1。 org.apache.flink.util.FlinkException:无法启动 TaskManagerRunner。 在 org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManager(TaskManagerRunner.java:483) ~[flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.taskexecutor.TaskManagerRunner.lambda$runTaskManagerProcessSecurely$5(TaskManagerRunner.java:525) ~[flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28) ~[flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManagerProcessSecurely(TaskManagerRunner.java:525) [flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManagerProcessSecurely(TaskManagerRunner.java:505) [flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.taskexecutor.TaskManagerRunner.main(TaskManagerRunner.java:463) [flink-dist-1.15.0.jar:1.15.0] 原因:java.io.IOException:无法创建工作目录 C:\Users\mohile\AppData\Local\Temp m_localhost:56106-13fd70。 在 org.apache.flink.runtime.entrypoint.WorkingDirectory.createDirectory(WorkingDirectory.java:58) ~[flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.entrypoint.WorkingDirectory.(WorkingDirectory.java:39) ~[flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.entrypoint.WorkingDirectory.create(WorkingDirectory.java:88) ~[flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.entrypoint.ClusterEntrypointUtils.lambda$createTaskManagerWorkingDirectory$0(ClusterEntrypointUtils.java:152) ~[flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.entrypoint.DeterminismEnvelope.map(DeterminismEnvelope.java:49) ~[flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.entrypoint.ClusterEntrypointUtils.createTaskManagerWorkingDirectory(ClusterEntrypointUtils.java:150) ~[flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.taskexecutor.TaskManagerRunner.startTaskManagerRunnerServices(TaskManagerRunner.java:210) ~[flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.taskexecutor.TaskManagerRunner.start(TaskManagerRunner.java:288) ~[flink-dist-1.15.0.jar:1.15.0] 在 org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManager(TaskManagerRunner.java:481) ~[flink-dist-1.15.0.jar:1.15.0] ... 5 更多 警告:发生了非法反射访问操作 警告:org.jboss.netty.util.internal.ByteBufferUtil 进行非法反射访问(文件:/C:/Users/mohile/AppData/Local/Temp/flink-rpc-akka_38e8d879-8c2e-46b3-8ff6-163f77c989d6.jar)方法 java.nio.DirectByteBuffer.cleaner() 警告:请考虑将此问题报告给 org.jboss.netty.util.internal.ByteBufferUtil 的维护者 警告:使用 --illegal-access=warn 启用进一步非法反射访问操作的警告 警告:所有非法访问操作将在未来版本中被拒绝
任何帮助表示赞赏..
我是这样解决的
taskmanager.resource-id : 50329fc0146
在 flink-conf.yaml 中添加此属性