You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "HunterHunter (Jira)" <ji...@apache.org> on 2022/07/07 06:07:00 UTC
[jira] [Comment Edited] (FLINK-28435) Flink version 1.15.0 consumption Kafka has backpressure.
[ https://issues.apache.org/jira/browse/FLINK-28435?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17563586#comment-17563586 ]
HunterHunter edited comment on FLINK-28435 at 7/7/22 6:06 AM:
--------------------------------------------------------------
[~jark]
Can you help me find someone to have a look
was (Author: hunterhunter):
[~jark]
> Flink version 1.15.0 consumption Kafka has backpressure.
> ---------------------------------------------------------
>
> Key: FLINK-28435
> URL: https://issues.apache.org/jira/browse/FLINK-28435
> Project: Flink
> Issue Type: Bug
> Affects Versions: 1.15.0
> Reporter: HunterHunter
> Priority: Major
>
> A simple SQL program
> {code:java}
> CREATE temporary TABLE `print_sink` (
> `id` VARCHAR(2147483647)
> )WITH (
> 'connector' = 'print'
> );
> insert into print_sink
> select id
> from kafka-source
> /*+ OPTIONS('properties.bootstrap.servers'='brokers',
> 'topic' = 'topicname',
> 'properties.group.id'='test',
> 'scan.startup.mode'='latest-offset')
> */ {code}
> Back pressure occurs when I use `flink 1.15.0`,
> When I use `flink 1.13/ flink 1.14`, it works normally.
> I think this is caused by the version of Kafka.
> I have tried to consume versions `Kafka 1.1` and `Kafka 2.7.1`, and `Flink 1.13/1.14` is normal （`Kafka 2.4.1` is used in `Flink 1.13/1.14`）;
> But `Flink 1.15` has back pressure. (I had try to change Kafka version to `Kafka 2.7.1`, which is still back pressure).
>
>
>
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)