[
https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17628623#comment-17628623
]
Yufan Sheng edited comment on FLINK-29495 at 11/4/22 1:42 AM:
--------------------------------------------------------------
[~martijnvisser] The CI link you have provided is tests on flink release-1.15
branch. And this is an error which has been fixed in
https://github.com/apache/pulsar/pull/15840 and released in Pulsar 2.10.1. Do
we need to bump the pulsar-client to 2.10.1 in release-1.15 branch to fix this
hang issue?
was (Author: syhily):
[~martijnvisser] The CI link you have provided is tests on flink release-1.15
branch. And this is an error which has been fixed in
https://github.com/apache/pulsar/pull/15840 and released in Pulsar 2.10.1. Do
we need to bump the pulsar-client to 2.10.1 in release-1.15 branch?
> PulsarSinkE2ECase hang
> ----------------------
>
> Key: FLINK-29495
> URL: https://issues.apache.org/jira/browse/FLINK-29495
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.16.0, 1.17.0, 1.15.2
> Reporter: Xingbo Huang
> Priority: Major
> Labels: pull-request-available, test-stability
> Fix For: 1.16.0, 1.17.0, 1.15.3
>
>
> {code:java}
> 2022-10-02T05:53:56.0611489Z "main" #1 prio=5 os_prio=0 cpu=5171.60ms
> elapsed=9072.82s tid=0x00007f9508028000 nid=0x54ef1 waiting on condition
> [0x00007f950f994000]
> 2022-10-02T05:53:56.0612041Z java.lang.Thread.State: TIMED_WAITING
> (parking)
> 2022-10-02T05:53:56.0612475Z at
> jdk.internal.misc.Unsafe.park([email protected]/Native Method)
> 2022-10-02T05:53:56.0613302Z - parking to wait for <0x0000000087d261f8> (a
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
> 2022-10-02T05:53:56.0613959Z at
> java.util.concurrent.locks.LockSupport.parkNanos([email protected]/LockSupport.java:234)
> 2022-10-02T05:53:56.0614661Z at
> java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos([email protected]/AbstractQueuedSynchronizer.java:2123)
> 2022-10-02T05:53:56.0615428Z at
> org.apache.pulsar.common.util.collections.GrowableArrayBlockingQueue.poll(GrowableArrayBlockingQueue.java:203)
> 2022-10-02T05:53:56.0616165Z at
> org.apache.pulsar.client.impl.MultiTopicsConsumerImpl.internalReceive(MultiTopicsConsumerImpl.java:370)
> 2022-10-02T05:53:56.0616807Z at
> org.apache.pulsar.client.impl.ConsumerBase.receive(ConsumerBase.java:198)
> 2022-10-02T05:53:56.0617486Z at
> org.apache.flink.connector.pulsar.testutils.sink.PulsarPartitionDataReader.poll(PulsarPartitionDataReader.java:72)
> {code}
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=41526&view=logs&j=6e8542d7-de38-5a33-4aca-458d6c87066d&t=5846934b-7a4f-545b-e5b0-eb4d8bda32e1
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
