You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Till Rohrmann (JIRA)" <ji...@apache.org> on 2018/03/29 15:28:00 UTC

[jira] [Commented] (FLINK-8820) FlinkKafkaConsumer010 reads too many bytes

    [ https://issues.apache.org/jira/browse/FLINK-8820?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16419193#comment-16419193 ] 

Till Rohrmann commented on FLINK-8820:
--------------------------------------

I would like to unblock 1.5.0 from this issue since it seems to exist since Flink 1.4.0. Moreover, we are currently still investigating. We should definitely keep an eye on this issue.

> FlinkKafkaConsumer010 reads too many bytes
> ------------------------------------------
>
>                 Key: FLINK-8820
>                 URL: https://issues.apache.org/jira/browse/FLINK-8820
>             Project: Flink
>          Issue Type: Bug
>          Components: Kafka Connector
>    Affects Versions: 1.4.0
>            Reporter: Fabian Hueske
>            Priority: Blocker
>             Fix For: 1.5.0
>
>
> A user reported that the FlinkKafkaConsumer010 very rarely consumes too many bytes, i.e., the returned message is too large. The application is running for about a year and the problem started to occur after upgrading to Flink 1.4.0.
> The user made a good effort in debugging the problem but was not able to reproduce it in a controlled environment. It seems that the data is correctly stored in Kafka.
> Here's the thread on the thread on the user mailing list for a detailed description of the problem and analysis so far: https://lists.apache.org/thread.html/1d62f616d275e9e23a5215ddf7f5466051be7ea96897d827232fcb4e@%3Cuser.flink.apache.org%3E



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)