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

Posted to commits@flink.apache.org by tr...@apache.org on 2019/01/31 10:49:17 UTC

[flink] branch release-1.6 updated (de3772b -> 1b9c464)

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

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


    from de3772b  [FLINK-11469][docs] Update documentation for `Tuning Checkpoints and Large State`
     add 402f235  [FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase
     add 2a5d97d  [FLINK-10774] [tests] Refactor Kafka tests to have consistent life cycle verifications
     add c215064  [FLINK-10774] [tests] Test that Kafka partition discoverer is wokeup before closed when concurrently accessed
     add 1b9c464  [FLINK-10774][tests] Refactor FlinkKafkaConsumerBaseTest#testConsumerLifeCycle

No new revisions were added by this update.

Summary of changes:
 .../connectors/kafka/FlinkKafkaConsumerBase.java   | 173 ++++++-----
 .../kafka/FlinkKafkaConsumerBaseTest.java          | 346 +++++++++++++++++++--
 2 files changed, 424 insertions(+), 95 deletions(-)