---
> *From:* Piotr Nowojski
> *Sent:* Thursday, March 4, 2021 7:03 AM
> *To:* Kezhu Wang
> *Cc:* Meissner, Dylan ;
> user@flink.apache.org
> *Subject:* Re: Stateful functions 2.2 and stop with savepoint
>
> It doesn't change much ;) There is a known issue of stopping
Piotr Nowojski
Sent: Thursday, March 4, 2021 7:03 AM
To: Kezhu Wang
Cc: Meissner, Dylan ; user@flink.apache.org
Subject: Re: Stateful functions 2.2 and stop with savepoint
It doesn't change much ;) There is a known issue of stopping with savepoint and
stateful functions not working [1]. Th
for opening the bug and including the extra context.
>>
>> I'll track the progress and, in the meantime, I will work around by
>> taking two separate actions when stopping job: take-savepoints, then cancel.
>> ------
>> *From:* Kezhu Wang
>> *Sent:* Sunday, Feb
ruary 28, 2021 12:31 AM
> *To:* user@flink.apache.org ; Meissner, Dylan <
> dylan.t.meiss...@nordstrom.com>
> *Subject:* Re: Stateful functions 2.2 and stop with savepoint
>
> Hi,
>
> Thanks for reporting. I think it is a Flink bug and have created
> FLINK-21522 for it. You could
Sent:* Sunday, February 28, 2021 12:31 AM
> *To:* user@flink.apache.org ; Meissner, Dylan <
> dylan.t.meiss...@nordstrom.com>
> *Subject:* Re: Stateful functions 2.2 and stop with savepoint
>
> Hi,
>
> Thanks for reporting. I think it is a Flink bug and have created
> FLINK-2
ancel.
--
*From:* Kezhu Wang
*Sent:* Sunday, February 28, 2021 12:31 AM
*To:* user@flink.apache.org ; Meissner, Dylan <
dylan.t.meiss...@nordstrom.com>
*Subject:* Re: Stateful functions 2.2 and stop with savepoint
Hi,
Thanks for reporting. I think it is a Flink bug and have cr
12:31 AM
To: user@flink.apache.org ; Meissner, Dylan
Subject: Re: Stateful functions 2.2 and stop with savepoint
Hi,
Thanks for reporting. I think it is a Flink bug and have created FLINK-21522
for it. You could track progress there.
FLINK-21522: https://issues.apache.org/jira/browse/FLINK-
Hi,
Thanks for reporting. I think it is a Flink bug and have created
FLINK-21522 for it. You could track progress there.
FLINK-21522: https://issues.apache.org/jira/browse/FLINK-21522
Best,
Kezhu Wang
On February 28, 2021 at 00:59:04, Meissner, Dylan (
dylan.t.meiss...@nordstrom.com) wrote:
I have an embedded function with a SinkFunction as an egress, implemented as
this pseudo-code:
val serializationSchema = KafkaSchemaSerializationSchema(... props required to
use a Confluent Schema Registry with Avro, auth etc ...)
return SinkFunctionSpec(EGRESS_ID, FlinkKafkaProducer(serializati
