You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by David Anderson <da...@apache.org> on 2022/07/07 22:18:01 UTC
[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
Re: Re: [ANNOUNCE] Apache Flink 1.15.1 released
Posted by po...@gmx.com.
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" <ga...@gmail.com>
**To:** podunk@gmx.com
**Cc:** "user" <us...@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.somogyi@gmail.com](mailto:gabor.g.somogyi@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 <[podunk@gmx.com](mailto:podunk@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"
> <[alexander@ververica.com](mailto:alexander@ververica.com)>
> **To:** "user" <[user@flink.apache.org](mailto:user@flink.apache.org)>
> **Cc:** [podunk@gmx.com](mailto:podunk@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
<[xyzhong131@163.com](mailto:xyzhong131@163.com)> wrote:
>>
>>> Hi, can you provide the error log so that we can locate the problem?
>
>>>
>>> 在 2022-07-11 03:36:00，[podunk@gmx.com](mailto:podunk@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"
> <[danderson@apache.org](mailto:danderson@apache.org)>
> **To:** "dev" <[dev@flink.apache.org](mailto:dev@flink.apache.org)>,
> "user" <[user@flink.apache.org](mailto:user@flink.apache.org)>, "user-zh"
> <[user-zh@flink.apache.org](mailto:user-zh@flink.apache.org)>,
> [announce@apache.org](mailto:announce@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](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
>>>>
>>>>
>>>>
>>>>
Re: Re: [ANNOUNCE] Apache Flink 1.15.1 released
Posted by Gabor Somogyi <ga...@gmail.com>.
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 <ga...@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 <po...@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" <al...@ververica.com>
>> *To:* "user" <us...@flink.apache.org>
>> *Cc:* podunk@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 <xy...@163.com> wrote:
>>
>>> Hi, can you provide the error log so that we can locate the problem?
>>>
>>>
>>> 在 2022-07-11 03:36:00，podunk@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" <da...@apache.org>
>>> *To:* "dev" <de...@flink.apache.org>, "user" <us...@flink.apache.org>,
>>> "user-zh" <us...@flink.apache.org>, announce@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
>>>
>>>
>>>
>>>
Re: Re: [ANNOUNCE] Apache Flink 1.15.1 released
Posted by Gabor Somogyi <ga...@gmail.com>.
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 <po...@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" <al...@ververica.com>
> *To:* "user" <us...@flink.apache.org>
> *Cc:* podunk@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 <xy...@163.com> wrote:
>
>> Hi, can you provide the error log so that we can locate the problem?
>>
>>
>> 在 2022-07-11 03:36:00，podunk@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" <da...@apache.org>
>> *To:* "dev" <de...@flink.apache.org>, "user" <us...@flink.apache.org>,
>> "user-zh" <us...@flink.apache.org>, announce@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
>>
>>
>>
>>
Re: Re: [ANNOUNCE] Apache Flink 1.15.1 released
Posted by po...@gmx.com.
...
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" <al...@ververica.com>
**To:** "user" <us...@flink.apache.org>
**Cc:** podunk@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
<[xyzhong131@163.com](mailto:xyzhong131@163.com)> wrote:
> Hi, can you provide the error log so that we can locate the problem?
>
>
> 在 2022-07-11 03:36:00，[podunk@gmx.com](mailto:podunk@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"
> <[danderson@apache.org](mailto:danderson@apache.org)>
> **To:** "dev" <[dev@flink.apache.org](mailto:dev@flink.apache.org)>,
> "user" <[user@flink.apache.org](mailto:user@flink.apache.org)>, "user-zh"
> <[user-zh@flink.apache.org](mailto:user-zh@flink.apache.org)>,
> [announce@apache.org](mailto:announce@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](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
>>
>>
>>
>>
Re: Re: [ANNOUNCE] Apache Flink 1.15.1 released
Posted by Alexander Fedulov <al...@ververica.com>.
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 <xy...@163.com> wrote:
> Hi, can you provide the error log so that we can locate the problem?
>
> 在 2022-07-11 03:36:00，podunk@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" <da...@apache.org>
> *To:* "dev" <de...@flink.apache.org>, "user" <us...@flink.apache.org>,
> "user-zh" <us...@flink.apache.org>, announce@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
>
>
>
>
Re:Re: [ANNOUNCE] Apache Flink 1.15.1 released
Posted by Xuyang <xy...@163.com>.
Hi, can you provide the error log so that we can locate the problem?
在 2022-07-11 03:36:00，podunk@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" <da...@apache.org>
To: "dev" <de...@flink.apache.org>, "user" <us...@flink.apache.org>, "user-zh" <us...@flink.apache.org>, announce@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
Re: [ANNOUNCE] Apache Flink 1.15.1 released
Posted by po...@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" <da...@apache.org>
**To:** "dev" <de...@flink.apache.org>, "user" <us...@flink.apache.org>, "user-
zh" <us...@flink.apache.org>, announce@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](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
Re: [ANNOUNCE] Apache Flink 1.15.1 released
Posted by Xingbo Huang <hx...@gmail.com>.
Thanks a lot for being our release manager David and everyone who
contributed.
Best,
Xingbo
David Anderson <da...@apache.org> 于2022年7月8日周五 06:18写道：
> 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
>
Re: [ANNOUNCE] Apache Flink 1.15.1 released
Posted by Xingbo Huang <hx...@gmail.com>.
Thanks a lot for being our release manager David and everyone who
contributed.
Best,
Xingbo
David Anderson <da...@apache.org> 于2022年7月8日周五 06:18写道：
> 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
>
Re: [ANNOUNCE] Apache Flink 1.15.1 released
Posted by Xingbo Huang <hx...@gmail.com>.
Thanks a lot for being our release manager David and everyone who
contributed.
Best,
Xingbo
David Anderson <da...@apache.org> 于2022年7月8日周五 06:18写道：
> 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
>