This is an automated email from the ASF dual-hosted git repository.
fanrui pushed a change to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git
from 219f22e53d8 [FLINK-28185][Connector/Kafka] Handle missing timestamps
when there are empty partitions for the TimestampOffsetsInitializer. This
closes #20370
add 71482596056 [FLINK-32023][API / DataStream] Add config
execution.buffer-timeout.enabled to flush only when the output buffer is full.
No new revisions were added by this update.
Summary of changes:
.../generated/execution_configuration.html | 10 +++-
.../flink/configuration/ExecutionOptions.java | 20 ++++++--
.../environment/StreamExecutionEnvironment.java | 15 ++++--
.../api/StreamExecutionEnvironmentTest.java | 54 ++++++++++++++++++++++
4 files changed, 91 insertions(+), 8 deletions(-)
