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(-)