[
https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17746177#comment-17746177
]
Zili Chen commented on FLINK-32645:
-----------------------------------
What version of Flink Pulsar connector did you use? 1.16.2 is Flink version and
now Pulsar Flink connector takes it own version series
https://github.com/apache/flink-connector-pulsar. Generally, 3.0.1 or 4.0.0.
> Flink pulsar sink is having poor performance
> --------------------------------------------
>
> Key: FLINK-32645
> URL: https://issues.apache.org/jira/browse/FLINK-32645
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.16.2
> Environment: !Screenshot 2023-07-22 at 1.59.42 PM.png!!Screenshot
> 2023-07-22 at 2.03.53 PM.png!
>
> Reporter: Vijaya Bhaskar V
> Priority: Major
> Attachments: Screenshot 2023-07-22 at 2.03.53 PM.png, Screenshot
> 2023-07-22 at 2.56.55 PM.png, Screenshot 2023-07-22 at 3.45.21 PM-1.png,
> Screenshot 2023-07-22 at 3.45.21 PM.png
>
>
> Found following issue with flink pulsar sink:
>
> Flink pulsar sink is always waiting while enqueueing the message and making
> the task slot busy no matter how many free slots we provide. Attached the
> screen shot of the same
> Just sending messages of less rate 8k msg/sec and stand alone flink job with
> discarding sink is able to receive full rate if 8K msg/sec
> Where as pulsar sink was consuming only upto 2K msg/sec and the sink is
> always busy waiting. Snapshot of thread dump attached.
> Also snap shot of flink stream graph attached
>
>
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
