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

Posted to commits@flink.apache.org by th...@apache.org on 2019/09/18 22:08:05 UTC

[flink] branch master updated (f65ee55 -> 4a4a147)

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

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


    from f65ee55  [FLINK-14017][python] Support to start up Python worker in process mode.
     add 4a4a147  [FLINK-14107][kinesis] Erroneous queue selection in record emitter may lead to deadlock

No new revisions were added by this update.

Summary of changes:
 .../connectors/kinesis/util/RecordEmitter.java     |  5 ++
 .../connectors/kinesis/util/RecordEmitterTest.java | 66 ++++++++++++++++++++--
 2 files changed, 65 insertions(+), 6 deletions(-)