You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@flink.apache.org by fp...@apache.org on 2022/03/21 08:56:16 UTC
[flink] branch master updated (c1bbbe6 -> 0e6f33b)
This is an automated email from the ASF dual-hosted git repository.
fpaul pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git.
from c1bbbe6 [FLINK-26334][datastream] Modified getWindowStartWithOffset method in org.apache.flink.table.runtime.operators.window.TimeWindow and org.apache.flink.streaming.api.windowing.windows.TimeWindow . Added test cases in unit test TimeWindowTest.
add 0e6f33b [FLINK-26642][connector/pulsar] Fix support for non-partitioned topic
No new revisions were added by this update.
Summary of changes:
.../sink/writer/topic/TopicMetadataListener.java | 12 ++++++++++--
.../source/enumerator/topic/TopicNameUtils.java | 5 +++++
.../sink/writer/topic/TopicMetadataListenerTest.java | 19 +++++++++++++++++++
3 files changed, 34 insertions(+), 2 deletions(-)