You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@flink.apache.org by ar...@apache.org on 2021/05/06 06:03:12 UTC

[flink] branch release-1.12 updated (c9b5156 -> 41dc587)

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

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


    from c9b5156  [FLINK-22442][CEP] Using scala api to change the TimeCharacteristic of the PatternStream is invalid
     add 41dc587  [FLINK-22573][datastream] Fix AsyncIO calls timeout on completed element.

No new revisions were added by this update.

Summary of changes:
 .../api/operators/async/AsyncWaitOperator.java     | 32 +++++-----
 .../api/operators/async/AsyncWaitOperatorTest.java | 69 ++++++++++++++++++++++
 .../tasks/StreamTaskMailboxTestHarness.java        |  4 ++
 3 files changed, 89 insertions(+), 16 deletions(-)