[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405742#comment-17405742 ] Roc Marshal edited comment on FLINK-23943 at 8/27/21, 10:58 AM: [~trohrmann] I reviewed the source operator carefully according to your suggestions. As you said, I used the default `cancel()` of SourceFunction method, which causes the error. So, it isn't a bug. [~chesnay] [~trohrmann] Thank you for your attention and guidance. I'll close the jira. was (Author: rocmarshal): [~trohrmann] I reviewed the source operator carefully according to your suggestion. As you said, I used the default `cancel()` of SourceFunction method, which causes the error. So, it isn't a bug. [~chesnay] [~trohrmann] Thank you for your attention and guidance. I'll close the jira. > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing, Runtime / Task >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405519#comment-17405519 ] Roc Marshal edited comment on FLINK-23943 at 8/27/21, 3:46 AM: --- [~trohrmann] [~chesnay] Yes. The problem is reproducible. I'm trying to locate the problem. The log level of 'org.apache.flink' was set as 'DEBUG' in the attach logs. was (Author: rocmarshal): [~trohrmann] [~chesnay] Yes. the problem is reproducible. I'm trying to locate the problem. The log level of 'org.apache.flink' was set as 'DEBUG' in the attach logs. > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405519#comment-17405519 ] Roc Marshal edited comment on FLINK-23943 at 8/27/21, 3:45 AM: --- [~trohrmann] [~chesnay] Yes. the problem is reproducible. I'm trying to locate the problem. The log level of 'org.apache.flink' was set as 'DEBUG' in the attach logs. was (Author: rocmarshal): [~trohrmann] [~chesnay] Yes. the problem reproducible. I'm trying to locate the problem. The log level of 'org.apache.flink' was set as 'DEBUG' in the attach logs. > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405519#comment-17405519 ] Roc Marshal edited comment on FLINK-23943 at 8/27/21, 1:45 AM: --- [~trohrmann] [~chesnay] Yes. the problem reproducible. I'm trying to locate the problem. The log level of 'org.apache.flink' was set as 'DEBUG' in the attach logs. was (Author: rocmarshal): [~trohrmann] [~chesnay] Yes. I'm trying to locate the problem. I will upload more fine-grained log information later . > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / Checkpointing >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > Labels: REST_API > Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log, > flink-roc-taskexecutor-0-MacBook-Pro.local.log > > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[
https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17405291#comment-17405291
]
Till Rohrmann edited comment on FLINK-23943 at 8/26/21, 3:14 PM:
-
Hmm, the logs don't show anything suspicious. Is the problem reproducible
[~RocMarshal]? If yes, could you run the job with debug logs? cc [~pnowojski]
do you know of any problems with the stop-with-savepoint shut down behaviour on
the {{StreamTask}} side?
was (Author: till.rohrmann):
Hmm, the logs don't show anything suspicious. Is the problem reproducible
[~RocMarshal]? If yes, could you run the job with debug logs?
> "/jobs/:jobid/stop" in REST API can't stop the target job.
> --
>
> Key: FLINK-23943
> URL: https://issues.apache.org/jira/browse/FLINK-23943
> Project: Flink
> Issue Type: Bug
> Components: Runtime / Checkpointing
>Affects Versions: 1.13.2
>Reporter: Roc Marshal
>Priority: Major
> Labels: REST_API
> Attachments: flink-roc-standalonesession-0-MacBook-Pro.local.log,
> flink-roc-taskexecutor-0-MacBook-Pro.local.log
>
>
> * "/jobs/:jobid/stop" in REST API can't stop the target job.
> * It can trigger a savepoint with the parameters.
> * The interface document link
> https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403750#comment-17403750 ] Till Rohrmann edited comment on FLINK-23943 at 8/25/21, 9:07 AM: - Well it triggers an asynchronous operation which may take a bit. Even if it finished the cluster will remain active until either 5 minutes have elapsed or the savepoint result was consumed. Do you see anything in the logs? was (Author: zentol): Well it triggers an synchronous operation which may take a bit. Even if it finished the cluster will remain active until either 5 minutes have elapsed or the savepoint result was consumed. Do you see anything in the logs? > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / REST >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
[jira] [Comment Edited] (FLINK-23943) "/jobs/:jobid/stop" in REST API can't stop the target job.
[ https://issues.apache.org/jira/browse/FLINK-23943?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=17403775#comment-17403775 ] Roc Marshal edited comment on FLINK-23943 at 8/24/21, 12:26 PM: Should the source operators in the job implement `StopableFunction` interface ? Could the job not be stopped by visiting `stop` url in REST API if all source operators are not both implemented from the `StopableFunction`? was (Author: rocmarshal): Should the source operators in the job implement `StopableFunction` interface ? Could the job not be stopped if all source operators are not both implemented from the `StopableFunction`? > "/jobs/:jobid/stop" in REST API can't stop the target job. > -- > > Key: FLINK-23943 > URL: https://issues.apache.org/jira/browse/FLINK-23943 > Project: Flink > Issue Type: Bug > Components: Runtime / REST >Affects Versions: 1.13.2 >Reporter: Roc Marshal >Priority: Major > > * "/jobs/:jobid/stop" in REST API can't stop the target job. > * It can trigger a savepoint with the parameters. > * The interface document link > https://ci.apache.org/projects/flink/flink-docs-master/docs/ops/rest_api/#jobs-jobid-stop -- This message was sent by Atlassian Jira (v8.3.4#803005)
