You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "Yufan Sheng (Jira)" <ji...@apache.org> on 2022/11/02 08:56:03 UTC
[jira] [Comment Edited] (FLINK-29495) PulsarSinkE2ECase hang
[ https://issues.apache.org/jira/browse/FLINK-29495?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17627533#comment-17627533 ]
Yufan Sheng edited comment on FLINK-29495 at 11/2/22 8:55 AM:
--------------------------------------------------------------
[~martijnvisser] I have checked the CI logs. It's wired and shows a NP exception. I think we can create a new one and close this one?
{code}
org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: java.lang.NullPointerException
at org.apache.pulsar.client.impl.ConnectionHandler.handleConnectionError(ConnectionHandler.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:884) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.uniExceptionallyStage(CompletableFuture.java:898) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.exceptionally(CompletableFuture.java:2209) ~[?:1.8.0_342]
at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:74) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.<init>(TransactionMetaStoreHandler.java:105) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.lambda$startAsync$0(TransactionCoordinatorClientImpl.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:995) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2137) ~[?:1.8.0_342]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.startAsync(TransactionCoordinatorClientImpl.java:78) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.start(TransactionCoordinatorClientImpl.java:68) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.PulsarClientImpl.<init>(PulsarClientImpl.java:204) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.PulsarClientImpl.<init>(PulsarClientImpl.java:140) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.ClientBuilderImpl.build(ClientBuilderImpl.java:67) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.flink.connector.pulsar.common.utils.PulsarExceptionUtils.sneaky(PulsarExceptionUtils.java:69) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
at org.apache.flink.connector.pulsar.common.utils.PulsarExceptionUtils.sneakyClient(PulsarExceptionUtils.java:46) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
at org.apache.flink.connector.pulsar.common.config.PulsarClientFactory.createClient(PulsarClientFactory.java:152) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
at org.apache.flink.connector.pulsar.sink.committer.PulsarCommitter.transactionCoordinatorClient(PulsarCommitter.java:158) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
at org.apache.flink.connector.pulsar.sink.committer.PulsarCommitter.commit(PulsarCommitter.java:70) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.operators.sink.committables.CheckpointCommittableManagerImpl.commit(CheckpointCommittableManagerImpl.java:126) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.commitAndEmit(CommitterOperator.java:176) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.commitAndEmitCheckpoints(CommitterOperator.java:160) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.notifyCheckpointComplete(CommitterOperator.java:150) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.notifyCheckpointComplete(StreamOperatorWrapper.java:104) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.notifyCheckpointComplete(RegularOperatorChain.java:145) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpoint(SubtaskCheckpointCoordinatorImpl.java:409) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpointComplete(SubtaskCheckpointCoordinatorImpl.java:343) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.notifyCheckpointComplete(StreamTask.java:1387) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointCompleteAsync$14(StreamTask.java:1328) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointOperation$17(StreamTask.java:1367) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsNonBlocking(MailboxProcessor.java:353) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:317) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:201) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:807) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:756) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342]
Caused by: java.util.concurrent.CompletionException: java.lang.NullPointerException
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:673) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010) ~[?:1.8.0_342]
at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d9
3a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
... 37 more
Caused by: java.lang.NullPointerException
at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.connectionOpened(TransactionMetaStoreHandler.java:121) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.ConnectionHandler.lambda$grabCnx$0(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010) ~[?:1.8.0_342]
at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
... 37 more
2022-11-02 03:49:56,321 WARN org.apache.pulsar.client.impl.ConnectionHandler [] - [persistent://pulsar/system/transaction_coordinator_assign-partition-0] [Transaction meta store handler [0]] Could not get connection to broker: java.lang.NullPointerException -- Will try again in 0.1 s
2022-11-02 03:49:56,322 ERROR org.apache.pulsar.client.impl.PulsarClientImpl [] - Start transactionCoordinatorClient error.
org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: java.lang.NullPointerException
at org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException.unwrap(TransactionCoordinatorClientException.java:131) ~[blob_p-4b3d6ed05b6715a4188854f7546af20bd5082468-a8d166b6a98b33c8b856fdb9ed3d9ee1:2.10.0]
at org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException.unwrap(TransactionCoordinatorClientException.java:129) ~[blob_p-4b3d6ed05b6715a4188854f7546af20bd5082468-a8d166b6a98b33c8b856fdb9ed3d9ee1:2.10.0]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.start(TransactionCoordinatorClientImpl.java:70) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.PulsarClientImpl.<init>(PulsarClientImpl.java:204) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.PulsarClientImpl.<init>(PulsarClientImpl.java:140) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.ClientBuilderImpl.build(ClientBuilderImpl.java:67) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.flink.connector.pulsar.common.utils.PulsarExceptionUtils.sneaky(PulsarExceptionUtils.java:69) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
at org.apache.flink.connector.pulsar.common.utils.PulsarExceptionUtils.sneakyClient(PulsarExceptionUtils.java:46) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
at org.apache.flink.connector.pulsar.common.config.PulsarClientFactory.createClient(PulsarClientFactory.java:152) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
at org.apache.flink.connector.pulsar.sink.committer.PulsarCommitter.transactionCoordinatorClient(PulsarCommitter.java:158) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
at org.apache.flink.connector.pulsar.sink.committer.PulsarCommitter.commit(PulsarCommitter.java:70) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.operators.sink.committables.CheckpointCommittableManagerImpl.commit(CheckpointCommittableManagerImpl.java:126) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.commitAndEmit(CommitterOperator.java:176) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.commitAndEmitCheckpoints(CommitterOperator.java:160) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.notifyCheckpointComplete(CommitterOperator.java:150) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.notifyCheckpointComplete(StreamOperatorWrapper.java:104) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.notifyCheckpointComplete(RegularOperatorChain.java:145) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpoint(SubtaskCheckpointCoordinatorImpl.java:409) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpointComplete(SubtaskCheckpointCoordinatorImpl.java:343) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.notifyCheckpointComplete(StreamTask.java:1387) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointCompleteAsync$14(StreamTask.java:1328) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointOperation$17(StreamTask.java:1367) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsNonBlocking(MailboxProcessor.java:353) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:317) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:201) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:807) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:756) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342]
Caused by: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: java.lang.NullPointerException
at org.apache.pulsar.client.impl.ConnectionHandler.handleConnectionError(ConnectionHandler.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:884) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.uniExceptionallyStage(CompletableFuture.java:898) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.exceptionally(CompletableFuture.java:2209) ~[?:1.8.0_342]
at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:74) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.<init>(TransactionMetaStoreHandler.java:105) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.lambda$startAsync$0(TransactionCoordinatorClientImpl.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:995) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2137) ~[?:1.8.0_342]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.startAsync(TransactionCoordinatorClientImpl.java:78) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.start(TransactionCoordinatorClientImpl.java:68) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
... 31 more
Caused by: java.util.concurrent.CompletionException: java.lang.NullPointerException
at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:673) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010) ~[?:1.8.0_342]
at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.<init>(TransactionMetaStoreHandler.java:105) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.lambda$startAsync$0(TransactionCoordinatorClientImpl.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:995) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2137) ~[?:1.8.0_342]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.startAsync(TransactionCoordinatorClientImpl.java:78) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.start(TransactionCoordinatorClientImpl.java:68) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
... 31 more
Caused by: java.lang.NullPointerException
at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.connectionOpened(TransactionMetaStoreHandler.java:121) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.ConnectionHandler.lambda$grabCnx$0(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010) ~[?:1.8.0_342]
at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.<init>(TransactionMetaStoreHandler.java:105) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.lambda$startAsync$0(TransactionCoordinatorClientImpl.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:995) ~[?:1.8.0_342]
at java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2137) ~[?:1.8.0_342]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.startAsync(TransactionCoordinatorClientImpl.java:78) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.start(TransactionCoordinatorClientImpl.java:68) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
... 31 more
{code}
was (Author: syhily):
[~martijnvisser] I have checked the CI logs. It's wired and shows a NP exception. I think we can create a new one and clone this one?
{code}
03:49:56,302 [docker-java-stream--220176269] INFO org.apache.flink.connector.pulsar.testutils.runtime.container.PulsarContainerRuntime [] - 2022-11-02T03:49:56,301+0000 [pulsar-io-20-3] INFO org.apache.pulsar.broker.service.ServerCnx - New connection from /172.24.0.4:41994
03:49:56,308 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: 2022-11-02 03:49:56,308 INFO org.apache.pulsar.client.impl.ConnectionPool [] - [[id: 0x756274ea, L:/172.24.0.4:41994 - R:pulsar/172.24.0.5:6650]] Connected to server
03:49:56,313 [docker-java-stream--220176269] INFO org.apache.flink.connector.pulsar.testutils.runtime.container.PulsarContainerRuntime [] - 2022-11-02T03:49:56,313+0000 [pulsar-io-20-4] INFO org.apache.pulsar.broker.service.ServerCnx - New connection from /172.24.0.4:42002
03:49:56,315 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: 2022-11-02 03:49:56,314 INFO org.apache.pulsar.client.impl.ConnectionPool [] - [[id: 0x285ea2f5, L:/172.24.0.4:42002 - R:pulsar/172.24.0.5:6650]] Connected to server
03:49:56,316 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: 2022-11-02 03:49:56,315 WARN org.apache.pulsar.client.impl.ConnectionHandler [] - [persistent://pulsar/system/transaction_coordinator_assign-partition-0] [Transaction meta store handler [0]] Error connecting to broker: java.lang.NullPointerException
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: 2022-11-02 03:49:56,317 ERROR org.apache.pulsar.client.impl.TransactionMetaStoreHandler [] - Transaction meta handler with transaction coordinator id 0 connection failed.
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: java.lang.NullPointerException
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ConnectionHandler.handleConnectionError(ConnectionHandler.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:884) ~[?:1.8.0_342]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniExceptionallyStage(CompletableFuture.java:898) ~[?:1.8.0_342]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.exceptionally(CompletableFuture.java:2209) ~[?:1.8.0_342]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:74) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.<init>(TransactionMetaStoreHandler.java:105) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.lambda$startAsync$0(TransactionCoordinatorClientImpl.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:995) ~[?:1.8.0_342]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2137) ~[?:1.8.0_342]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.startAsync(TransactionCoordinatorClientImpl.java:78) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.start(TransactionCoordinatorClientImpl.java:68) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.PulsarClientImpl.<init>(PulsarClientImpl.java:204) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.PulsarClientImpl.<init>(PulsarClientImpl.java:140) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ClientBuilderImpl.build(ClientBuilderImpl.java:67) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.connector.pulsar.common.utils.PulsarExceptionUtils.sneaky(PulsarExceptionUtils.java:69) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
03:49:56,320 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.connector.pulsar.common.utils.PulsarExceptionUtils.sneakyClient(PulsarExceptionUtils.java:46) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.connector.pulsar.common.config.PulsarClientFactory.createClient(PulsarClientFactory.java:152) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.connector.pulsar.sink.committer.PulsarCommitter.transactionCoordinatorClient(PulsarCommitter.java:158) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.connector.pulsar.sink.committer.PulsarCommitter.commit(PulsarCommitter.java:70) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.operators.sink.committables.CheckpointCommittableManagerImpl.commit(CheckpointCommittableManagerImpl.java:126) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.commitAndEmit(CommitterOperator.java:176) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.commitAndEmitCheckpoints(CommitterOperator.java:160) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.notifyCheckpointComplete(CommitterOperator.java:150) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.notifyCheckpointComplete(StreamOperatorWrapper.java:104) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.notifyCheckpointComplete(RegularOperatorChain.java:145) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpoint(SubtaskCheckpointCoordinatorImpl.java:409) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpointComplete(SubtaskCheckpointCoordinatorImpl.java:343) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTask.notifyCheckpointComplete(StreamTask.java:1387) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointCompleteAsync$14(StreamTask.java:1328) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointOperation$17(StreamTask.java:1367) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsNonBlocking(MailboxProcessor.java:353) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:317) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:201) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:807) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:756) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: Caused by: java.util.concurrent.CompletionException: java.lang.NullPointerException
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_342]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_342]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:673) ~[?:1.8.0_342]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683) ~[?:1.8.0_342]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010) ~[?:1.8.0_342]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d9
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: 3a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: ... 37 more
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: Caused by: java.lang.NullPointerException
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.connectionOpened(TransactionMetaStoreHandler.java:121) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ConnectionHandler.lambda$grabCnx$0(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) ~[?:1.8.0_342]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683) ~[?:1.8.0_342]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010) ~[?:1.8.0_342]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: ... 37 more
03:49:56,321 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: 2022-11-02 03:49:56,321 WARN org.apache.pulsar.client.impl.ConnectionHandler [] - [persistent://pulsar/system/transaction_coordinator_assign-partition-0] [Transaction meta store handler [0]] Could not get connection to broker: java.lang.NullPointerException -- Will try again in 0.1 s
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: 2022-11-02 03:49:56,322 ERROR org.apache.pulsar.client.impl.PulsarClientImpl [] - Start transactionCoordinatorClient error.
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: java.lang.NullPointerException
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException.unwrap(TransactionCoordinatorClientException.java:131) ~[blob_p-4b3d6ed05b6715a4188854f7546af20bd5082468-a8d166b6a98b33c8b856fdb9ed3d9ee1:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.api.transaction.TransactionCoordinatorClientException.unwrap(TransactionCoordinatorClientException.java:129) ~[blob_p-4b3d6ed05b6715a4188854f7546af20bd5082468-a8d166b6a98b33c8b856fdb9ed3d9ee1:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.start(TransactionCoordinatorClientImpl.java:70) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.PulsarClientImpl.<init>(PulsarClientImpl.java:204) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.PulsarClientImpl.<init>(PulsarClientImpl.java:140) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ClientBuilderImpl.build(ClientBuilderImpl.java:67) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.connector.pulsar.common.utils.PulsarExceptionUtils.sneaky(PulsarExceptionUtils.java:69) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.connector.pulsar.common.utils.PulsarExceptionUtils.sneakyClient(PulsarExceptionUtils.java:46) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.connector.pulsar.common.config.PulsarClientFactory.createClient(PulsarClientFactory.java:152) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.connector.pulsar.sink.committer.PulsarCommitter.transactionCoordinatorClient(PulsarCommitter.java:158) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.connector.pulsar.sink.committer.PulsarCommitter.commit(PulsarCommitter.java:70) ~[blob_p-8b5ac19c79f1f5e8e495fec1e487d5c051157af1-c417788a2d249f7022633051d21c30dd:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.operators.sink.committables.CheckpointCommittableManagerImpl.commit(CheckpointCommittableManagerImpl.java:126) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.commitAndEmit(CommitterOperator.java:176) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.commitAndEmitCheckpoints(CommitterOperator.java:160) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.operators.sink.CommitterOperator.notifyCheckpointComplete(CommitterOperator.java:150) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamOperatorWrapper.notifyCheckpointComplete(StreamOperatorWrapper.java:104) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.notifyCheckpointComplete(RegularOperatorChain.java:145) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpoint(SubtaskCheckpointCoordinatorImpl.java:409) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.SubtaskCheckpointCoordinatorImpl.notifyCheckpointComplete(SubtaskCheckpointCoordinatorImpl.java:343) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTask.notifyCheckpointComplete(StreamTask.java:1387) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointCompleteAsync$14(StreamTask.java:1328) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$notifyCheckpointOperation$17(StreamTask.java:1367) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$1.runThrowing(StreamTaskActionExecutor.java:50) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.mailbox.Mail.run(Mail.java:90) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMailsNonBlocking(MailboxProcessor.java:353) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.processMail(MailboxProcessor.java:317) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.mailbox.MailboxProcessor.runMailboxLoop(MailboxProcessor.java:201) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTask.runMailboxLoop(StreamTask.java:807) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:756) ~[flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:948) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:927) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:741) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.flink.runtime.taskmanager.Task.run(Task.java:563) [flink-dist-1.15-SNAPSHOT.jar:1.15-SNAPSHOT]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.lang.Thread.run(Thread.java:750) [?:1.8.0_342]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: Caused by: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: java.lang.NullPointerException
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ConnectionHandler.handleConnectionError(ConnectionHandler.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniExceptionally(CompletableFuture.java:884) ~[?:1.8.0_342]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniExceptionallyStage(CompletableFuture.java:898) ~[?:1.8.0_342]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.exceptionally(CompletableFuture.java:2209) ~[?:1.8.0_342]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:74) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.<init>(TransactionMetaStoreHandler.java:105) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.lambda$startAsync$0(TransactionCoordinatorClientImpl.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:995) ~[?:1.8.0_342]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2137) ~[?:1.8.0_342]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.imp
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: l.transaction.TransactionCoordinatorClientImpl.startAsync(TransactionCoordinatorClientImpl.java:78) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.start(TransactionCoordinatorClientImpl.java:68) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: ... 31 more
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: Caused by: java.util.concurrent.CompletionException: java.lang.NullPointerException
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.encodeThrowable(CompletableFuture.java:273) ~[?:1.8.0_342]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.completeThrowable(CompletableFuture.java:280) ~[?:1.8.0_342]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:673) ~[?:1.8.0_342]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683) ~[?:1.8.0_342]
03:49:56,326 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010) ~[?:1.8.0_342]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.<init>(TransactionMetaStoreHandler.java:105) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.lambda$startAsync$0(TransactionCoordinatorClientImpl.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:995) ~[?:1.8.0_342]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2137) ~[?:1.8.0_342]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.startAsync(TransactionCoordinatorClientImpl.java:78) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.start(TransactionCoordinatorClientImpl.java:68) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: ... 31 more
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: Caused by: java.lang.NullPointerException
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.connectionOpened(TransactionMetaStoreHandler.java:121) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ConnectionHandler.lambda$grabCnx$0(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniAccept(CompletableFuture.java:670) ~[?:1.8.0_342]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniAcceptStage(CompletableFuture.java:683) ~[?:1.8.0_342]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.thenAccept(CompletableFuture.java:2010) ~[?:1.8.0_342]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.ConnectionHandler.grabCnx(ConnectionHandler.java:73) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.TransactionMetaStoreHandler.<init>(TransactionMetaStoreHandler.java:105) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.lambda$startAsync$0(TransactionCoordinatorClientImpl.java:89) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.uniComposeStage(CompletableFuture.java:995) ~[?:1.8.0_342]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at java.util.concurrent.CompletableFuture.thenCompose(CompletableFuture.java:2137) ~[?:1.8.0_342]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.startAsync(TransactionCoordinatorClientImpl.java:78) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: at org.apache.pulsar.client.impl.transaction.TransactionCoordinatorClientImpl.start(TransactionCoordinatorClientImpl.java:68) ~[blob_p-13182ae1972a0afba0da920da789e044f64d93a3-43e2094ec5a07433aa9a86aa77b6ae17:2.10.0]
03:49:56,327 [docker-java-stream--1630370232] INFO org.apache.flink.tests.util.flink.FlinkContainerTestEnvironment [] - [TaskManager-0] STDOUT: ... 31 more
03:49:56,330 [docker-java-stream--220176269] INFO org.apache.flink.connector.pulsar.testutils.runtime.container.PulsarContainerRuntime [] - 2022-11-02T03:49:56,329+0000 [pulsar-io-20-3] INFO org.apache.pulsar.broker.service.ServerCnx - Closed connection from /172.24.0.4:41994
03:49:56,330 [docker-java-stream--220176269] INFO org.apache.flink.connector.pulsar.testutils.runtime.container.PulsarContainerRuntime [] - 2022-11-02T03:49:56,330+0000 [pulsar-io-20-4] INFO org.apache.pulsar.broker.service.ServerCnx - Closed connection from /172.24.0.4:42002
{code}
> 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(java.base@11.0.16.1/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(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&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)