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:57:11 UTC

[flink] branch release-1.15 updated (cad7cfc -> 3c963cc)

This is an automated email from the ASF dual-hosted git repository.

fpaul pushed a change to branch release-1.15
in repository https://gitbox.apache.org/repos/asf/flink.git.


    from cad7cfc  [FLINK-26334][datastream] for 1.15.0 . 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 3c963cc  [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(-)