flink list -r shows CANCELED jobs - Flink 1.5

[Edward Rojas]

Hello all,

On Flink 1.5, the CLI returns the CANCELED jobs when requesting only the
running job by using the -r flag...
is this an intended behavior ?

On 1.4 CANCELED jobs does not appear when running this command.



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Edward Rojas]

I forgot to add an example of the execution:

$ ./bin/flink list -r
Waiting for response...
------------------ Running/Restarting Jobs -------------------
17.05.2018 19:34:31 : edec969d6f9609455f9c42443b26d688 : FlinkAvgJob
(CANCELED)
17.05.2018 19:36:01 : bd87ffc35e1521806928d6251990d715 : FlinkAvgJob
(RUNNING)

Note that from the title it's supposed to return only Running or Restarting
Jobs.

I'm using this response on a script that updates a job by canceling with
savepoint... I just want to know if I have ti update my script :)

Thanks in advance



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Rong Rong]

This sounds like a bug to me, I can reproduce with the latest RC#3 of Flink 1.5 with:

bin/start-cluster.sh
bin/flink run examples/streaming/WordCount.jar
bin/flink list -r

Would you please file a JIRA bug report? I will look into it

--

Rong

On Thu, May 17, 2018 at 10:50 AM, Edward Rojas <[hidden email]> wrote:

I forgot to add an example of the execution:

$ ./bin/flink list -r
Waiting for response...
------------------ Running/Restarting Jobs -------------------
17.05.2018 19:34:31 : edec969d6f9609455f9c42443b26d688 : FlinkAvgJob
(CANCELED)
17.05.2018 19:36:01 : bd87ffc35e1521806928d6251990d715 : FlinkAvgJob
(RUNNING)

Note that from the title it's supposed to return only Running or Restarting
Jobs.

I'm using this response on a script that updates a job by canceling with
savepoint... I just want to know if I have ti update my script :)

Thanks in advance

--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

[Rong Rong]

Hi Edward,

I dug a little into the CLIFrontend code and seems like there's some discrepancies between the description and the result return from

flink list -r
I have documented the issue in [1]. Please feel free to comment if I missed anything.

Thanks,

Rong

Reference:
[1] https://issues.apache.org/jira/browse/FLINK-9398

On Thu, May 17, 2018 at 4:48 PM, Rong Rong <[hidden email]> wrote:

This sounds like a bug to me, I can reproduce with the latest RC#3 of Flink 1.5 with:

bin/start-cluster.sh
bin/flink run examples/streaming/WordCount.jar
bin/flink list -r

Would you please file a JIRA bug report? I will look into it

--

Rong

On Thu, May 17, 2018 at 10:50 AM, Edward Rojas <[hidden email]> wrote:

I forgot to add an example of the execution:

$ ./bin/flink list -r
Waiting for response...
------------------ Running/Restarting Jobs -------------------
17.05.2018 19:34:31 : edec969d6f9609455f9c42443b26d688 : FlinkAvgJob
(CANCELED)
17.05.2018 19:36:01 : bd87ffc35e1521806928d6251990d715 : FlinkAvgJob
(RUNNING)

Note that from the title it's supposed to return only Running or Restarting
Jobs.

I'm using this response on a script that updates a job by canceling with
savepoint... I just want to know if I have ti update my script :)

Thanks in advance

--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/