flink-cdc icon indicating copy to clipboard operation
flink-cdc copied to clipboard

Published 20 hours ago • verified publisher icon apache

[FLINK-36546] Handle batch sources in DataSinkTranslator

Open morozov opened this issue 4 months ago • 2 comments

There's no public API in Flink to detect the boundedness of a stream, so this patch duplicates the code from StreamGraphGenerator that Flink itself uses to instantiate CommitterOperatorFactory.

morozov avatar Oct 16 '24 02:10 morozov