Hello, everyone,
I have some unclear points when using Flink SQL. I hope to get an
answer or tell me where I can find the answer.
When using the DataStream API, in order to ensure that the job can
recover the state from savepoint after adjustment, it is necessary to specify
the uid for the operator. However, when using Flink SQL, the uid of the
operator is automatically generated. If the SQL logic changes (operator order
changes), when the task is restored from savepoint, will it cause some of the
operator states to be unable to be mapped back, resulting in state loss?
Thanks~
Jie Feng
| |
shadowell
|
|
shadow...@126.com
|
签名由网易邮箱大师定制
