flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Bowen Li (JIRA)" <j...@apache.org>
Subject [jira] [Updated] (FLINK-7733) test instability in Kafka end-to-end test (RetriableCommitFailedException)
Date Mon, 02 Oct 2017 05:28:12 GMT

     [ https://issues.apache.org/jira/browse/FLINK-7733?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]

Bowen Li updated FLINK-7733:
----------------------------
    Summary: test instability in Kafka end-to-end test (RetriableCommitFailedException)  (was:
test instability in Kafa end-to-end test (RetriableCommitFailedException))

> 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: Critical
>              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
(v6.4.14#64029)

Mime
View raw message