This is an automated email from the ASF dual-hosted git repository.
lzljs3620320 pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from a04af5f [FLINK-20610][table-planner-blink] Introduce
BatchPhysicalCalc & BatchPhysicalPythonCalc, and make BatchExecCalc &
BatchExecPythonCalc only extended from ExecNode
add a046ee8 [FLINK-20213][fs-connector] Partition commit is delayed when
records keep coming
No new revisions were added by this update.
Summary of changes:
.../filesystem/stream/AbstractStreamingWriter.java | 6 ++++
.../filesystem/stream/StreamingFileWriter.java | 35 ++++++++++++++++++----
.../stream/compact/CompactFileWriter.java | 4 +++
.../filesystem/stream/StreamingFileWriterTest.java | 25 ++++++++++++++++
4 files changed, 65 insertions(+), 5 deletions(-)
