Nicholas Leong
07/26/2024, 3:34 AMSamrat Deb
07/26/2024, 5:12 AMenv.getConfig().setAutoWatermarkInterval(<value>);
2. Delta Lake allows you to set a target file size, and Flink can be configured to commit when the data size reaches this target.
tableProperties.put("delta.targetFileSize", "<number>");
Samrat Deb
07/26/2024, 5:12 AM