Hi Yun Thanks for your quick reply. To be clear, It's not essential to implement these features into the SQL statement. And precisely because of the limitations of SQL, we want these features happen.
1. Yeah, I think the stream api also has not similar api. We want it because sometimes we want to record the error and record itself to analyse instead of leave it crash the task. Especially in Job by SQL , we can hardly handle the errors occur in query . 2. Almost same reason, and also not essential to present the operation in the statement. Thanks again. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/