Yun Gao created FLINK-26242:
-------------------------------
Summary: 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
{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
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
