polyzos opened a new pull request, #3432: URL: https://github.com/apache/fluss/pull/3432
The DataStream `FlussSource/FlussSourceBuilder` never created a `LakeSource`, it always passed `null` to FlinkSource. So DataStream jobs read only Fluss data, even for datalake-enabled tables. Union read worked only via the Flink SQL/Table connector. This pr addresses this missing piece -- 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]
