[jira] [Commented] (FLINK-21264) at yarn-per-job mode, tm stopped ,the jm dont relase resource,its also running
[
https://issues.apache.org/jira/browse/FLINK-21264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278692#comment-17278692
]
Yang Wang commented on FLINK-21264:
---
This is not a bug. Please note that you are submitting the Flink per-job
cluster in attached mode, only when the result is retrieved by client. Then the
application will be deregistered from Yarn.
You could use the following code to start a detached per-job cluster.
{code:java}
./bin/flink run -d -m yarn-cluster -yjm 2048 -ytm 8086
./examples/streaming/SocketWindowWordCount.jar --hostname ip --port 9998
{code}
> at yarn-per-job mode, tm stopped ,the jm dont relase resource,its also running
> --
>
> Key: FLINK-21264
> URL: https://issues.apache.org/jira/browse/FLINK-21264
> Project: Flink
> Issue Type: Bug
> Components: Deployment / YARN
>Affects Versions: 1.12.0
>Reporter: tonychan
>Priority: Blocker
> Attachments: Flink任务结束后Yarn上仍然显示RUNNING.docx,
> image-2021-02-03-17-42-53-269.png, image-2021-02-03-17-43-28-017.png
>
>
> i make a socket (nc -lk ) for flink test, and at first the flink running
> is ok,when the source server stopped, the flink tm is stopped and the status
> is finish ,but the jm is also running, !image-2021-02-03-17-42-53-269.png!
>
> !image-2021-02-03-17-43-28-017.png!
>
>
>
>
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Commented] (FLINK-21264) at yarn-per-job mode, tm stopped ,the jm dont relase resource,its also running
[ https://issues.apache.org/jira/browse/FLINK-21264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278641#comment-17278641 ] Jichao Wang commented on FLINK-21264: - [^Flink任务结束后Yarn上仍然显示RUNNING.docx] hi, [~tonychan] , there are answers to your questions in this document. > at yarn-per-job mode, tm stopped ,the jm dont relase resource,its also running > -- > > Key: FLINK-21264 > URL: https://issues.apache.org/jira/browse/FLINK-21264 > Project: Flink > Issue Type: Bug >Affects Versions: 1.12.0 >Reporter: tonychan >Priority: Blocker > Attachments: Flink任务结束后Yarn上仍然显示RUNNING.docx, > image-2021-02-03-17-42-53-269.png, image-2021-02-03-17-43-28-017.png > > > i make a socket (nc -lk ) for flink test, and at first the flink running > is ok,when the source server stopped, the flink tm is stopped and the status > is finish ,but the jm is also running, !image-2021-02-03-17-42-53-269.png! > > !image-2021-02-03-17-43-28-017.png! > > > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-21264) at yarn-per-job mode, tm stopped ,the jm dont relase resource,its also running
[ https://issues.apache.org/jira/browse/FLINK-21264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278540#comment-17278540 ] tonychan commented on FLINK-21264: -- this is the summit code ./bin/flink run -m yarn-cluster -yjm 2048 -ytm 8086 ./examples/streaming/SocketWindowWordCount.jar --hostname 10.20.30.111 --port 9998 > at yarn-per-job mode, tm stopped ,the jm dont relase resource,its also running > -- > > Key: FLINK-21264 > URL: https://issues.apache.org/jira/browse/FLINK-21264 > Project: Flink > Issue Type: Bug >Affects Versions: 1.12.0 >Reporter: tonychan >Priority: Blocker > Attachments: image-2021-02-03-17-42-53-269.png, > image-2021-02-03-17-43-28-017.png > > > i make a socket (nc -lk ) for flink test, and at first the flink running > is ok,when the source server stopped, the flink tm is stopped and the status > is finish ,but the jm is also running, !image-2021-02-03-17-42-53-269.png! > > !image-2021-02-03-17-43-28-017.png! > > > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Commented] (FLINK-21264) at yarn-per-job mode, tm stopped ,the jm dont relase resource,its also running
[ https://issues.apache.org/jira/browse/FLINK-21264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17278501#comment-17278501 ] Yang Wang commented on FLINK-21264: --- Could you please check you are submitting the yarn per-job cluster in detached or attached mode? If it is the attached mode, then the application will be deregistered only after the job result is retrieved by Flink client. Moreover, it will help a lot to find the root cause if you could the share the JobManager logs. > at yarn-per-job mode, tm stopped ,the jm dont relase resource,its also running > -- > > Key: FLINK-21264 > URL: https://issues.apache.org/jira/browse/FLINK-21264 > Project: Flink > Issue Type: Bug >Affects Versions: 1.12.0 >Reporter: tonychan >Priority: Blocker > Attachments: image-2021-02-03-17-42-53-269.png, > image-2021-02-03-17-43-28-017.png > > > i make a socket (nc -lk ) for flink test, and at first the flink running > is ok,when the source server stopped, the flink tm is stopped and the status > is finish ,but the jm is also running, !image-2021-02-03-17-42-53-269.png! > > !image-2021-02-03-17-43-28-017.png! > > > > -- This message was sent by Atlassian Jira (v8.3.4#803005)
