[jira] [Commented] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?
[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16983147#comment-16983147 ] Donghui Xu commented on FLINK-13482: [~azagrebin] I can kill the Flink process manually . You can close this issue. Thanks. > 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 >Affects Versions: 1.6.4 >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)
[jira] [Commented] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?
[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16971270#comment-16971270 ] Donghui Xu commented on FLINK-13482: Thank you for your advice. [~azagrebin] I want to kill the local process when the job has consumed all the topic data in kafka. > 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 >Affects Versions: 1.6.4 >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)
[jira] [Updated] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?
[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Donghui Xu updated FLINK-13482: --- Affects Version/s: 1.6.4 > 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 >Affects Versions: 1.6.4 >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)
[jira] [Commented] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?
[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898496#comment-16898496 ] Donghui Xu commented on FLINK-13482: The data source I used was FlinkKafka Consumer010. After consuming kafka's data, I want to terminate stream job processing. Can this be implemented in code? > 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: Runtime / Coordination >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 (v7.6.14#76016)
[jira] [Comment Edited] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?
[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16898496#comment-16898496 ] Donghui Xu edited comment on FLINK-13482 at 8/2/19 2:40 AM: The data source I used was FlinkKafkaConsumer010. After consuming kafka's data, I want to terminate stream job processing. Can this be implemented in code? was (Author: davidxdh): The data source I used was FlinkKafka Consumer010. After consuming kafka's data, I want to terminate stream job processing. Can this be implemented in code? > 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: Runtime / Coordination >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 (v7.6.14#76016)
[jira] [Updated] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?
[ https://issues.apache.org/jira/browse/FLINK-13482?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Donghui Xu updated FLINK-13482: --- Description: 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. was: 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 local mode flow jobs. > 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: Runtime / Coordination >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 (v7.6.14#76016)
[jira] [Created] (FLINK-13482) How can I cleanly shutdown streaming jobs in local mode?
Donghui Xu created FLINK-13482: -- Summary: 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 Reporter: Donghui Xu 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 local mode flow jobs. -- This message was sent by Atlassian JIRA (v7.6.14#76016)
[jira] [Created] (FLINK-8827) When FLINK_CONF_DIR contains spaces, execute zookeeper related scripts failed
Donghui Xu created FLINK-8827: - Summary: When FLINK_CONF_DIR contains spaces, execute zookeeper related scripts failed Key: FLINK-8827 URL: https://issues.apache.org/jira/browse/FLINK-8827 Project: Flink Issue Type: Bug Affects Versions: 1.4.0 Environment: Red Hat Enterprise Linux Server release 6.5 (Santiago) Reporter: Donghui Xu When the path of FLINK_CONF_DIR including spaces, executing zookeeper related scripts failed with the following error message: Expect binary expression. -- This message was sent by Atlassian JIRA (v7.6.3#76005)
