Re: Re: [ANNOUNCE] Apache Flink 1.15.1 released

Mon, 25 Jul 2022 06:12:17 -0700

I've added 'taskmanager.resource-id' option to config file and seems it works. Thank you!
 
 
Sent: Tuesday, July 12, 2022 at 12:02 PM
From: "Gabor Somogyi" <gabor.g.somo...@gmail.com>
To: pod...@gmx.com
Cc: "user" <user@flink.apache.org>
Subject: Re: Re: [ANNOUNCE] Apache Flink 1.15.1 released
In order to provide a hotfix please set "taskmanager.resource-id" to something which doesn't contain special any character.
 
G
 
 
On Tue, Jul 12, 2022 at 11:59 AM Gabor Somogyi <gabor.g.somo...@gmail.com> wrote:
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:

We would like to thank all contributors of the Apache Flink community who made this release possible!
 
Regards,
David Anderson
 
 

Reply via email to