flink-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Piotr Nowojski (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-7343) Kafka010ProducerITCase instability
Date Wed, 02 Aug 2017 07:04:01 GMT
Piotr Nowojski created FLINK-7343:

             Summary: Kafka010ProducerITCase instability
                 Key: FLINK-7343
                 URL: https://issues.apache.org/jira/browse/FLINK-7343
             Project: Flink
          Issue Type: Bug
          Components: Kafka Connector
            Reporter: Piotr Nowojski
            Assignee: Piotr Nowojski

As reported by [~till.rohrmann] in https://issues.apache.org/jira/browse/FLINK-6996 there
seems to be a test instability with `Kafka010ProducerITCase>KafkaProducerTestBase.testOneToOneAtLeastOnceRegularSink`


It is probably related to log.flush intervals in Kafka, which delay flushing the data to files
and potentially causing data loses on killing Kafka brokers in the tests.

This message was sent by Atlassian JIRA

View raw message