[
https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16970086#comment-16970086
]
Andrey Zagrebin edited comment on FLINK-13482 at 11/8/19 11:14 AM:
-------------------------------------------------------------------
@Donghui Xu
In general, it is better firstly to discuss this kind of issues in [user
ML|https://flink.apache.org/community.html#mailing-lists].
The local mode is intended more for debugging, could you not just kill the
local process when the job is not needed?
Alternatively, you could try [REST
API|https://ci.apache.org/projects/flink/flink-docs-release-1.9/monitoring/rest_api.html#jobs-jobid-1].
There is also a
[FLIP-73|https://cwiki.apache.org/confluence/display/FLINK/FLIP-73%3A+Introducing+Executors+for+job+submission]
in progress for new executor, thereafter execution result handle might be
revisited and cancel/stop might be added to manage job in code.
Does it help?
was (Author: azagrebin):
Donghui Xu
In general, it is better firstly to discuss this kind of issues in [user
ML|https://flink.apache.org/community.html#mailing-lists].
The local mode is intended more for debugging, could you not just kill the
local process when the job is not needed?
Alternatively, you could try [REST
API|https://ci.apache.org/projects/flink/flink-docs-release-1.9/monitoring/rest_api.html#jobs-jobid-1].
There is also a
[FLIP-73|https://cwiki.apache.org/confluence/display/FLINK/FLIP-73%3A+Introducing+Executors+for+job+submission]
in progress for new executor, thereafter execution result handle might be
revisited and cancel/stop might be added to manage job in code.
Does it help?
> How can I cleanly shutdown streaming jobs in local mode?
> --------------------------------------------------------
>
> Key: FLINK-13482
> URL: https://issues.apache.org/jira/browse/FLINK-13482
> Project: Flink
> Issue Type: Improvement
> Components: API / DataStream
> Reporter: Donghui Xu
> Priority: Minor
>
> Currently, streaming jobs can be stopped using "cancel" and "stop" command
> only in cluster mode, not in local mode.
> When users need to explicitly terminate jobs, it is necessary to provide a
> termination mechanism for streaming jobs in local mode.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
