Hi,
What is your use case? Flink doesn't have an UPDATE statement, because
Flink relies on Dynamic Tables and Continuous Queries. [1]
Best regards,
Martijn
[1]
https://nightlies.apache.org/flink/flink-docs-stable/docs/dev/table/concepts/dynamic_tables/
On Wed, Sep 21, 2022 at 5:40 PM Xuyang w
Hi,
There's a specific page on the Flink documentation which explains the
difference between checkpoints and savepoints at
https://nightlies.apache.org/flink/flink-docs-stable/docs/ops/state/checkpoints_vs_savepoints/
- Have you read this? If so, what's missing so that we can improve the page?
Be
You will need to reload the savepoint with the original job and add uids
to all operators (while also setting the uid hashes on all operators to
properly restore the state).
On 22/09/2022 11:06, Chesnay Schepler wrote:
Currently the state processor API does not support that.
On 22/09/2022 11:
Currently the state processor API does not support that.
On 22/09/2022 11:02, BIGO wrote:
I didn't set the uid for my flink operator, is there any way to read
the flink state data? State Processor API requires uid. Thanks.
I didn't set the uid for my flink operator, is there any way to read the flink
state data? State Processor API requires uid.
Thanks.
Hi folks,
I would like to know the difference between externalized checkpoint and
savepoint. Regarding externalized checkpoint, is the checkpoint written to
persistent storage only if the job is failed or suspended? What about cancelled
or killed by the user? What information is written to persi
