HunterHunter created FLINK-28435:
------------------------------------
Summary: 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
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)
