[
https://issues.apache.org/jira/browse/FLINK-26242?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chesnay Schepler reopened FLINK-26242:
--------------------------------------
> Pulsar connector tests fails the JVM with exit code 255
> -------------------------------------------------------
>
> Key: FLINK-26242
> URL: https://issues.apache.org/jira/browse/FLINK-26242
> Project: Flink
> Issue Type: Bug
> Components: Connectors / Pulsar
> Affects Versions: 1.15.0
> Reporter: Yun Gao
> Priority: Critical
> Labels: test-stability
>
> {code:java}
> 23:03:52,970 [metadata-store-906-1] INFO
> org.apache.pulsar.broker.namespace.OwnedBundle [] - Unloading
> pulsar/standalone/127.0.0.1:43356/0x00000000_0xffffffff namespace-bundle with
> 0 topics completed in 1.0 ms
> 23:03:52,970 [ main] INFO
> org.apache.pulsar.broker.namespace.OwnedBundle [] - Disabling
> ownership: pulsar/127.0.0.1:43356/0x00000000_0xffffffff
> 23:03:52,971 [metadata-store-906-1] INFO
> org.apache.pulsar.broker.namespace.OwnershipCache [] - Resource
> lock for /namespace/pulsar/127.0.0.1:43356/0x00000000_0xffffffff has expired
> 23:03:52,971 [metadata-store-906-1] INFO
> org.apache.pulsar.metadata.coordination.impl.LockManagerImpl [] - Released
> resource lock on /namespace/pulsar/127.0.0.1:43356/0x00000000_0xffffffff
> 23:03:52,971 [metadata-store-906-1] INFO
> org.apache.pulsar.broker.namespace.OwnedBundle [] - Unloading
> pulsar/127.0.0.1:43356/0x00000000_0xffffffff namespace-bundle with 0 topics
> completed in 1.0 ms
> 23:03:52,971 [ main] INFO
> org.apache.pulsar.broker.namespace.OwnedBundle [] - Disabling
> ownership: public/default/0xc0000000_0xffffffff
> 23:03:52,972 [metadata-store-906-1] INFO
> org.apache.pulsar.broker.namespace.OwnershipCache [] - Resource
> lock for /namespace/public/default/0xc0000000_0xffffffff has expired
> 23:03:52,973 [metadata-store-906-1] INFO
> org.apache.pulsar.metadata.coordination.impl.LockManagerImpl [] - Released
> resource lock on /namespace/public/default/0xc0000000_0xffffffff
> 23:03:52,973 [metadata-store-906-1] INFO
> org.apache.pulsar.broker.namespace.OwnedBundle [] - Unloading
> public/default/0xc0000000_0xffffffff namespace-bundle with 0 topics completed
> in 1.0 ms
> 23:03:52,973 [ main] INFO
> org.apache.pulsar.broker.service.BrokerService [] - Unloading 7
> namespace-bundles completed in 0.009 seconds
> 23:03:52,973 [ main] INFO
> org.apache.pulsar.broker.service.BrokerService [] - Event loops
> shutting down gracefully...
> 23:03:52,974 [ pulsar-io-905-10] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x79d7ad85, L:/127.0.0.1:55188 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,974 [ pulsar-io-905-6] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x98490f33, L:/127.0.0.1:55180 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,974 [ bookie-io-888-9] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x28997aa1, L:/127.0.0.1:35707 ! R:/127.0.0.1:55188]
> 23:03:52,974 [ bookie-io-888-5] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x4a15d8d9, L:/127.0.0.1:35707 ! R:/127.0.0.1:55180]
> 23:03:52,975 [ bookie-io-888-3] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0xbf8feb70, L:/127.0.0.1:35707 ! R:/127.0.0.1:55176]
> 23:03:52,975 [ pulsar-io-905-4] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0xe8635990, L:/127.0.0.1:55176 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ pulsar-io-905-12] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x50cd9cf3, L:/127.0.0.1:55192 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ pulsar-io-905-5] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x83aa4bab, L:/127.0.0.1:55178 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ bookie-io-888-4] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x1fb66760, L:/127.0.0.1:35707 ! R:/127.0.0.1:55178]
> 23:03:52,975 [ bookie-io-888-11] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x72c5c9d1, L:/127.0.0.1:35707 ! R:/127.0.0.1:55192]
> 23:03:52,975 [ pulsar-io-905-3] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0xb6a6a3d0, L:/127.0.0.1:55174 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ pulsar-io-905-13] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x23fa0dd7, L:/127.0.0.1:55194 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ bookie-io-888-10] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0xf4a9f6a4, L:/127.0.0.1:35707 ! R:/127.0.0.1:55190]
> 23:03:52,975 [ pulsar-io-905-9] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x289673fc, L:/127.0.0.1:55186 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ pulsar-io-905-8] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0xc96787a6, L:/127.0.0.1:55184 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ pulsar-io-905-7] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x5e604b5f, L:/127.0.0.1:55182 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ bookie-io-888-12] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x9bbb5996, L:/127.0.0.1:35707 ! R:/127.0.0.1:55194]
> 23:03:52,975 [ bookie-io-888-15] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x4f4fc0bf, L:/127.0.0.1:35707 ! R:/127.0.0.1:55200]
> 23:03:52,975 [ bookie-io-888-8] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0xbc826e77, L:/127.0.0.1:35707 ! R:/127.0.0.1:55186]
> 23:03:52,975 [ bookie-io-888-7] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x0e336268, L:/127.0.0.1:35707 ! R:/127.0.0.1:55184]
> 23:03:52,975 [ bookie-io-888-16] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0xea5d1879, L:/127.0.0.1:35707 ! R:/127.0.0.1:55202]
> 23:03:52,975 [ bookie-io-888-2] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x6198c677, L:/127.0.0.1:35707 ! R:/127.0.0.1:55174]
> 23:03:52,975 [ bookie-io-888-17] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x39cbfe10, L:/127.0.0.1:35707 ! R:/127.0.0.1:55204]
> 23:03:52,975 [ bookie-io-888-6] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x1e89334c, L:/127.0.0.1:35707 ! R:/127.0.0.1:55182]
> 23:03:52,975 [ bookie-io-888-14] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x2484a8d3, L:/127.0.0.1:35707 ! R:/127.0.0.1:55198]
> 23:03:52,975 [ bookie-io-888-13] INFO
> org.apache.bookkeeper.proto.BookieRequestHandler [] - Channels
> disconnected: [id: 0x4d5b89ae, L:/127.0.0.1:35707 ! R:/127.0.0.1:55196]
> 23:03:52,975 [ pulsar-io-905-18] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x39d01da6, L:/127.0.0.1:55204 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ pulsar-io-905-17] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x39d52a4d, L:/127.0.0.1:55202 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ pulsar-io-905-16] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0xe0fc1f2e, L:/127.0.0.1:55200 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ pulsar-io-905-14] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x15c15745, L:/127.0.0.1:55196 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ pulsar-io-905-15] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x98d93df4, L:/127.0.0.1:55198 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,975 [ pulsar-io-905-11] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] -
> Disconnected from bookie channel [id: 0x15df3e30, L:/127.0.0.1:55190 !
> R:127.0.0.1/127.0.0.1:35707]
> 23:03:52,979 [ main] INFO
> org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl [] - Closing 0
> ledgers
> 23:03:52,979 [ main] INFO
> org.apache.bookkeeper.mledger.impl.ManagedLedgerFactoryImpl [] - 0 ledgers
> closed
> 23:03:52,979 [ main] INFO
> org.apache.pulsar.broker.ManagedLedgerClientFactory [] - Closed
> managed ledger factory
> 23:03:52,979 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,075 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,075 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,175 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,175 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,175 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,175 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,275 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,275 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,275 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,275 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,375 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,375 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,475 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,475 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,575 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,575 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,576 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,576 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,675 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,675 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,775 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,776 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,776 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,776 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,876 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,876 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,976 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:53,976 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:54,076 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:54,076 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:54,176 [ main] INFO
> org.apache.bookkeeper.proto.PerChannelBookieClient [] - Closing the
> per channel bookie client for 127.0.0.1:35707
> 23:03:54,281 [ main] INFO
> org.apache.pulsar.broker.ManagedLedgerClientFactory [] - Closed
> BookKeeper client
> 23:03:54,288 [ main] INFO
> org.apache.pulsar.client.impl.PulsarClientImpl [] - Client
> closing. URL: pulsar://127.0.0.1:44420
> 23:03:54,810 [ pulsar-timer-290-1] INFO
> org.apache.pulsar.client.impl.ConnectionHandler [] -
> [persistent://public/default/TNulyTWEkb-partition-0] [standalone-0-18]
> Reconnecting after connection was closed
> 23:03:54,810 [pulsar-client-io-287-1] WARN
> org.apache.pulsar.client.impl.ConnectionPool [] - Failed to
> open connection to 127.0.0.1:35202 :
> io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..)
> failed: Connection refused: /127.0.0.1:35202
> 23:03:54,810 [pulsar-client-io-287-1] WARN
> org.apache.pulsar.client.impl.ConnectionHandler [] -
> [persistent://public/default/TNulyTWEkb-partition-0] [standalone-0-18] Error
> connecting to broker: org.apache.pulsar.client.api.PulsarClientException:
> java.util.concurrent.CompletionException:
> io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..)
> failed: Connection refused: /127.0.0.1:35202
> 23:03:54,810 [pulsar-client-io-287-1] WARN
> org.apache.pulsar.client.impl.ConnectionHandler [] -
> [persistent://public/default/TNulyTWEkb-partition-0] [standalone-0-18] Could
> not get connection to broker:
> org.apache.pulsar.client.api.PulsarClientException:
> java.util.concurrent.CompletionException:
> io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..)
> failed: Connection refused: /127.0.0.1:35202 -- Will try again in 57.446 s
> 23:03:57,858 [ pulsar-timer-174-1] INFO
> org.apache.pulsar.client.impl.ConnectionHandler [] -
> [persistent://public/default/FCgUXgcoQQ-partition-3] [standalone-0-19]
> Reconnecting after connection was closed
> 23:03:57,858 [pulsar-client-io-171-1] WARN
> org.apache.pulsar.client.impl.ConnectionPool [] - Failed to
> open connection to 127.0.0.1:43427 :
> io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..)
> failed: Connection refused: /127.0.0.1:43427
> 23:03:57,858 [pulsar-client-io-171-1] WARN
> org.apache.pulsar.client.impl.ConnectionHandler [] -
> [persistent://public/default/FCgUXgcoQQ-partition-3] [standalone-0-19] Error
> connecting to broker: org.apache.pulsar.client.api.PulsarClientException:
> java.util.concurrent.CompletionException:
> io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..)
> failed: Connection refused: /127.0.0.1:43427
> 23:03:57,858 [pulsar-client-io-171-1] WARN
> org.apache.pulsar.client.impl.ConnectionHandler [] -
> [persistent://public/default/FCgUXgcoQQ-partition-3] [standalone-0-19] Could
> not get connection to broker:
> org.apache.pulsar.client.api.PulsarClientException:
> java.util.concurrent.CompletionException:
> io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..)
> failed: Connection refused: /127.0.0.1:43427 -- Will try again in 54.799 s
> 23:03:59,180 [globalEventExecutor-2-107] INFO
> org.apache.pulsar.broker.service.BrokerService [] - Event loops
> shutdown completed.
> 23:03:59,180 [globalEventExecutor-2-107] INFO
> org.apache.pulsar.broker.service.BrokerService [] - Continuing
> to second phase in shutdown.
> 23:03:59,181 [globalEventExecutor-2-107] INFO
> org.apache.pulsar.broker.service.GracefulExecutorServicesTerminationHandler
> [] - Starting termination handler for 7 executors.
> 23:03:59,181 [globalEventExecutor-2-107] INFO
> org.apache.pulsar.broker.service.GracefulExecutorServicesTerminationHandler
> [] - Shutdown completed.
> 23:03:59,181 [globalEventExecutor-2-107] INFO
> org.apache.pulsar.broker.service.BrokerService [] - Broker
> service completely shut down
> 23:03:59,390 [metadata-store-zk-session-watcher-907-1] ERROR
> org.apache.pulsar.metadata.impl.ZKSessionWatcher [] - ZooKeeper
> session expired
> 23:03:59,390 [ main-EventThread] INFO
> org.apache.pulsar.zookeeper.ZooKeeperDataCache [] -
> [State:CLOSED sessionid:0x1010dec3e770002 local:/127.0.0.1:36606
> remoteserver:localhost/127.0.0.1:43696 lastZxid:217 xid:350 sent:350 recv:491
> queuedpkts:0 pendingresp:0 queuedevents:1] Received ZooKeeper watch event:
> WatchedEvent state:Closed type:None path:null
> 23:03:59,390 [metadata-store-zk-session-watcher-907-1] INFO
> org.apache.pulsar.broker.PulsarService [] - Received
> metadata service session event: SessionLost
> 23:03:59,391 [metadata-store-zk-session-watcher-907-1] WARN
> org.apache.pulsar.broker.PulsarService [] - The session
> with metadata service was lost. Shutting down.
> 23:03:59,391 [metadata-store-zk-session-watcher-907-1] INFO
> org.apache.pulsar.broker.PulsarService [] - Invoking
> Pulsar service immediate shutdown
> 23:03:59,391 [metadata-store-zk-session-watcher-907-1] WARN
> org.apache.pulsar.broker.PulsarService [] - Failed to
> close metadata service session: null
> 23:03:59,392 [metadata-store-zk-session-watcher-907-1] INFO
> org.apache.flink.connector.pulsar.testutils.runtime.embedded.PulsarEmbeddedRuntime
> [] - Halting standalone process with code -1 {code}
> From the log it seems to be the teardown phase of
> org.apache.flink.connector.pulsar.source.enumerator.subscriber.PulsarSubscriberTest.topicListSubscriber
>
> https://dev.azure.com/apache-flink/apache-flink/_build/results?buildId=31797&view=logs&j=fc5181b0-e452-5c8f-68de-1097947f6483&t=995c650b-6573-581c-9ce6-7ad4cc038461&l=27176
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
