bithw1 commented on issue #17658: URL: https://github.com/apache/hudi/issues/17658#issuecomment-3684931386
I am using Flink 1.17.1 and Hudi 0.15.0. I am able to write to mysql sink if the `insert .. select` sql is run in normal mode(not in recovery mode). Could you please share your experiment sql? BTW, one thing I want to confirm: from the exception message, it complains the `state for operator c43c1940ad62bf3bc996ebfabca09279 to the new program`, it looks that the operator uid has been changed. In the DataStream world, we need to specify uid for the operator, we don't need to specify the uid in the sql world? how could the state be matched and recover? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
