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/05 19:15:55 UTC

[flink] branch master updated (cb0d8eb -> 0790768)

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

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


    from cb0d8eb  [FLINK-22442][CEP] Using scala api to change the TimeCharacteristic of the PatternStream is invalid
     add 56e292b  [FLINK-22573][datastream] Fix AsyncIO calls timeout on completed element.
     add 0790768  [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(-)