CloverDew commented on PR #10951: URL: https://github.com/apache/seatunnel/pull/10951#issuecomment-4598441672
> 需要澄清一点：该问题针对的是 Flink 1.13，而此 bug 已在 Flink 1.14 及更高版本中修复。计划中的代码更改将在通用模块中进行。这种做法是否合适？将更改放入通用模块是否会引入不必要的开销（例如回退定时器）和不必要的反射耦合？ Okay, this fix has been moved to seatunnel-translation-flink-13. I plan to implement a new overridden SchemaOperator later; Flink 1.13 will have its own SchemaOperator13, and SourceExecuteProcessor will instantiate SchemaOperator13, which will not affect other versions. -- 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]
