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:48:29 UTC

[flink] branch release-1.7 updated (c193cf0 -> 8012ab1)

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

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


    from c193cf0  [FLINK-11469][docs] Update documentation for `Tuning Checkpoints and Large State`
     add af83b99  [FLINK-10774] Rework lifecycle management of partitionDiscoverer in FlinkKafkaConsumerBase
     add 4789b3f  [FLINK-10774] [tests] Refactor Kafka tests to have consistent life cycle verifications
     add 198c400  [FLINK-10774] [tests] Test that Kafka partition discoverer is wokeup before closed when concurrently accessed
     add 8012ab1  [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          | 341 +++++++++++++++++++--
 .../util/MockStreamingRuntimeContext.java          |  12 +
 3 files changed, 431 insertions(+), 95 deletions(-)