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 2021/01/27 16:54:15 UTC

[flink] branch master updated (dac3e72 -> a4f1174)

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 dac3e72  [FLINK-21006] Fix hbase 1.4 tests on Hadoop 3.x
     add a4f1174  [FLINK-21059][kafka] KafkaSourceEnumerator does not honor consumer properties

No new revisions were added by this update.

Summary of changes:
 .../flink/connector/kafka/source/KafkaSource.java  |  2 +-
 .../source/enumerator/KafkaSourceEnumerator.java   | 11 +++--
 .../source/enumerator/KafkaEnumeratorTest.java     | 56 ++++++++++++++++++++--
 3 files changed, 61 insertions(+), 8 deletions(-)