[jira] [Closed] (FLINK-29495) PulsarSinkE2ECase hang
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-29495. - Resolution: Fixed follow-up to fix 1.15 via b37999514cbbd019b31fb2d9c4ae751a956f6c87 > 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 >Assignee: Yufan Sheng >Priority: Major > Labels: pull-request-available, test-stability > Fix For: 1.17.0, 1.15.3, 1.16.0 > > > {code:java} > 2022-10-02T05:53:56.0611489Z "main" #1 prio=5 os_prio=0 cpu=5171.60ms > elapsed=9072.82s tid=0x7f9508028000 nid=0x54ef1 waiting on condition > [0x7f950f994000] > 2022-10-02T05:53:56.0612041Zjava.lang.Thread.State: TIMED_WAITING > (parking) > 2022-10-02T05:53:56.0612475Z at > jdk.internal.misc.Unsafe.park(java.base@11.0.16.1/Native Method) > 2022-10-02T05:53:56.0613302Z - parking to wait for <0x87d261f8> (a > java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) > 2022-10-02T05:53:56.0613959Z at > java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.16.1/LockSupport.java:234) > 2022-10-02T05:53:56.0614661Z at > java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.16.1/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=logs=6e8542d7-de38-5a33-4aca-458d6c87066d=5846934b-7a4f-545b-e5b0-eb4d8bda32e1 -- This message was sent by Atlassian Jira (v8.20.10#820010)
[jira] [Closed] (FLINK-29495) PulsarSinkE2ECase hang
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Zili Chen closed FLINK-29495. - Fix Version/s: 1.16.0 1.17.0 1.15.3 Assignee: Martijn Visser (was: Yufan Sheng) Resolution: Fixed > 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 >Assignee: Martijn Visser >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=0x7f9508028000 nid=0x54ef1 waiting on condition > [0x7f950f994000] > 2022-10-02T05:53:56.0612041Zjava.lang.Thread.State: TIMED_WAITING > (parking) > 2022-10-02T05:53:56.0612475Z at > jdk.internal.misc.Unsafe.park(java.base@11.0.16.1/Native Method) > 2022-10-02T05:53:56.0613302Z - parking to wait for <0x87d261f8> (a > java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject) > 2022-10-02T05:53:56.0613959Z at > java.util.concurrent.locks.LockSupport.parkNanos(java.base@11.0.16.1/LockSupport.java:234) > 2022-10-02T05:53:56.0614661Z at > java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.awaitNanos(java.base@11.0.16.1/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=logs=6e8542d7-de38-5a33-4aca-458d6c87066d=5846934b-7a4f-545b-e5b0-eb4d8bda32e1 -- This message was sent by Atlassian Jira (v8.20.10#820010)