:2021 Jun. 9 (Wed.) 22:12
>> To:Kezhu Wang
>> Cc:Thomas Wang ; Yun Gao ; user <
>> user@flink.apache.org>
>> Subject:Re: Re: Re: Re: Failed to cancel a job using the STOP rest API
>>
>> Yes good catch Kezhu, IllegalStateException sounds very much like
>
FLINK-21028.
>
> --
> From:Piotr Nowojski
> Send Time:2021 Jun. 9 (Wed.) 22:12
> To:Kezhu Wang
> Cc:Thomas Wang ; Yun Gao ; user <
> user@flink.apache.org>
> Subject:Re: Re: Re: Re: Failed to cancel a job using t
cancel a job using the STOP rest API
Yes good catch Kezhu, IllegalStateException sounds very much like FLINK-21028.
Thomas, could you try upgrading to Flink 1.13.1 or 1.12.4? (1.11.4 hasn't been
released yet)?
Piotrek
wt., 8 cze 2021 o 17:18 Kezhu Wang napisał(a):
Could it be same as FLINK-21
ld you also show us the dag of the job ? And does some operators in
>>> the source task
>>> use multiple-threads to emit records?
>>>
>>> Best,
>>> Yun
>>>
>>>
>>> --Original Mail --
>>
: Re: Re: Failed to cancel a job using the STOP rest API
> This is actually a very simple job that reads from Kafka and writes to S3
> using the StreamingFileSink w/ Parquet format. I'm all using Flink's API
> and nothing custom.
>
> Thomas
>
> On Sun, Jun 6, 2021 at
CC:user
Subject:Re: Re: Re: Failed to cancel a job using the STOP rest API
This is actually a very simple job that reads from Kafka and writes to S3 using
the StreamingFileSink w/ Parquet format. I'm all using Flink's API and nothing
custom.
Thomas
On Sun, Jun 6, 2021 at 6:43 PM Yun
:*Thomas Wang
> *Send Date:*Sun Jun 6 04:02:20 2021
> *Recipients:*Yun Gao
> *CC:*user
> *Subject:*Re: Re: Failed to cancel a job using the STOP rest API
>
>> One thing I noticed is that if I set drain = true, the job could be
>> stopped correctly. Maybe that's bec
Hi Thoms,
Very thanks for reporting the exceptions, and it seems to be not work as
expected to me...
Could you also show us the dag of the job ? And does some operators in the
source task
use multiple-threads to emit records?
Best,
Yun
--Original Mail --
Sen
One thing I noticed is that if I set drain = true, the job could be stopped
correctly. Maybe that's because I'm using a Parquet file sink which is a
bulk-encoded format and only writes to disk during checkpoints?
Thomas
On Sat, Jun 5, 2021 at 10:06 AM Thomas Wang wrote:
> Hi Yun,
>
> Thanks for
Hi Yun,
Thanks for the tips. Yes, I do see some exceptions as copied below. I'm not
quite sure what they mean though. Any hints?
Thanks.
Thomas
```
2021-06-05 10:02:51
java.util.concurrent.ExecutionException:
org.apache.flink.streaming.runtime.tasks.ExceptionInChainedOperatorException:
Could no
Hi Thomas,
For querying the savepoint status, a get request could be issued to
/jobs/:jobid/savepoints/:savepointtriggerid [1] to get the status and position
of the savepoint. But if the job is running with some kind of per-job mode and
JobMaster is gone after the stop-with-savepoint, the reque
11 matches
Mail list logo
