Hi, Robert,
The configuration allowNonRestoredState should be used like this:
./bin/flink run --detached --allowNonRestoredState
Best,
Hang
Robert Cullen 于2022年10月12日周三 23:13写道：
> I don't see AllowNonRestoredState in the configuration documentation. How
> would it be passed to a job? On the c
I don't see AllowNonRestoredState in the configuration documentation. How
would it be passed to a job? On the command line like this:
./bin/flink run --detached -Dallownonrestoredstate=true ...
On Tue, Oct 4, 2022 at 4:52 PM Martijn Visser
wrote:
> Hi Mason,
>
> Definitely! Feel free to open a
Hi Mason,
Definitely! Feel free to open a PR and ping me for a review.
Cheers, Martijn
On Tue, Oct 4, 2022 at 3:51 PM Mason Chen wrote:
> Hi Martjin,
>
> I notice that this question comes up quite often. Would this be a good
> addition to the KafkaSource documentation? I'd be happy to contribu
Hi Martjin,
I notice that this question comes up quite often. Would this be a good
addition to the KafkaSource documentation? I'd be happy to contribute to
the documentation.
Best,
Mason
On Tue, Oct 4, 2022 at 11:23 AM Martijn Visser
wrote:
> Hi Robert,
>
> Based on
> https://stackoverflow.com
Hi Robert,
Based on
https://stackoverflow.com/questions/72870074/apache-flink-restoring-state-from-checkpoint-with-changes-kafka-topic
I think you'll need to change the UID for your KafkaSource and restart your
job with allowNonRestoredState enabled.
Best regards,
Martijn
On Tue, Oct 4, 2022 at
