leo65535 edited a comment on pull request #1721: URL: https://github.com/apache/incubator-inlong/pull/1721#issuecomment-954506880
hi @gosonzhang @dockerzhang, thanks for review The key point is we need use high flink version(e.g flink-1.13.x) - Flink1.9.X can not parse sql, we need custom the sql parser ourself. - Flink1.9.X api can not compatible with flink-1.13.x - Before flink-1.13.x, we can not assign different parallelism for different sink - and so on In general, if we use old flink version, we will spend most time on flink framework instead of flinksql workflow job, on the other hand, we will not expose flink to end users. And, I had tried put the basic framework to the sort module and upgrade the flink version in sort module, but met many errors. -- 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]
