[
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)
