You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Vijaya Bhaskar V (Jira)" <ji...@apache.org> on 2023/08/01 07:06:00 UTC
[jira] [Commented] (FLINK-32645) Flink pulsar sink is having poor performance
[ https://issues.apache.org/jira/browse/FLINK-32645?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17749501#comment-17749501 ]
Vijaya Bhaskar V commented on FLINK-32645:
------------------------------------------
[~syhily] thanks its working fine now. Will report here any other issues if we see. Please keep the ticket open until that time
> 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
> Assignee: Zili Chen
> Priority: Major
> Fix For: pulsar-3.0.2
>
> 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, pom.xml
>
>
> 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)