[ https://issues.apache.org/jira/browse/FLINK-7733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Aljoscha Krettek closed FLINK-7733. ----------------------------------- Resolution: Cannot Reproduce Fix Version/s: (was: 1.5.0) Closing for now since this hasn't reappeared in a while. > test instability in Kafka end-to-end test (RetriableCommitFailedException) > -------------------------------------------------------------------------- > > Key: FLINK-7733 > URL: https://issues.apache.org/jira/browse/FLINK-7733 > Project: Flink > Issue Type: Bug > Components: Kafka Connector, Tests > Affects Versions: 1.4.0 > Reporter: Nico Kruber > Priority: Blocker > Labels: test-stability > > In a branch with unrelated changes, the Kafka end-to-end tests fails with the > following strange entries in the log. > {code} > 2017-09-27 17:50:36,777 INFO org.apache.kafka.common.utils.AppInfoParser > - Kafka version : 0.10.2.1 > 2017-09-27 17:50:36,778 INFO org.apache.kafka.common.utils.AppInfoParser > - Kafka commitId : e89bffd6b2eff799 > 2017-09-27 17:50:38,492 INFO > org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered > coordinator testing-gce-b6810926-7003-4390-9002-178739bb4946:9092 (id: > 2147483647 rack: null) for group myconsumer. > 2017-09-27 17:50:38,511 INFO > org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Marking > the coordinator testing-gce-b6810926-7003-4390-9002-178739bb4946:9092 (id: > 2147483647 rack: null) dead for group myconsumer > 2017-09-27 17:50:38,618 INFO > org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Discovered > coordinator testing-gce-b6810926-7003-4390-9002-178739bb4946:9092 (id: > 2147483647 rack: null) for group myconsumer. > 2017-09-27 17:50:41,525 INFO > org.apache.flink.runtime.state.DefaultOperatorStateBackend - > DefaultOperatorStateBackend snapshot (In-Memory Stream Factory, synchronous > part) in thread Thread[Async calls on Source: Custom Source -> Map -> Sink: > Unnamed (1/1),5,Flink Task Threads] took 481 ms. > 2017-09-27 17:50:41,598 INFO > org.apache.kafka.clients.consumer.internals.AbstractCoordinator - Marking > the coordinator testing-gce-b6810926-7003-4390-9002-178739bb4946:9092 (id: > 2147483647 rack: null) dead for group myconsumer > 2017-09-27 17:50:41,600 WARN > org.apache.flink.streaming.connectors.kafka.internal.Kafka09Fetcher - > Committing offsets to Kafka failed. This does not compromise Flink's > checkpoints. > org.apache.kafka.clients.consumer.RetriableCommitFailedException: Offset > commit failed with a retriable exception. You should retry committing offsets. > Caused by: org.apache.kafka.common.errors.DisconnectException > 2017-09-27 17:50:41,608 ERROR > org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumerBase - Async > Kafka commit failed. > org.apache.kafka.clients.consumer.RetriableCommitFailedException: Offset > commit failed with a retriable exception. You should retry committing offsets. > Caused by: org.apache.kafka.common.errors.DisconnectException > {code} > https://travis-ci.org/NicoK/flink/jobs/280477275 -- This message was sent by Atlassian JIRA (v7.6.3#76005)