Flink tried to create the following dir: tm_localhost:50329-fc0146 Colon is allowed on linux but not on windows and that's the reason of the exception.
BR, G On Tue, Jul 12, 2022 at 11:30 AM <pod...@gmx.com> wrote: > ... > 2022-07-12 11:25:08,448 INFO > akka.remote.Remoting [] - Remoting > started; listening on addresses :[akka.tcp://flink@localhost:50329] > 2022-07-12 11:25:08,658 INFO > org.apache.flink.runtime.rpc.akka.AkkaRpcServiceUtils [] - Actor > system started at akka.tcp://flink@localhost:50329 > 2022-07-12 11:25:08,683 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:483) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.lambda$runTaskManagerProcessSecurely$5(TaskManagerRunner.java:525) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.security.contexts.NoOpSecurityContext.runSecured(NoOpSecurityContext.java:28) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManagerProcessSecurely(TaskManagerRunner.java:525) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManagerProcessSecurely(TaskManagerRunner.java:505) > [flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.main(TaskManagerRunner.java:463) > [flink-dist-1.15.1.jar:1.15.1] > Caused by: java.io.IOException: Could not create the working directory > C:\Users\MIKE~1\AppData\Local\Temp\tm_localhost:50329-fc0146. > at > org.apache.flink.runtime.entrypoint.WorkingDirectory.createDirectory(WorkingDirectory.java:58) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.entrypoint.WorkingDirectory.<init>(WorkingDirectory.java:39) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.entrypoint.WorkingDirectory.create(WorkingDirectory.java:88) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.entrypoint.ClusterEntrypointUtils.lambda$createTaskManagerWorkingDirectory$0(ClusterEntrypointUtils.java:152) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.entrypoint.DeterminismEnvelope.map(DeterminismEnvelope.java:49) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.entrypoint.ClusterEntrypointUtils.createTaskManagerWorkingDirectory(ClusterEntrypointUtils.java:150) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.startTaskManagerRunnerServices(TaskManagerRunner.java:210) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.start(TaskManagerRunner.java:288) > ~[flink-dist-1.15.1.jar:1.15.1] > at > org.apache.flink.runtime.taskexecutor.TaskManagerRunner.runTaskManager(TaskManagerRunner.java:481) > ~[flink-dist-1.15.1.jar:1.15.1] > ... 5 more > 2022-07-12 11:25:08,700 INFO > org.apache.flink.runtime.rpc.akka.AkkaRpcService [] - Stopping > Akka RPC service. > 2022-07-12 11:25:08,820 INFO > akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Shutting > down remote daemon. > 2022-07-12 11:25:08,823 INFO > akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Remote > daemon shut down; proceeding with flushing remote transports. > 2022-07-12 11:25:08,870 INFO > akka.remote.RemoteActorRefProvider$RemotingTerminator [] - Remoting > shut down. > > Another log file: > > WARNING: An illegal reflective access operation has occurred > WARNING: Illegal reflective access by > org.jboss.netty.util.internal.ByteBufferUtil > (file:/C:/Users/MIKE~1/AppData/Local/Temp/flink-rpc-akka_0dcbf78d-8e4f-4f57-ae73-8cf2bdb0bb61.jar) > to method java.nio.DirectByteBuffer.cleaner() > WARNING: Please consider reporting this to the maintainers of > org.jboss.netty.util.internal.ByteBufferUtil > WARNING: Use --illegal-access=warn to enable warnings of further illegal > reflective access operations > WARNING: All illegal access operations will be denied in a future release > > > *Sent:* Monday, July 11, 2022 at 11:36 PM > *From:* "Alexander Fedulov" <alexan...@ververica.com> > *To:* "user" <user@flink.apache.org> > *Cc:* pod...@gmx.com > *Subject:* Re: Re: [ANNOUNCE] Apache Flink 1.15.1 released > Hi podunk, > please share exceptions that you find in the log/ folder of your Flink > distribution. > The Taskmanger startup issues should be captured in the *-taskexecutor-* > files. > Best, > Alexander Fedulov > > On Mon, Jul 11, 2022 at 5:42 PM Xuyang <xyzhong...@163.com> wrote: > >> Hi, can you provide the error log so that we can locate the problem? >> >> >> 在 2022-07-11 03:36:00，pod...@gmx.com 写道： >> >> I run Flink in Windows and in version 1.15.1 Task Managers fails to start. >> Works without problems in 1.14.5 >> >> >> *Sent:* Friday, July 08, 2022 at 12:18 AM >> *From:* "David Anderson" <dander...@apache.org> >> *To:* "dev" <d...@flink.apache.org>, "user" <user@flink.apache.org>, >> "user-zh" <user...@flink.apache.org>, annou...@apache.org >> *Subject:* [ANNOUNCE] Apache Flink 1.15.1 released >> >> The Apache Flink community is very happy to announce the release of >> Apache Flink 1.15.1, which is the first bugfix release for the Apache Flink >> 1.15 series. >> >> Apache Flink® is an open-source stream processing framework for >> distributed, high-performing, always-available, and accurate data streaming >> applications. >> >> The release is available for download at: >> https://flink.apache.org/downloads.html >> >> Please check out the release blog post for an overview of the >> improvements for this bugfix release: >> >> https://flink.apache.org/news/2022/07/06/release-1.15.1.html >> >> The full release notes are available in Jira: >> >> >> https://issues.apache.org/jira/secure/ReleaseNote.jspa?projectId=12315522&version=12351546 >> >> We would like to thank all contributors of the Apache Flink community who >> made this release possible! >> >> Regards, >> David Anderson >> >> >> >>
