This PR adds a new option starrocks.write.buffer.rows to control how to trigger flush according the number of buffered rows in a table. If the number of rows reaches the limitation, send these data to StarRocks.
This PR is based on https://github.com/StarRocks/starrocks-connector-for-apache-flink/pull/267
Checklist:
[ ] I have added test cases for my bug fix or my new feature
[ ] This pr will affect users' behaviors
[ ] This pr needs user documentation (for new or modified features or behaviors)
[ ] I have added documentation for my new feature or new function
What type of PR is this：
Which issues of this PR fixes ：
Fixes #
Problem Summary(Required) ：
This PR adds a new option
starrocks.write.buffer.rowsto control how to trigger flush according the number of buffered rows in a table. If the number of rows reaches the limitation, send these data to StarRocks. This PR is based on https://github.com/StarRocks/starrocks-connector-for-apache-flink/pull/267Checklist: