search

apache / pulsar

Apache Pulsar - distributed pub-sub messaging system
https://pulsar.apache.org/
Apache License 2.0
14.12k stars 3.57k forks source link

Debezium Demo Doesn't Work with 2.9.1 and Aurora 5.x #14305

Closed prime-minister-of-fun closed 1 year ago

prime-minister-of-fun commented 2 years ago

On either amd64 or arm64 Ubuntu images, https://debezium.io/blog/2019/05/23/tutorial-using-debezium-connectors-with-apache-pulsar/ doesn't work with version 2.9.1 binary download.

Tests before running. Pod can connect to AWS with mysql client.

Steps to reproduce: Download pulsar binaries, extract. https://dlcdn.apache.org/pulsar/pulsar-2.9.1/apache-pulsar-2.9.1-bin.tar.gz Download connector dependencies per instructions. apt --assume-yes install wget unzip net-tools scala openjdk-8-jre-headless libcommons-io-java libcommons-lang3-java libcommons-math3-java libcommons-dbcp2-java libavro-java libjackson2-databind-java libcommons-codec-java python3 python3-pip export environment variables, JAVA_HOME, PULSAR_HOME start pulsar: ./bin/pulsar standalone. Appears to be running. Use example debezium-mysql-source-config.yaml and change the hostname and credentials. Server has multiple MySQL databases that all need to be streamed. Either defining all of them in whitelist, or defining none, doesn't change anything. Open new terminal, run: bin/pulsar-admin source localrun --source-config-file /setup/debezium-mysql-source.yaml

It takes a minute to start logging. Then looks like the source is just restarting after crashing:

componentType: SOURCE , maxBufferedTuples=1024, functionAuthenticationSpec=null, port=0, clusterName=local, maxPendingAsyncRequests=1000, exposePulsarAdminClientEnabled=false, metricsPort=0) 2022-02-15T19:53:45,246+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.common.nar.FileUtils - Jar file connectors/pulsar-io-kafka-connect-adaptor-2.9.1.nar contains META-INF/bundled-dependencies, it may be a NAR file 2022-02-15T19:53:45,246+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Trying Loading file as NAR file: connectors/pulsar-io-kafka-connect-adaptor-2.9.1.nar 2022-02-15T19:53:47,043+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Initialize function class loader for function debezium-kafka-source at function cache manager, functionClassLoader: org.apache.pulsar.common.nar.NarClassLoader[/tmp/pulsar_localrunner_nars_7426220787174598080/pulsar-nar/pulsar-io-kafka-connect-adaptor-2.9.1.nar-unpacked/90ickkj44GhweghdXLZZsw] 2022-02-15T19:53:47,044+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - ThreadContainer starting function with instance config InstanceConfig(instanceId=0, functionId=f01479ec-ab28-42eb-9d83-4b1517f72c3d, functionVersion=9879029e-4d46-480f-8a72-3481f5a91771, functionDetails=tenant: "public" namespace: "mysql8pipeline" name: "debezium-kafka-source" className: "org.apache.pulsar.functions.api.utils.IdentityFunction" autoAck: true parallelism: 1 source { className: "org.apache.pulsar.io.kafka.connect.KafkaConnectSource" configs: "{}" typeClassName: "org.apache.pulsar.common.schema.KeyValue" } sink { topic: "all-the-databases" typeClassName: "org.apache.pulsar.common.schema.KeyValue" forwardSourceMessageProperty: true } resources { cpu: 1.0 ram: 1073741824 disk: 10737418240 } componentType: SOURCE , maxBufferedTuples=1024, functionAuthenticationSpec=null, port=0, clusterName=local, maxPendingAsyncRequests=1000, exposePulsarAdminClientEnabled=false, metricsPort=0) 2022-02-15T19:53:47,056+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {"topicName":"all-the-databases","producerName":null,"sendTimeoutMs":0,"blockIfQueueFull":true,"maxPendingMessages":1000,"maxPendingMessagesAcrossPartitions":50000,"messageRoutingMode":"CustomPartition","hashingScheme":"Murmur3_32Hash","cryptoFailureAction":"FAIL","batchingMaxPublishDelayMicros":10000,"batchingPartitionSwitchFrequencyByPublishDelay":10,"batchingMaxMessages":1000,"batchingMaxBytes":131072,"batchingEnabled":true,"chunkingEnabled":false,"compressionType":"LZ4","initialSequenceId":null,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"multiSchema":true,"accessMode":"Shared","lazyStartPartitionedProducers":false,"properties":{"application":"pulsar-source","id":"public/mysql8pipeline/debezium-kafka-source","instance_hostname":"pulsar-ftw-0.pulsar-ftw.pipeline.svc.cluster.local","instance_id":"0"}} 2022-02-15T19:53:47,141+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"useTcpNoDelay":true,"useTls":false,"tlsTrustCertsFilePath":null,"tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsTrustStoreType":"JKS","tlsTrustStorePath":null,"tlsTrustStorePassword":null,"tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null} 2022-02-15T19:53:47,143+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [null] Creating producer on cnx [id: 0x144d34b8, L:/127.0.0.1:53656 - R:localhost/127.0.0.1:6650] 2022-02-15T19:53:47,151+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [standalone-0-22] Created producer on cnx [id: 0x144d34b8, L:/127.0.0.1:53656 - R:localhost/127.0.0.1:6650] 2022-02-15T19:53:47,241+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [standalone-0-22] Closed Producer 2022-02-15T19:54:15,243+0000 [function-timer-thread-6-1] ERROR org.apache.pulsar.functions.runtime.RuntimeSpawner - public/mysql8pipeline/debezium-kafka-source Function Container is dead with following exception. Restarting. java.lang.NullPointerException: null at java.lang.Class.forName0(Native Method) ~[?:1.8.0_312] at java.lang.Class.forName(Class.java:264) ~[?:1.8.0_312] at org.apache.pulsar.io.kafka.connect.AbstractKafkaConnectSource.open(AbstractKafkaConnectSource.java:88) ~[?:?] at org.apache.pulsar.io.kafka.connect.KafkaConnectSource.open(KafkaConnectSource.java:62) ~[?:?] at org.apache.pulsar.functions.instance.JavaInstanceRunnable.setupInput(JavaInstanceRunnable.java:757) ~[org.apache.pulsar-pulsar-functions-instance-2.9.1.jar:2.9.1] at org.apache.pulsar.functions.instance.JavaInstanceRunnable.setup(JavaInstanceRunnable.java:232) ~[org.apache.pulsar-pulsar-functions-instance-2.9.1.jar:2.9.1] at org.apache.pulsar.functions.instance.JavaInstanceRunnable.run(JavaInstanceRunnable.java:260) ~[org.apache.pulsar-pulsar-functions-instance-2.9.1.jar:2.9.1] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312] 2022-02-15T19:54:15,245+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Unloading JAR files for function InstanceConfig(instanceId=0, functionId=f01479ec-ab28-42eb-9d83-4b1517f72c3d, functionVersion=9879029e-4d46-480f-8a72-3481f5a91771, functionDetails=tenant: "public" namespace: "mysql8pipeline" name: "debezium-kafka-source" className: "org.apache.pulsar.functions.api.utils.IdentityFunction" autoAck: true parallelism: 1 source { className: "org.apache.pulsar.io.kafka.connect.KafkaConnectSource" configs: "{}" typeClassName: "org.apache.pulsar.common.schema.KeyValue" } sink { topic: "all-the-databases" typeClassName: "org.apache.pulsar.common.schema.KeyValue" forwardSourceMessageProperty: true } resources { cpu: 1.0 ram: 1073741824 disk: 10737418240 } componentType: SOURCE , maxBufferedTuples=1024, functionAuthenticationSpec=null, port=0, clusterName=local, maxPendingAsyncRequests=1000, exposePulsarAdminClientEnabled=false, metricsPort=0) 2022-02-15T19:54:15,246+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.common.nar.FileUtils - Jar file connectors/pulsar-io-kafka-connect-adaptor-2.9.1.nar contains META-INF/bundled-dependencies, it may be a NAR file 2022-02-15T19:54:15,247+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Trying Loading file as NAR file: connectors/pulsar-io-kafka-connect-adaptor-2.9.1.nar 2022-02-15T19:54:17,053+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Initialize function class loader for function debezium-kafka-source at function cache manager, functionClassLoader: org.apache.pulsar.common.nar.NarClassLoader[/tmp/pulsar_localrunner_nars_7426220787174598080/pulsar-nar/pulsar-io-kafka-connect-adaptor-2.9.1.nar-unpacked/90ickkj44GhweghdXLZZsw] 2022-02-15T19:54:17,054+0000 [function-timer-thread-6-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - ThreadContainer starting function with instance config InstanceConfig(instanceId=0, functionId=f01479ec-ab28-42eb-9d83-4b1517f72c3d, functionVersion=9879029e-4d46-480f-8a72-3481f5a91771, functionDetails=tenant: "public" namespace: "mysql8pipeline" name: "debezium-kafka-source" className: "org.apache.pulsar.functions.api.utils.IdentityFunction" autoAck: true parallelism: 1 source { className: "org.apache.pulsar.io.kafka.connect.KafkaConnectSource" configs: "{}" typeClassName: "org.apache.pulsar.common.schema.KeyValue" } sink { topic: "all-the-databases" typeClassName: "org.apache.pulsar.common.schema.KeyValue" forwardSourceMessageProperty: true } resources { cpu: 1.0 ram: 1073741824 disk: 10737418240 } componentType: SOURCE , maxBufferedTuples=1024, functionAuthenticationSpec=null, port=0, clusterName=local, maxPendingAsyncRequests=1000, exposePulsarAdminClientEnabled=false, metricsPort=0) 2022-02-15T19:54:17,149+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {"topicName":"all-the-databases","producerName":null,"sendTimeoutMs":0,"blockIfQueueFull":true,"maxPendingMessages":1000,"maxPendingMessagesAcrossPartitions":50000,"messageRoutingMode":"CustomPartition","hashingScheme":"Murmur3_32Hash","cryptoFailureAction":"FAIL","batchingMaxPublishDelayMicros":10000,"batchingPartitionSwitchFrequencyByPublishDelay":10,"batchingMaxMessages":1000,"batchingMaxBytes":131072,"batchingEnabled":true,"chunkingEnabled":false,"compressionType":"LZ4","initialSequenceId":null,"autoUpdatePartitions":true,"autoUpdatePartitionsIntervalSeconds":60,"multiSchema":true,"accessMode":"Shared","lazyStartPartitionedProducers":false,"properties":{"application":"pulsar-source","id":"public/mysql8pipeline/debezium-kafka-source","instance_hostname":"pulsar-ftw-0.pulsar-ftw.pipeline.svc.cluster.local","instance_id":"0"}} 2022-02-15T19:54:17,151+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {"serviceUrl":"pulsar://localhost:6650","authPluginClassName":null,"authParams":null,"authParamMap":null,"operationTimeoutMs":30000,"lookupTimeoutMs":30000,"statsIntervalSeconds":60,"numIoThreads":1,"numListenerThreads":1,"connectionsPerBroker":1,"useTcpNoDelay":true,"useTls":false,"tlsTrustCertsFilePath":null,"tlsAllowInsecureConnection":false,"tlsHostnameVerificationEnable":false,"concurrentLookupRequest":5000,"maxLookupRequest":50000,"maxLookupRedirects":20,"maxNumberOfRejectedRequestPerConnection":50,"keepAliveIntervalSeconds":30,"connectionTimeoutMs":10000,"requestTimeoutMs":60000,"initialBackoffIntervalNanos":100000000,"maxBackoffIntervalNanos":60000000000,"enableBusyWait":false,"listenerName":null,"useKeyStoreTls":false,"sslProvider":null,"tlsTrustStoreType":"JKS","tlsTrustStorePath":null,"tlsTrustStorePassword":null,"tlsCiphers":[],"tlsProtocols":[],"memoryLimitBytes":0,"proxyServiceUrl":null,"proxyProtocol":null,"enableTransaction":false,"socks5ProxyAddress":null,"socks5ProxyUsername":null,"socks5ProxyPassword":null} 2022-02-15T19:54:17,240+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [null] Creating producer on cnx [id: 0x144d34b8, L:/127.0.0.1:53656 - R:localhost/127.0.0.1:6650] 2022-02-15T19:54:17,247+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [standalone-0-23] Created producer on cnx [id: 0x144d34b8, L:/127.0.0.1:53656 - R:localhost/127.0.0.1:6650] 2022-02-15T19:54:17,345+0000 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [all-the-databases] [standalone-0-23] Closed Producer ^C2022-02-15T19:54:28,778+0000 [Thread-1] INFO org.apache.pulsar.functions.runtime.thread.ThreadRuntime - Unloading JAR files for function InstanceConfig(instanceId=0, functionId=f01479ec-ab28-42eb-9d83-4b1517f72c3d, functionVersion=9879029e-4d46-480f-8a72-3481f5a91771, functionDetails=tenant: "public" namespace: "mysql8pipeline" name: "debezium-kafka-source" className: "org.apache.pulsar.functions.api.utils.IdentityFunction" autoAck: true parallelism: 1 source { className: "org.apache.pulsar.io.kafka.connect.KafkaConnectSource" configs: "{}" typeClassName: "org.apache.pulsar.common.schema.KeyValue" } sink { topic: "all-the-databases" typeClassName: "org.apache.pulsar.common.schema.KeyValue" forwardSourceMessageProperty: true } resources { cpu: 1.0 ram: 1073741824 disk: 10737418240 }

prime-minister-of-fun commented 2 years ago

Here's the output from running pulsar standalone. I stopped it towards the end:

`2022-02-15T20:07:57,250+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Running 1 bookie(s) and advertised them at 127.0.0.1. 2022-02-15T20:07:57,343+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Starting ZK server 2022-02-15T20:07:57,443+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - 2022-02-15T20:07:57,443+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - __ _
2022-02-15T20:07:57,444+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - | / | |
2022-02-15T20:07:57,444+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - / / _ | | _
2022-02-15T20:07:57,444+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - / / / \ / \ | |/ / / \ / \ | ' \ / \ | '| 2022-02-15T20:07:57,444+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - / / | () | | () | | < | / | / | |_) | | / | |
2022-02-15T20:07:57,444+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - /____| \/ _/ ||_\ \| _| | ./ __| || 2022-02-15T20:07:57,445+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - | |
2022-02-15T20:07:57,445+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - |_|
2022-02-15T20:07:57,445+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - 2022-02-15T20:07:57,447+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:zookeeper.version=3.6.3--6401e4ad2087061bc6b9f80dec2d69f2e3c8660a, built on 04/08/2021 16:35 GMT 2022-02-15T20:07:57,447+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:host.name=pulsar-ftw-0.pulsar-ftw.pipeline.svc.cluster.local 2022-02-15T20:07:57,447+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.version=1.8.0_312 2022-02-15T20:07:57,448+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.vendor=Private Build 2022-02-15T20:07:57,448+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.home=/usr/lib/jvm/java-8-openjdk-amd64/jre 2022-02-15T20:07:57,448+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.class.path=/data/apache-pulsar/conf:::/data/apache-pulsar/lib/com.google.guava-failureaccess-1.0.1.jar:/data/apache-pulsar/lib/io.vertx-vertx-bridge-common-3.9.8.jar:/data/apache-pulsar/lib/org.jctools-jctools-core-2.1.2.jar:/data/apache-pulsar/lib/io.netty-netty-codec-socks-4.1.72.Final.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-graphite-3.2.5.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-core-4.14.2.jar:/data/apache-pulsar/lib/com.google.code.gson-gson-2.8.6.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-jute-3.6.3.jar:/data/apache-pulsar/lib/jakarta.validation-jakarta.validation-api-2.0.2.jar:/data/apache-pulsar/lib/io.netty-netty-codec-haproxy-4.1.72.Final.jar:/data/apache-pulsar/lib/commons-configuration-commons-configuration-1.10.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-common-4.14.2.jar:/data/apache-pulsar/lib/jakarta.xml.bind-jakarta.xml.bind-api-2.3.3.jar:/data/apache-pulsar/lib/org.reactivestreams-reactive-streams-1.0.3.jar:/data/apache-pulsar/lib/io.gsonfire-gson-fire-1.8.5.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-2.9.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-security-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-transaction-common-2.9.1.jar:/data/apache-pulsar/lib/org.apache.thrift-libthrift-0.14.2.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-utils-2.6.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-protobuf-1.33.0.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-core-2.12.3.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient-0.5.0.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_httpserver-0.5.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-javax-websocket-client-impl-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.xerial.snappy-snappy-java-1.1.7.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.http-vertx-http-server-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-client-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.checkerframework-checker-qual-3.5.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-worker-2.9.1.jar:/data/apache-pulsar/lib/io.netty-netty-handler-proxy-4.1.72.Final.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-prometheus-metrics-3.6.3.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-1.2-api-2.16.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-runtime-2.9.1.jar:/data/apache-pulsar/lib/org.glassfish.hk2-osgi-resource-locator-1.0.3.jar:/data/apache-pulsar/lib/io.grpc-grpc-stub-1.33.0.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_jetty-0.5.0.jar:/data/apache-pulsar/lib/com.github.zafarkhaja-java-semver-0.9.0.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-web-2.16.0.jar:/data/apache-pulsar/lib/org.apache.curator-curator-recipes-5.1.0.jar:/data/apache-pulsar/lib/io.swagger-swagger-core-1.6.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-xds-1.33.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.media-jersey-media-json-jackson-2.34.jar:/data/apache-pulsar/lib/com.squareup.okio-okio-2.8.0.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-locator-2.6.1.jar:/data/apache-pulsar/lib/com.google.re2j-re2j-1.2.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-client-2.34.jar:/data/apache-pulsar/lib/io.grpc-grpc-auth-1.33.0.jar:/data/apache-pulsar/lib/io.grpc-grpc-netty-1.33.0.jar:/data/apache-pulsar/lib/io.vertx-vertx-web-common-3.9.8.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-unix-common-4.1.72.Final.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-servlet-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-statelib-4.14.2.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_log4j2-0.5.0.jar:/data/apache-pulsar/lib/org.apache.httpcomponents-httpclient-4.5.13.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-tools-framework-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-common-4.14.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-databind-2.12.3.jar:/data/apache-pulsar/lib/org.bitbucket.b_c-jose4j-0.7.6.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-common-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-core-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-unix-common-4.1.72.Final-linux-x86_64.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-original-2.9.1.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-jvm-3.2.5.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-server-4.14.2.jar:/data/apache-pulsar/lib/org.jvnet.mimepull-mimepull-1.9.13.jar:/data/apache-pulsar/lib/org.glassfish.jersey.media-jersey-media-multipart-2.34.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-testclient-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-netty-shaded-1.33.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-api-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-3.6.3.jar:/data/apache-pulsar/lib/commons-codec-commons-codec-1.15.jar:/data/apache-pulsar/lib/io.netty-netty-codec-dns-4.1.72.Final.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-jackson-0.11.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-tools-2.9.1.jar:/data/apache-pulsar/lib/org.glassfish.jersey.containers-jersey-container-servlet-2.34.jar:/data/apache-pulsar/lib/org.apache.curator-curator-framework-5.1.0.jar:/data/apache-pulsar/lib/com.yahoo.datasketches-memory-0.8.3.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-secrets-2.9.1.jar:/data/apache-pulsar/lib/com.google.code.findbugs-jsr305-3.0.2.jar:/data/apache-pulsar/lib/io.airlift-aircompressor-0.20.jar:/data/apache-pulsar/lib/com.google.guava-listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-prometheus-metrics-provider-4.14.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcpkix-jdk15on-1.69.jar:/data/apache-pulsar/lib/com.google.auto.value-auto-value-annotations-1.7.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-proto-2.9.1.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-contrib-http-util-0.24.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-server-2.34.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-config-validation-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-testmocks-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-utils-2.9.1.jar:/data/apache-pulsar/lib/jakarta.annotation-jakarta.annotation-api-1.3.5.jar:/data/apache-pulsar/lib/jakarta.activation-jakarta.activation-api-1.2.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.dataformat-jackson-dataformat-yaml-2.12.3.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-common-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-zookeeper-utils-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-package-core-2.9.1.jar:/data/apache-pulsar/lib/javax.servlet-javax.servlet-api-3.1.0.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-jdk8-1.4.32.jar:/data/apache-pulsar/lib/io.vertx-vertx-auth-common-3.9.8.jar:/data/apache-pulsar/lib/com.google.http-client-google-http-client-1.34.0.jar:/data/apache-pulsar/lib/org.jetbrains-annotations-13.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-package-bookkeeper-storage-2.9.1.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-slf4j-impl-2.16.0.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-common-1.4.32.jar:/data/apache-pulsar/lib/io.prometheus.jmx-collector-0.14.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.http-http-server-4.14.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-protobuf-lite-1.33.0.jar:/data/apache-pulsar/lib/org.bouncycastle-bcprov-ext-jdk15on-1.69.jar:/data/apache-pulsar/lib/commons-collections-commons-collections-3.2.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-http-9.4.43.v20210629.jar:/data/apache-pulsar/lib/com.carrotsearch-hppc-0.7.3.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.jaxrs-jackson-jaxrs-json-provider-2.12.3.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-1.4.32.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-bookkeeper-stats-api-4.14.2.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-protocol-4.14.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-grpclb-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-codec-http-4.1.72.Final.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-api-2.6.1.jar:/data/apache-pulsar/lib/org.asynchttpclient-async-http-client-netty-utils-2.12.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-client-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-servlet-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.netty-netty-handler-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-buffer-4.1.72.Final.jar:/data/apache-pulsar/lib/com.beust-jcommander-1.78.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-proxy-2.9.1.jar:/data/apache-pulsar/lib/com.squareup.okhttp3-okhttp-4.9.3.jar:/data/apache-pulsar/lib/org.slf4j-slf4j-api-1.7.25.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-common-2.9.1.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.module-jackson-module-jsonSchema-2.12.3.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-transaction-coordinator-2.9.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-servlets-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_caffeine-0.5.0.jar:/data/apache-pulsar/lib/com.squareup.okhttp3-logging-interceptor-4.9.3.jar:/data/apache-pulsar/lib/org.javassist-javassist-3.25.0-GA.jar:/data/apache-pulsar/lib/org.apache.commons-commons-collections4-4.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-alpn-conscrypt-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-common-4.14.2.jar:/data/apache-pulsar/lib/org.asynchttpclient-async-http-client-2.12.1.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-annotations-2.12.3.jar:/data/apache-pulsar/lib/com.google.errorprone-error_prone_annotations-2.5.1.jar:/data/apache-pulsar/lib/org.glassfish.hk2.external-jakarta.inject-2.6.1.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_servlet-0.5.0.jar:/data/apache-pulsar/lib/javax.websocket-javax.websocket-client-api-1.0.jar:/data/apache-pulsar/lib/io.swagger-swagger-models-1.6.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-metadata-2.9.1.jar:/data/apache-pulsar/lib/com.google.protobuf-protobuf-java-util-3.11.4.jar:/data/apache-pulsar/lib/io.grpc-grpc-api-1.33.0.jar:/data/apache-pulsar/lib/net.jodah-typetools-0.5.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-auth-sasl-2.9.1.jar:/data/apache-pulsar/lib/commons-lang-commons-lang-2.6.jar:/data/apache-pulsar/lib/com.google.http-client-google-http-client-jackson2-1.34.0.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-core-3.2.5.jar:/data/apache-pulsar/lib/io.vertx-vertx-web-3.9.8.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-admin-api-2.9.1.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-proto-12.0.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-proto-4.14.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcutil-jdk15on-1.69.jar:/data/apache-pulsar/lib/org.apache.httpcomponents-httpcore-4.4.13.jar:/data/apache-pulsar/lib/io.grpc-grpc-alts-1.33.0.jar:/data/apache-pulsar/lib/javax.validation-validation-api-1.1.0.Final.jar:/data/apache-pulsar/lib/io.netty-netty-common-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-epoll-4.1.72.Final.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_common-0.5.0.jar:/data/apache-pulsar/lib/org.slf4j-jul-to-slf4j-1.7.25.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-api-2.16.0.jar:/data/apache-pulsar/lib/io.netty-netty-resolver-dns-4.1.72.Final.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-continuation-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.conscrypt-conscrypt-openjdk-uber-2.5.2.jar:/data/apache-pulsar/lib/io.swagger-swagger-annotations-1.6.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-proxy-9.4.43.v20210629.jar:/data/apache-pulsar/lib/commons-io-commons-io-2.8.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-codahale-metrics-provider-4.14.2.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-api-0.11.1.jar:/data/apache-pulsar/lib/org.hdrhistogram-HdrHistogram-2.1.9.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-io-9.4.43.v20210629.jar:/data/apache-pulsar/lib/com.sun.activation-javax.activation-1.2.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-util-ajax-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-messagecrypto-bc-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-circe-checksum-4.14.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-api-2.9.1.jar:/data/apache-pulsar/lib/net.java.dev.jna-jna-4.2.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-common-2.34.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-service-api-4.14.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-io-core-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-websocket-2.9.1.jar:/data/apache-pulsar/lib/commons-logging-commons-logging-1.1.1.jar:/data/apache-pulsar/lib/com.google.auth-google-auth-library-credentials-0.20.0.jar:/data/apache-pulsar/lib/org.apache.curator-curator-client-5.1.0.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.jaxrs-jackson-jaxrs-base-2.12.3.jar:/data/apache-pulsar/lib/io.vertx-vertx-core-3.9.8.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-common-allocator-4.14.2.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-cpu-affinity-4.14.2.jar:/data/apache-pulsar/lib/commons-cli-commons-cli-1.2.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-server-4.14.2.jar:/data/apache-pulsar/lib/io.netty-netty-resolver-4.1.72.Final.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-instance-2.9.1.jar:/data/apache-pulsar/lib/com.google.j2objc-j2objc-annotations-1.3.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-util-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.glassfish.hk2.external-aopalliance-repackaged-2.6.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-api-4.14.2.jar:/data/apache-pulsar/lib/com.google.guava-guava-30.1-jre.jar:/data/apache-pulsar/lib/org.glassfish.jersey.inject-jersey-hk2-2.34.jar:/data/apache-pulsar/lib/org.yaml-snakeyaml-1.27.jar:/data/apache-pulsar/lib/io.grpc-grpc-context-1.33.0.jar:/data/apache-pulsar/lib/org.rocksdb-rocksdbjni-6.10.2.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-jdk7-1.4.32.jar:/data/apache-pulsar/lib/com.google.auth-google-auth-library-oauth2-http-0.20.0.jar:/data/apache-pulsar/lib/org.apache.commons-commons-compress-1.21.jar:/data/apache-pulsar/lib/jakarta.ws.rs-jakarta.ws.rs-api-2.1.6.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-core-4.14.2-tests.jar:/data/apache-pulsar/lib/io.netty-netty-codec-http2-4.1.72.Final.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-api-0.18.0.jar:/data/apache-pulsar/lib/com.google.protobuf-protobuf-java-3.11.4.jar:/data/apache-pulsar/lib/org.glassfish.jersey.containers-jersey-container-servlet-core-2.34.jar:/data/apache-pulsar/lib/io.grpc-grpc-services-1.33.0.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-12.0.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-bouncy-castle-bc-2.9.1-pkg.jar:/data/apache-pulsar/lib/org.apache.yetus-audience-annotations-0.5.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.ext-jersey-entity-filtering-2.34.jar:/data/apache-pulsar/lib/org.apache.commons-commons-lang3-3.11.jar:/data/apache-pulsar/lib/org.apache.pulsar-managed-ledger-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-all-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-transport-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-epoll-4.1.72.Final-linux-x86_64.jar:/data/apache-pulsar/lib/javax.xml.bind-jaxb-api-2.3.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-auth-sasl-2.9.1.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-api-12.0.1.jar:/data/apache-pulsar/lib/net.jcip-jcip-annotations-1.0.jar:/data/apache-pulsar/lib/io.netty-netty-tcnative-classes-2.0.46.Final.jar:/data/apache-pulsar/lib/org.apache.avro-avro-1.10.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-api-2.9.1.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-core-2.16.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-local-runner-original-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-service-impl-4.14.2.jar:/data/apache-pulsar/lib/com.google.api.grpc-proto-google-common-protos-1.17.0.jar:/data/apache-pulsar/lib/io.perfmark-perfmark-api-0.19.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-proto-4.14.2.jar:/data/apache-pulsar/lib/javax.ws.rs-javax.ws.rs-api-2.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-admin-original-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-java-client-base-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-alpn-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-proto-0.2.0.jar:/data/apache-pulsar/lib/com.typesafe.netty-netty-reactive-streams-2.0.4.jar:/data/apache-pulsar/lib/io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:/data/apache-pulsar/lib/com.yahoo.datasketches-sketches-core-0.8.3.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_hotspot-0.5.0.jar:/data/apache-pulsar/lib/io.netty-netty-tcnative-boringssl-static-2.0.46.Final.jar:/data/apache-pulsar/lib/org.slf4j-jcl-over-slf4j-1.7.25.jar:/data/apache-pulsar/lib/javax.annotation-javax.annotation-api-1.3.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcprov-jdk15on-1.69.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-java-client-4.14.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.module-jackson-module-jaxb-annotations-2.12.3.jar:/data/apache-pulsar/lib/jline-jline-2.14.6.jar:/data/apache-pulsar/lib/org.apache.avro-avro-protobuf-1.10.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-io-common-2.9.1.jar:/data/apache-pulsar/lib/com.github.ben-manes.caffeine-caffeine-2.9.1.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-impl-0.11.1.jar:/data/apache-pulsar/lib/io.netty-netty-codec-4.1.72.Final.jar:/data/apache-pulsar/lib 2022-02-15T20:07:57,539+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib 2022-02-15T20:07:57,539+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.io.tmpdir=/tmp 2022-02-15T20:07:57,540+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:java.compiler= 2022-02-15T20:07:57,541+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.name=Linux 2022-02-15T20:07:57,542+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.arch=amd64 2022-02-15T20:07:57,542+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.version=5.4.172-90.336.amzn2.x86_64 2022-02-15T20:07:57,543+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:user.name=root 2022-02-15T20:07:57,543+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:user.home=/root 2022-02-15T20:07:57,543+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:user.dir=/data/apache-pulsar 2022-02-15T20:07:57,543+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.memory.free=1874MB 2022-02-15T20:07:57,544+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.memory.max=2048MB 2022-02-15T20:07:57,544+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Server environment:os.memory.total=2048MB 2022-02-15T20:07:57,545+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.enableEagerACLCheck = false 2022-02-15T20:07:57,545+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.digest.enabled = true 2022-02-15T20:07:57,545+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.closeSessionTxn.enabled = true 2022-02-15T20:07:57,546+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.flushDelay=0 2022-02-15T20:07:57,546+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.maxWriteQueuePollTime=0 2022-02-15T20:07:57,546+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.maxBatchSize=1000 2022-02-15T20:07:57,547+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - zookeeper.intBufferStartingSizeBytes = 1024 2022-02-15T20:07:57,550+0000 [main] INFO org.apache.zookeeper.server.persistence.FileTxnSnapLog - zookeeper.snapshot.trust.empty : true 2022-02-15T20:07:57,740+0000 [main] INFO org.apache.zookeeper.server.watch.WatchManagerFactory - Using org.apache.zookeeper.server.watch.WatchManager as watch manager 2022-02-15T20:07:57,740+0000 [main] INFO org.apache.zookeeper.server.watch.WatchManagerFactory - Using org.apache.zookeeper.server.watch.WatchManager as watch manager 2022-02-15T20:07:57,742+0000 [main] INFO org.apache.zookeeper.server.ZKDatabase - zookeeper.snapshotSizeFactor = 0.33 2022-02-15T20:07:57,742+0000 [main] INFO org.apache.zookeeper.server.ZKDatabase - zookeeper.commitLogCount=500 2022-02-15T20:07:57,746+0000 [main] INFO org.apache.zookeeper.server.BlueThrottle - Weighed connection throttling is disabled 2022-02-15T20:07:57,748+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - minSessionTimeout set to 6000 2022-02-15T20:07:57,748+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - maxSessionTimeout set to 60000 2022-02-15T20:07:57,750+0000 [main] INFO org.apache.zookeeper.server.ResponseCache - Response cache size is initialized with value 400. 2022-02-15T20:07:57,750+0000 [main] INFO org.apache.zookeeper.server.ResponseCache - Response cache size is initialized with value 400. 2022-02-15T20:07:57,751+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.slotCapacity = 60 2022-02-15T20:07:57,751+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.slotDuration = 15 2022-02-15T20:07:57,751+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.maxDepth = 6 2022-02-15T20:07:57,751+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.initialDelay = 5 2022-02-15T20:07:57,752+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.delay = 5 2022-02-15T20:07:57,752+0000 [main] INFO org.apache.zookeeper.server.util.RequestPathMetricsCollector - zookeeper.pathStats.enabled = false 2022-02-15T20:07:57,841+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - The max bytes for all large requests are set to 104857600 2022-02-15T20:07:57,841+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - The large request threshold is set to -1 2022-02-15T20:07:57,842+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Created server with tickTime 3000 minSessionTimeout 6000 maxSessionTimeout 60000 clientPortListenBacklog -1 datadir data/standalone/zookeeper/version-2 snapdir data/standalone/zookeeper/version-2 2022-02-15T20:07:57,851+0000 [main] WARN org.apache.zookeeper.server.ServerCnxnFactory - maxCnxns is not configured, using default value 0. 2022-02-15T20:07:57,852+0000 [main] INFO org.apache.zookeeper.server.NIOServerCnxnFactory - Configuring NIO connection handler with 10s sessionless connection timeout, 1 selector thread(s), 2 worker threads, and 64 kB direct buffers. 2022-02-15T20:07:57,940+0000 [main] INFO org.apache.zookeeper.server.NIOServerCnxnFactory - binding to port 0.0.0.0/0.0.0.0:2181 2022-02-15T20:07:57,948+0000 [main] INFO org.apache.zookeeper.server.persistence.SnapStream - zookeeper.snapshot.compression.method = CHECKED 2022-02-15T20:07:57,949+0000 [main] INFO org.apache.zookeeper.server.persistence.FileSnap - Reading snapshot data/standalone/zookeeper/version-2/snapshot.187 2022-02-15T20:07:58,052+0000 [main] INFO org.apache.zookeeper.server.DataTree - The digest in the snapshot has digest version of 2, , with zxid as 0x187, and digest value as 755870435808 2022-02-15T20:07:58,449+0000 [main] INFO org.apache.zookeeper.server.persistence.FileTxnSnapLog - 2 txns loaded in 3 ms 2022-02-15T20:07:58,450+0000 [main] INFO org.apache.zookeeper.server.ZKDatabase - Snapshot loaded in 506 ms, highest zxid is 0x189, digest is 755870435808 2022-02-15T20:07:58,450+0000 [main] INFO org.apache.zookeeper.server.persistence.FileTxnSnapLog - Snapshotting: 0x189 to data/standalone/zookeeper/version-2/snapshot.189 2022-02-15T20:07:58,546+0000 [main] INFO org.apache.zookeeper.server.ZooKeeperServer - Snapshot taken in 96 ms 2022-02-15T20:07:58,673+0000 [ProcessThread(sid:0 cport:2181):] INFO org.apache.zookeeper.server.PrepRequestProcessor - PrepRequestProcessor (sid:0) started, reconfigEnabled=false 2022-02-15T20:07:58,739+0000 [main] INFO org.apache.zookeeper.server.RequestThrottler - zookeeper.request_throttler.shutdownTimeout = 10000 2022-02-15T20:07:58,847+0000 [main] INFO org.apache.zookeeper.server.DatadirCleanupManager - autopurge.snapRetainCount set to 3 2022-02-15T20:07:58,939+0000 [main] INFO org.apache.zookeeper.server.DatadirCleanupManager - autopurge.purgeInterval set to 1 2022-02-15T20:07:59,040+0000 [PurgeTask] INFO org.apache.zookeeper.server.DatadirCleanupManager - Purge task started. 2022-02-15T20:07:59,048+0000 [PurgeTask] INFO org.apache.zookeeper.server.persistence.FileTxnSnapLog - zookeeper.snapshot.trust.empty : true 2022-02-15T20:07:59,050+0000 [PurgeTask] INFO org.apache.zookeeper.server.DatadirCleanupManager - Purge task completed. 2022-02-15T20:07:59,139+0000 [NIOWorkerThread-1] INFO org.apache.zookeeper.server.command.FourLetterCommands - The list of known four letter word commands is : [{1936881266=srvr, 1937006964=stat, 2003003491=wchc, 1685417328=dump, 1668445044=crst, 1936880500=srst, 1701738089=envi, 1668247142=conf, -720899=telnet close, 1751217000=hash, 2003003507=wchs, 2003003504=wchp, 1684632179=dirs, 1668247155=cons, 1835955314=mntr, 1769173615=isro, 1920298859=ruok, 1735683435=gtmk, 1937010027=stmk}] 2022-02-15T20:07:59,141+0000 [NIOWorkerThread-1] INFO org.apache.zookeeper.server.command.FourLetterCommands - The list of enabled four letter word commands is : [[wchs, stat, wchp, dirs, stmk, conf, ruok, mntr, srvr, wchc, envi, srst, isro, dump, gtmk, telnet close, crst, hash, cons]] 2022-02-15T20:07:59,141+0000 [NIOWorkerThread-1] INFO org.apache.zookeeper.server.NIOServerCnxn - Processing stat command from /127.0.0.1:41090 2022-02-15T20:07:59,148+0000 [NIOWorkerThread-1] INFO org.apache.zookeeper.server.command.AbstractFourLetterCommand - Stat command output 2022-02-15T20:07:59,149+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Server UP 2022-02-15T20:07:59,149+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - ZooKeeper server up: true 2022-02-15T20:07:59,149+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Instantiate ZK Client 2022-02-15T20:07:59,241+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.6.3--6401e4ad2087061bc6b9f80dec2d69f2e3c8660a, built on 04/08/2021 16:35 GMT 2022-02-15T20:07:59,241+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:host.name=pulsar-ftw-0.pulsar-ftw.pipeline.svc.cluster.local 2022-02-15T20:07:59,242+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.version=1.8.0_312 2022-02-15T20:07:59,242+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Private Build 2022-02-15T20:07:59,242+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.home=/usr/lib/jvm/java-8-openjdk-amd64/jre 2022-02-15T20:07:59,242+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=/data/apache-pulsar/conf:::/data/apache-pulsar/lib/com.google.guava-failureaccess-1.0.1.jar:/data/apache-pulsar/lib/io.vertx-vertx-bridge-common-3.9.8.jar:/data/apache-pulsar/lib/org.jctools-jctools-core-2.1.2.jar:/data/apache-pulsar/lib/io.netty-netty-codec-socks-4.1.72.Final.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-graphite-3.2.5.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-core-4.14.2.jar:/data/apache-pulsar/lib/com.google.code.gson-gson-2.8.6.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-jute-3.6.3.jar:/data/apache-pulsar/lib/jakarta.validation-jakarta.validation-api-2.0.2.jar:/data/apache-pulsar/lib/io.netty-netty-codec-haproxy-4.1.72.Final.jar:/data/apache-pulsar/lib/commons-configuration-commons-configuration-1.10.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-common-4.14.2.jar:/data/apache-pulsar/lib/jakarta.xml.bind-jakarta.xml.bind-api-2.3.3.jar:/data/apache-pulsar/lib/org.reactivestreams-reactive-streams-1.0.3.jar:/data/apache-pulsar/lib/io.gsonfire-gson-fire-1.8.5.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-2.9.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-security-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-transaction-common-2.9.1.jar:/data/apache-pulsar/lib/org.apache.thrift-libthrift-0.14.2.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-utils-2.6.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-protobuf-1.33.0.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-core-2.12.3.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient-0.5.0.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_httpserver-0.5.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-javax-websocket-client-impl-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.xerial.snappy-snappy-java-1.1.7.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.http-vertx-http-server-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-client-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.checkerframework-checker-qual-3.5.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-worker-2.9.1.jar:/data/apache-pulsar/lib/io.netty-netty-handler-proxy-4.1.72.Final.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-prometheus-metrics-3.6.3.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-1.2-api-2.16.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-runtime-2.9.1.jar:/data/apache-pulsar/lib/org.glassfish.hk2-osgi-resource-locator-1.0.3.jar:/data/apache-pulsar/lib/io.grpc-grpc-stub-1.33.0.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_jetty-0.5.0.jar:/data/apache-pulsar/lib/com.github.zafarkhaja-java-semver-0.9.0.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-web-2.16.0.jar:/data/apache-pulsar/lib/org.apache.curator-curator-recipes-5.1.0.jar:/data/apache-pulsar/lib/io.swagger-swagger-core-1.6.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-xds-1.33.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.media-jersey-media-json-jackson-2.34.jar:/data/apache-pulsar/lib/com.squareup.okio-okio-2.8.0.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-locator-2.6.1.jar:/data/apache-pulsar/lib/com.google.re2j-re2j-1.2.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-client-2.34.jar:/data/apache-pulsar/lib/io.grpc-grpc-auth-1.33.0.jar:/data/apache-pulsar/lib/io.grpc-grpc-netty-1.33.0.jar:/data/apache-pulsar/lib/io.vertx-vertx-web-common-3.9.8.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-unix-common-4.1.72.Final.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-servlet-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-statelib-4.14.2.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_log4j2-0.5.0.jar:/data/apache-pulsar/lib/org.apache.httpcomponents-httpclient-4.5.13.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-tools-framework-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-common-4.14.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-databind-2.12.3.jar:/data/apache-pulsar/lib/org.bitbucket.b_c-jose4j-0.7.6.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-common-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-core-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-unix-common-4.1.72.Final-linux-x86_64.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-original-2.9.1.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-jvm-3.2.5.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-server-4.14.2.jar:/data/apache-pulsar/lib/org.jvnet.mimepull-mimepull-1.9.13.jar:/data/apache-pulsar/lib/org.glassfish.jersey.media-jersey-media-multipart-2.34.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-testclient-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-netty-shaded-1.33.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-api-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.zookeeper-zookeeper-3.6.3.jar:/data/apache-pulsar/lib/commons-codec-commons-codec-1.15.jar:/data/apache-pulsar/lib/io.netty-netty-codec-dns-4.1.72.Final.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-jackson-0.11.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-tools-2.9.1.jar:/data/apache-pulsar/lib/org.glassfish.jersey.containers-jersey-container-servlet-2.34.jar:/data/apache-pulsar/lib/org.apache.curator-curator-framework-5.1.0.jar:/data/apache-pulsar/lib/com.yahoo.datasketches-memory-0.8.3.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-secrets-2.9.1.jar:/data/apache-pulsar/lib/com.google.code.findbugs-jsr305-3.0.2.jar:/data/apache-pulsar/lib/io.airlift-aircompressor-0.20.jar:/data/apache-pulsar/lib/com.google.guava-listenablefuture-9999.0-empty-to-avoid-conflict-with-guava.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-prometheus-metrics-provider-4.14.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcpkix-jdk15on-1.69.jar:/data/apache-pulsar/lib/com.google.auto.value-auto-value-annotations-1.7.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-proto-2.9.1.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-contrib-http-util-0.24.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-server-2.34.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-config-validation-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-testmocks-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-utils-2.9.1.jar:/data/apache-pulsar/lib/jakarta.annotation-jakarta.annotation-api-1.3.5.jar:/data/apache-pulsar/lib/jakarta.activation-jakarta.activation-api-1.2.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.dataformat-jackson-dataformat-yaml-2.12.3.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-common-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-zookeeper-utils-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-package-core-2.9.1.jar:/data/apache-pulsar/lib/javax.servlet-javax.servlet-api-3.1.0.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-jdk8-1.4.32.jar:/data/apache-pulsar/lib/io.vertx-vertx-auth-common-3.9.8.jar:/data/apache-pulsar/lib/com.google.http-client-google-http-client-1.34.0.jar:/data/apache-pulsar/lib/org.jetbrains-annotations-13.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-package-bookkeeper-storage-2.9.1.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-slf4j-impl-2.16.0.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-common-1.4.32.jar:/data/apache-pulsar/lib/io.prometheus.jmx-collector-0.14.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.http-http-server-4.14.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-protobuf-lite-1.33.0.jar:/data/apache-pulsar/lib/org.bouncycastle-bcprov-ext-jdk15on-1.69.jar:/data/apache-pulsar/lib/commons-collections-commons-collections-3.2.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-http-9.4.43.v20210629.jar:/data/apache-pulsar/lib/com.carrotsearch-hppc-0.7.3.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.jaxrs-jackson-jaxrs-json-provider-2.12.3.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-1.4.32.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-bookkeeper-stats-api-4.14.2.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-protocol-4.14.2.jar:/data/apache-pulsar/lib/io.grpc-grpc-grpclb-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-codec-http-4.1.72.Final.jar:/data/apache-pulsar/lib/org.glassfish.hk2-hk2-api-2.6.1.jar:/data/apache-pulsar/lib/org.asynchttpclient-async-http-client-netty-utils-2.12.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-client-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.eclipse.jetty.websocket-websocket-servlet-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.netty-netty-handler-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-buffer-4.1.72.Final.jar:/data/apache-pulsar/lib/com.beust-jcommander-1.78.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-proxy-2.9.1.jar:/data/apache-pulsar/lib/com.squareup.okhttp3-okhttp-4.9.3.jar:/data/apache-pulsar/lib/org.slf4j-slf4j-api-1.7.25.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-common-2.9.1.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.module-jackson-module-jsonSchema-2.12.3.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-transaction-coordinator-2.9.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-servlets-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_caffeine-0.5.0.jar:/data/apache-pulsar/lib/com.squareup.okhttp3-logging-interceptor-4.9.3.jar:/data/apache-pulsar/lib/org.javassist-javassist-3.25.0-GA.jar:/data/apache-pulsar/lib/org.apache.commons-commons-collections4-4.1.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-alpn-conscrypt-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-common-4.14.2.jar:/data/apache-pulsar/lib/org.asynchttpclient-async-http-client-2.12.1.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.core-jackson-annotations-2.12.3.jar:/data/apache-pulsar/lib/com.google.errorprone-error_prone_annotations-2.5.1.jar:/data/apache-pulsar/lib/org.glassfish.hk2.external-jakarta.inject-2.6.1.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_servlet-0.5.0.jar:/data/apache-pulsar/lib/javax.websocket-javax.websocket-client-api-1.0.jar:/data/apache-pulsar/lib/io.swagger-swagger-models-1.6.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-metadata-2.9.1.jar:/data/apache-pulsar/lib/com.google.protobuf-protobuf-java-util-3.11.4.jar:/data/apache-pulsar/lib/io.grpc-grpc-api-1.33.0.jar:/data/apache-pulsar/lib/net.jodah-typetools-0.5.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-broker-auth-sasl-2.9.1.jar:/data/apache-pulsar/lib/commons-lang-commons-lang-2.6.jar:/data/apache-pulsar/lib/com.google.http-client-google-http-client-jackson2-1.34.0.jar:/data/apache-pulsar/lib/io.dropwizard.metrics-metrics-core-3.2.5.jar:/data/apache-pulsar/lib/io.vertx-vertx-web-3.9.8.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-admin-api-2.9.1.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-proto-12.0.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-proto-4.14.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcutil-jdk15on-1.69.jar:/data/apache-pulsar/lib/org.apache.httpcomponents-httpcore-4.4.13.jar:/data/apache-pulsar/lib/io.grpc-grpc-alts-1.33.0.jar:/data/apache-pulsar/lib/javax.validation-validation-api-1.1.0.Final.jar:/data/apache-pulsar/lib/io.netty-netty-common-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-epoll-4.1.72.Final.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_common-0.5.0.jar:/data/apache-pulsar/lib/org.slf4j-jul-to-slf4j-1.7.25.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-api-2.16.0.jar:/data/apache-pulsar/lib/io.netty-netty-resolver-dns-4.1.72.Final.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-continuation-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.conscrypt-conscrypt-openjdk-uber-2.5.2.jar:/data/apache-pulsar/lib/io.swagger-swagger-annotations-1.6.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-proxy-9.4.43.v20210629.jar:/data/apache-pulsar/lib/commons-io-commons-io-2.8.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper.stats-codahale-metrics-provider-4.14.2.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-api-0.11.1.jar:/data/apache-pulsar/lib/org.hdrhistogram-HdrHistogram-2.1.9.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-io-9.4.43.v20210629.jar:/data/apache-pulsar/lib/com.sun.activation-javax.activation-1.2.0.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-util-ajax-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-messagecrypto-bc-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-circe-checksum-4.14.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-api-2.9.1.jar:/data/apache-pulsar/lib/net.java.dev.jna-jna-4.2.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.core-jersey-common-2.34.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-service-api-4.14.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-io-core-2.9.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-websocket-2.9.1.jar:/data/apache-pulsar/lib/commons-logging-commons-logging-1.1.1.jar:/data/apache-pulsar/lib/com.google.auth-google-auth-library-credentials-0.20.0.jar:/data/apache-pulsar/lib/org.apache.curator-curator-client-5.1.0.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.jaxrs-jackson-jaxrs-base-2.12.3.jar:/data/apache-pulsar/lib/io.vertx-vertx-core-3.9.8.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-bookkeeper-common-allocator-4.14.2.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-cpu-affinity-4.14.2.jar:/data/apache-pulsar/lib/commons-cli-commons-cli-1.2.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-server-4.14.2.jar:/data/apache-pulsar/lib/io.netty-netty-resolver-4.1.72.Final.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-instance-2.9.1.jar:/data/apache-pulsar/lib/com.google.j2objc-j2objc-annotations-1.3.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-util-9.4.43.v20210629.jar:/data/apache-pulsar/lib/org.glassfish.hk2.external-aopalliance-repackaged-2.6.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-api-4.14.2.jar:/data/apache-pulsar/lib/com.google.guava-guava-30.1-jre.jar:/data/apache-pulsar/lib/org.glassfish.jersey.inject-jersey-hk2-2.34.jar:/data/apache-pulsar/lib/org.yaml-snakeyaml-1.27.jar:/data/apache-pulsar/lib/io.grpc-grpc-context-1.33.0.jar:/data/apache-pulsar/lib/org.rocksdb-rocksdbjni-6.10.2.jar:/data/apache-pulsar/lib/org.jetbrains.kotlin-kotlin-stdlib-jdk7-1.4.32.jar:/data/apache-pulsar/lib/com.google.auth-google-auth-library-oauth2-http-0.20.0.jar:/data/apache-pulsar/lib/org.apache.commons-commons-compress-1.21.jar:/data/apache-pulsar/lib/jakarta.ws.rs-jakarta.ws.rs-api-2.1.6.jar:/data/apache-pulsar/lib/org.apache.distributedlog-distributedlog-core-4.14.2-tests.jar:/data/apache-pulsar/lib/io.netty-netty-codec-http2-4.1.72.Final.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-api-0.18.0.jar:/data/apache-pulsar/lib/com.google.protobuf-protobuf-java-3.11.4.jar:/data/apache-pulsar/lib/org.glassfish.jersey.containers-jersey-container-servlet-core-2.34.jar:/data/apache-pulsar/lib/io.grpc-grpc-services-1.33.0.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-12.0.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-bouncy-castle-bc-2.9.1-pkg.jar:/data/apache-pulsar/lib/org.apache.yetus-audience-annotations-0.5.0.jar:/data/apache-pulsar/lib/org.glassfish.jersey.ext-jersey-entity-filtering-2.34.jar:/data/apache-pulsar/lib/org.apache.commons-commons-lang3-3.11.jar:/data/apache-pulsar/lib/org.apache.pulsar-managed-ledger-2.9.1.jar:/data/apache-pulsar/lib/io.grpc-grpc-all-1.33.0.jar:/data/apache-pulsar/lib/io.netty-netty-transport-4.1.72.Final.jar:/data/apache-pulsar/lib/io.netty-netty-transport-native-epoll-4.1.72.Final-linux-x86_64.jar:/data/apache-pulsar/lib/javax.xml.bind-jaxb-api-2.3.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-auth-sasl-2.9.1.jar:/data/apache-pulsar/lib/io.kubernetes-client-java-api-12.0.1.jar:/data/apache-pulsar/lib/net.jcip-jcip-annotations-1.0.jar:/data/apache-pulsar/lib/io.netty-netty-tcnative-classes-2.0.46.Final.jar:/data/apache-pulsar/lib/org.apache.avro-avro-1.10.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-api-2.9.1.jar:/data/apache-pulsar/lib/org.apache.logging.log4j-log4j-core-2.16.0.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-functions-local-runner-original-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-service-impl-4.14.2.jar:/data/apache-pulsar/lib/com.google.api.grpc-proto-google-common-protos-1.17.0.jar:/data/apache-pulsar/lib/io.perfmark-perfmark-api-0.19.0.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-proto-4.14.2.jar:/data/apache-pulsar/lib/javax.ws.rs-javax.ws.rs-api-2.1.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-client-admin-original-2.9.1.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-java-client-base-4.14.2.jar:/data/apache-pulsar/lib/org.eclipse.jetty-jetty-alpn-server-9.4.43.v20210629.jar:/data/apache-pulsar/lib/io.opencensus-opencensus-proto-0.2.0.jar:/data/apache-pulsar/lib/com.typesafe.netty-netty-reactive-streams-2.0.4.jar:/data/apache-pulsar/lib/io.netty-netty-transport-classes-epoll-4.1.72.Final.jar:/data/apache-pulsar/lib/com.yahoo.datasketches-sketches-core-0.8.3.jar:/data/apache-pulsar/lib/io.prometheus-simpleclient_hotspot-0.5.0.jar:/data/apache-pulsar/lib/io.netty-netty-tcnative-boringssl-static-2.0.46.Final.jar:/data/apache-pulsar/lib/org.slf4j-jcl-over-slf4j-1.7.25.jar:/data/apache-pulsar/lib/javax.annotation-javax.annotation-api-1.3.2.jar:/data/apache-pulsar/lib/org.bouncycastle-bcprov-jdk15on-1.69.jar:/data/apache-pulsar/lib/org.apache.bookkeeper-stream-storage-java-client-4.14.2.jar:/data/apache-pulsar/lib/com.fasterxml.jackson.module-jackson-module-jaxb-annotations-2.12.3.jar:/data/apache-pulsar/lib/jline-jline-2.14.6.jar:/data/apache-pulsar/lib/org.apache.avro-avro-protobuf-1.10.2.jar:/data/apache-pulsar/lib/org.apache.pulsar-pulsar-io-common-2.9.1.jar:/data/apache-pulsar/lib/com.github.ben-manes.caffeine-caffeine-2.9.1.jar:/data/apache-pulsar/lib/io.jsonwebtoken-jjwt-impl-0.11.1.jar:/data/apache-pulsar/lib/io.netty-netty-codec-4.1.72.Final.jar:/data/apache-pulsar/lib 2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib/x86_64-linux-gnu/jni:/lib/x86_64-linux-gnu:/usr/lib/x86_64-linux-gnu:/usr/lib/jni:/lib:/usr/lib 2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=/tmp 2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.compiler= 2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.name=Linux 2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64 2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.version=5.4.172-90.336.amzn2.x86_64 2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.name=root 2022-02-15T20:07:59,245+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.home=/root 2022-02-15T20:07:59,246+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/data/apache-pulsar 2022-02-15T20:07:59,246+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.free=1858MB 2022-02-15T20:07:59,246+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.max=2048MB 2022-02-15T20:07:59,246+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.total=2048MB 2022-02-15T20:07:59,248+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=5000 watcher=org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble$ZKConnectionWatcher@63787180 2022-02-15T20:07:59,252+0000 [main] INFO org.apache.zookeeper.common.X509Util - Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation 2022-02-15T20:07:59,255+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes 2022-02-15T20:07:59,345+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false 2022-02-15T20:07:59,444+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. 2022-02-15T20:07:59,444+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error) 2022-02-15T20:07:59,445+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41092, server: localhost/127.0.0.1:2181 2022-02-15T20:07:59,552+0000 [SyncThread:0] INFO org.apache.zookeeper.server.persistence.FileTxnLog - Creating new log file: log.18a 2022-02-15T20:07:59,641+0000 [SyncThread:0] INFO org.apache.zookeeper.audit.ZKAuditProvider - ZooKeeper audit is disabled. 2022-02-15T20:07:59,739+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60000, negotiated timeout = 6000 2022-02-15T20:07:59,844+0000 [main] INFO org.apache.pulsar.zookeeper.LocalBookkeeperEnsemble - Starting Bookie(s) 2022-02-15T20:08:06,846+0000 [main] INFO org.apache.bookkeeper.proto.BookieServer - { "loadBalancerNamespaceBundleMaxBandwidthMbytes" : "100", "numExecutorThreadPoolSize" : "", "exposeTopicLevelMetricsInPrometheus" : "true", "tlsCertificateFilePath" : "", "managedLedgerCursorBackloggedThreshold" : "1000", "exposePreciseBacklogInPrometheus" : "false", "brokerPublisherThrottlingMaxByteRate" : "0", "bookkeeperClientHealthCheckErrorThresholdPerInterval" : "5", "brokerDeduplicationEntriesInterval" : "1000", "authenticateOriginalAuthData" : "false", "anonymousUserRole" : "", "bookkeeperClientNumWorkerThreads" : "", "dbStorage_rocksDB_numLevels" : "-1", "packagesManagementStorageProvider" : "org.apache.pulsar.packages.management.storage.bookkeeper.BookKeeperPackagesStorageProvider", "managedLedgerDigestType" : "CRC32C", "loadBalancerAutoBundleSplitEnabled" : "true", "tokenSecretKey" : "", "bookkeeperClientAuthenticationParametersName" : "", "managedLedgerDefaultAckQuorum" : "1", "loadBalancerBrokerThresholdShedderPercentage" : "10", "forceDeleteNamespaceAllowed" : "false", "tlsRequireTrustedClientCertOnConnect" : "false", "webSocketConnectionsPerBroker" : "8", "zkServers" : "127.0.0.1:2181", "dbStorage_rocksDB_maxSizeInLevel1MB" : "256", "brokerServicePort" : "6650", "loadBalancerReportUpdateMaxIntervalMinutes" : "15", "managedLedgerNumSchedulerThreads" : "4", "clientLibraryVersionCheckEnabled" : "false", "tokenAuthClaim" : "", "bookkeeperClientReorderReadSequenceEnabled" : "false", "dbStorage_rocksDB_blockCacheSize" : "", "brokerShutdownTimeoutMs" : "60000", "maxConsumersPerSubscription" : "0", "bookkeeperClientEnforceMinNumRacksPerWriteQuorum" : "false", "tokenAudience" : "", "maxNumPartitionsPerPartitionedTopic" : "0", "brokerClientTlsTrustStore" : "", "tlsEnabled" : "false", "managedLedgerMinLedgerRolloverTimeMinutes" : "10", "tlsProvider" : "", "bookkeeperTLSTrustCertsFilePath" : "", "transactionCoordinatorEnabled" : "false", "clusterName" : "standalone", "superUserRoles" : "", "authenticationProviders" : "", "tlsCiphers" : "", "brokerClientTlsCiphers" : "", "dispatchThrottlingRateRelativeToPublishRate" : "false", "haProxyProtocolEnabled" : "false", "bookkeeperUseV2WireProtocol" : "true", "bookiePort" : "3181", "managedLedgerCacheSizeMB" : "", "maxSameAddressProducersPerTopic" : "0", "advertisedAddress" : "127.0.0.1", "bookkeeperClientRegionawarePolicyEnabled" : "false", "brokerDeduplicationEnabled" : "false", "topicPublisherThrottlingTickTimeMillis" : "2", "dispatchThrottlingOnNonBacklogConsumerEnabled" : "true", "bookkeeperTLSTrustCertTypes" : "PEM", "webSocketServiceEnabled" : "true", "bookkeeperTLSCertificateFilePath" : "", "numHttpServerThreads" : "", "managedLedgerCacheEvictionWatermark" : "0.9", "loadBalancerNamespaceBundleMaxMsgRate" : "30000", "bookkeeperClientHealthCheckIntervalSeconds" : "60", "webSocketSessionIdleTimeoutMillis" : "300000", "allowAutoTopicCreationType" : "non-partitioned", "managedLedgerMaxSizePerLedgerMbytes" : "2048", "exposePublisherStats" : "true", "tlsKeyStoreType" : "JKS", "maxUnackedMessagesPerConsumer" : "50000", "replicationConnectionsPerBroker" : "16", "bookkeeperTLSTrustStorePasswordPath" : "", "maxSameAddressConsumersPerTopic" : "0", "managedLedgerMetadataOperationsTimeoutSeconds" : "60", "webServicePort" : "8080", "ledgerStorageClass" : "org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage", "gcWaitTime" : "300000", "maxConcurrentHttpRequests" : "1024", "enableNonPersistentTopics" : "true", "managedLedgerPrometheusStatsLatencyRolloverSeconds" : "60", "loadBalancerNamespaceBundleMaxTopics" : "1000", "brokerClientTlsTrustStorePassword" : "", "managedLedgerCursorMaxEntriesPerLedger" : "50000", "brokerClientAuthenticationPlugin" : "", "loadBalancerMemoryResourceWeight" : "1.0", "bookkeeperClientMinAvailableBookiesInIsolationGroups" : "", "athenzDomainNames" : "", "dbStorage_rocksDB_writeBufferSizeMB" : "4", "proxyRoles" : "", "managedLedgerNumWorkerThreads" : "4", "loadBalancerReportUpdateThresholdPercentage" : "10", "dbStorage_rocksDB_sstSizeInMB" : "4", "brokerDeleteInactiveTopicsEnabled" : "true", "diskUsageThreshold" : "0.99", "bookkeeperClientRackawarePolicyEnabled" : "true", "managedLedgerMaxUnackedRangesToPersist" : "10000", "maxConcurrentTopicLoadRequest" : "5000", "enablePersistentTopics" : "true", "managedLedgerTraceTaskExecution" : "true", "loadBalancerAutoUnloadSplitBundlesEnabled" : "true", "dbStorage_rocksDB_blockSize" : "4096", "encryptionRequireOnProducer" : "false", "zooKeeperOperationTimeoutSeconds" : "30", "maxPendingPublishRequestsPerConnection" : "1000", "bookkeeperTLSKeyFilePath" : "", "allowLoopback" : "true", "webSocketMaxTextFrameSize" : "1048576", "loadBalancerCPUResourceWeight" : "1.0", "backlogQuotaCheckEnabled" : "true", "replicationPolicyCheckDurationSeconds" : "600", "allowAutoTopicCreation" : "true", "bookkeeperClientIsolationGroups" : "", "configurationStoreServers" : "", "maxUnackedMessagesPerSubscriptionOnBrokerBlocked" : "0.16", "dbStorage_writeCacheMaxSizeMb" : "", "brokerClientTlsProtocols" : "", "authorizationEnabled" : "false", "loadBalancerSheddingIntervalMinutes" : "1", "managedLedgerCursorPositionFlushSeconds" : "60", "loadManagerClassName" : "org.apache.pulsar.broker.loadbalance.NoopLoadManager", "bookkeeperClientHealthCheckQuarantineTimeInSeconds" : "1800", "numCacheExecutorThreadPoolSize" : "10", "loadBalancerSheddingGracePeriodMinutes" : "30", "backlogQuotaCheckIntervalInSeconds" : "60", "loadBalancerBandwithInResourceWeight" : "1.0", "loadBalancerBandwithOutResourceWeight" : "1.0", "bookkeeperClientTimeoutInSeconds" : "30", "tlsTrustCertsFilePath" : "", "managedLedgerCacheEvictionFrequency" : "100.0", "autoSkipNonRecoverableData" : "false", "bookkeeperClientHealthCheckEnabled" : "true", "dbStorage_rocksDB_numFilesInLevel0" : "4", "brokerDeleteInactiveTopicsFrequencySeconds" : "60", "managedLedgerReadEntryTimeoutSeconds" : "0", "loadBalancerBrokerMaxTopics" : "50000", "nettyMaxFrameSizeBytes" : "5253120", "enablePackagesManagement" : "false", "managedLedgerAddEntryTimeoutSeconds" : "0", "loadBalancerDirectMemoryResourceWeight" : "1.0", "managedLedgerMaxEntriesPerLedger" : "50000", "loadBalancerNamespaceMaximumBundles" : "128", "managedLedgerCacheCopyEntries" : "false", "tlsCertRefreshCheckDurationSec" : "300", "journalSyncData" : "false", "bindAddress" : "0.0.0.0", "transactionMetadataStoreProviderClassName" : "org.apache.pulsar.transaction.coordinator.impl.MLTransactionMetadataStoreProvider", "tlsAllowInsecureConnection" : "false", "allowEphemeralPorts" : "true", "maxProducersPerTopic" : "0", "tokenPublicKey" : "", "subscriptionExpirationTimeMinutes" : "0", "numWorkerThreadsForNonPersistentTopic" : "8", "maxConcurrentNonPersistentMessagePerConnection" : "1000", "managedLedgerNewEntriesCheckDelayInMillis" : "10", "bookkeeperClientAuthenticationParameters" : "", "authenticationEnabled" : "false", "numIOThreads" : "", "maxSubscriptionsPerTopic" : "0", "maxTopicsPerNamespace" : "0", "allocatorPoolingPolicy" : "UnpooledHeap", "topicLevelPoliciesEnabled" : "false", "brokerClientTlsEnabledWithKeyStore" : "false", "maxConsumersPerTopic" : "0", "brokerClientTlsTrustStoreType" : "JKS", "backlogQuotaDefaultLimitSecond" : "-1", "bookkeeperClientMinNumRacksPerWriteQuorum" : "1", "numOrderedExecutorThreads" : "8", "subscriptionRedeliveryTrackerEnabled" : "true", "dispatchThrottlingRatePerTopicInByte" : "0", "managedLedgerCursorRolloverTimeInSeconds" : "14400", "globalZookeeperServers" : "", "defaultNumberOfNamespaceBundles" : "4", "loadBalancerEnabled" : "false", "dbStorage_readAheadCacheMaxSizeMb" : "", "activeConsumerFailoverDelayTimeMillis" : "1000", "managedLedgerDefaultEnsembleSize" : "1", "loadBalancerHistoryResourcePercentage" : "0.9", "dbStorage_readAheadCacheBatchSize" : "1000", "bindAddresses" : "", "authorizationProvider" : "org.apache.pulsar.broker.authorization.PulsarAuthorizationProvider", "tlsTrustStore" : "", "maxMessageSizeCheckIntervalInSeconds" : "60", "zookeeperServers" : "", "transactionBufferSnapshotMaxTransactionCount" : "1000", "defaultRetentionSizeInMB" : "0", "defaultNumPartitions" : "1", "packagesReplicas" : "1", "topicFencingTimeoutSeconds" : "0", "bookkeeperTLSProviderFactoryClass" : "org.apache.bookkeeper.tls.TLSContextFactory", "bookkeeperNumberOfChannelsPerBookie" : "16", "transactionBufferSnapshotMinTimeInMillis" : "5000", "brokerClientSslProvider" : "", "preciseDispatcherFlowControl" : "false", "maxConcurrentLookupRequest" : "50000", "skipBrokerShutdownOnOOM" : "false", "bookkeeperTLSKeyStorePasswordPath" : "", "defaultRetentionTimeInMinutes" : "0", "brokerPublisherThrottlingMaxMessageRate" : "0", "bookkeeperExplicitLacIntervalInMills" : "0", "replicationProducerQueueSize" : "1000", "loadBalancerNamespaceBundleMaxSessions" : "1000", "tlsProtocols" : "", "managedLedgerDefaultWriteQuorum" : "1", "zooKeeperSessionTimeoutMillis" : "30000", "statusFilePath" : "/usr/local/apache/htdocs", "bookkeeperClientSecondaryIsolationGroups" : "", "tokenAudienceClaim" : "", "brokerServicePurgeInactiveFrequencyInSeconds" : "60", "journalMaxGroupWaitMSec" : "1", "dbStorage_rocksDB_bloomFilterBitsPerKey" : "10", "brokerDeduplicationMaxNumberOfProducers" : "10000", "diskUsageWarnThreshold" : "0.99", "brokerDeduplicationProducerInactivityTimeoutMinutes" : "360", "tlsKeyFilePath" : "", "bookkeeperClientAuthenticationPlugin" : "", "packagesManagementLedgerRootPath" : "/ledgers", "bookkeeperDiskWeightBasedPlacementEnabled" : "false", "tlsTrustStoreType" : "JKS", "authorizationAllowWildcardsMatching" : "false", "subscriptionKeySharedConsistentHashingReplicaPoints" : "100", "managedLedgerDefaultMarkDeleteRateLimit" : "0.1", "bookkeeperClientQuarantineRatio" : "1.0", "managedLedgerMaxLedgerRolloverTimeMinutes" : "240", "subscriptionExpiryCheckIntervalInMinutes" : "5", "maxUnackedMessagesPerBroker" : "0", "preciseTopicPublishRateLimiterEnable" : "false", "tlsKeyStore" : "", "keepAliveIntervalSeconds" : "30", "flushInterval" : "60000", "brokerClientAuthenticationParameters" : "", "splitTopicAndPartitionLabelInPrometheus" : "false", "tlsEnabledWithKeyStore" : "false", "managedLedgerCacheEvictionTimeThresholdMillis" : "1000", "replicationMetricsEnabled" : "true", "bookkeeperClientSpeculativeReadTimeoutInMillis" : "0", "bookkeeperTLSKeyFileType" : "PEM", "ttlDurationDefaultInSeconds" : "0", "backlogQuotaDefaultLimitGB" : "10", "ledgerDirectories" : "data/standalone/bookkeeper0", "zooKeeperCacheExpirySeconds" : "300", "journalDirectories" : "data/standalone/bookkeeper0", "bookkeeperTLSClientAuthentication" : "false", "managedLedgerMaxUnackedRangesToPersistInZooKeeper" : "1000", "loadBalancerBundleUnloadMinThroughputThreshold" : "10", "metricsServletTimeoutMs" : "30000", "dispatchThrottlingRatePerTopicInMsg" : "0", "maxUnackedMessagesPerSubscription" : "200000", "tlsTrustStorePassword" : "", "failureDomainsEnabled" : "false", "managedLedgerUnackedRangesOpenCacheSetEnabled" : "true", "forceDeleteTenantAllowed" : "false", "webSocketNumIoThreads" : "8", "subscriptionKeySharedUseConsistentHashing" : "false", "brokerPublisherThrottlingTickTimeMillis" : "50", "tlsKeyStorePassword" : "", "systemTopicEnabled" : "false", "allowAutoSubscriptionCreation" : "true", "messageExpiryCheckIntervalInMinutes" : "5", "loadBalancerHostUsageCheckIntervalMinutes" : "1", "loadBalancerResourceQuotaUpdateIntervalMinutes" : "15" } 2022-02-15T20:08:07,339+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053c2ea580000, timeout of 6000ms exceeded 2022-02-15T20:08:08,442+0000 [main] INFO org.apache.bookkeeper.proto.BookieNettyServer - Binding bookie-rpc endpoint to 0.0.0.0/0.0.0.0:3181 2022-02-15T20:08:09,139+0000 [main] INFO org.apache.bookkeeper.meta.MetadataDrivers - BookKeeper metadata driver manager initialized 2022-02-15T20:08:09,150+0000 [main] INFO org.apache.bookkeeper.meta.zk.ZKMetadataDriverBase - Initialize zookeeper metadata driver at metadata service uri zk+null://127.0.0.1:2181/ledgers : zkServers = 127.0.0.1:2181, ledgersRootPath = /ledgers. 2022-02-15T20:08:09,153+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=10000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@71984c3 2022-02-15T20:08:09,239+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes 2022-02-15T20:08:09,240+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false 2022-02-15T20:08:09,241+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. 2022-02-15T20:08:09,242+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error) 2022-02-15T20:08:09,243+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41130, server: localhost/127.0.0.1:2181 2022-02-15T20:08:09,246+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60001, negotiated timeout = 10000 2022-02-15T20:08:09,339+0000 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now. 2022-02-15T20:08:09,358+0000 [main] INFO org.apache.bookkeeper.discover.ZKRegistrationManager - INSTANCEID not exists in zookeeper. Not considering it for data verification 2022-02-15T20:08:10,242+0000 [main] INFO org.apache.bookkeeper.bookie.Bookie - instantiate ledger manager org.apache.bookkeeper.meta.HierarchicalLedgerManagerFactory 2022-02-15T20:08:10,339+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd000b, timeout of 10000ms exceeded 2022-02-15T20:08:10,340+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd0001, timeout of 10000ms exceeded 2022-02-15T20:08:10,341+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd0007, timeout of 10000ms exceeded 2022-02-15T20:08:10,342+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd000a, timeout of 10000ms exceeded 2022-02-15T20:08:10,350+0000 [main] INFO org.apache.bookkeeper.bookie.Bookie - Using ledger storage: org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage 2022-02-15T20:08:10,439+0000 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - Started Db Ledger Storage 2022-02-15T20:08:10,439+0000 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - - Number of directories: 1 2022-02-15T20:08:10,440+0000 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - - Write cache size: 1024 MB 2022-02-15T20:08:10,440+0000 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.DbLedgerStorage - - Read Cache: 1024 MB 2022-02-15T20:08:10,443+0000 [main] INFO org.apache.bookkeeper.bookie.storage.ldb.SingleDirectoryDbLedgerStorage - Creating single directory db ledger storage on data/standalone/bookkeeper0/current 2022-02-15T20:08:11,348+0000 [main] INFO org.apache.bookkeeper.bookie.ScanAndCompareGarbageCollector - Over Replicated Ledger Deletion : enabled=true, interval=86400000 2022-02-15T20:08:11,444+0000 [main] INFO org.apache.bookkeeper.bookie.GarbageCollectorThread - Minor Compaction : enabled=true, threshold=0.20000000298023224, interval=3600000 2022-02-15T20:08:11,444+0000 [main] INFO org.apache.bookkeeper.bookie.GarbageCollectorThread - Major Compaction : enabled=true, threshold=0.800000011920929, interval=86400000 2022-02-15T20:08:11,654+0000 [main] INFO org.apache.bookkeeper.bookie.Bookie - Replaying journal 1644953547840 from position 61440 2022-02-15T20:08:11,742+0000 [main] INFO org.apache.bookkeeper.bookie.JournalChannel - Opening journal data/standalone/bookkeeper0/current/17efedf3440.txn 2022-02-15T20:08:11,747+0000 [main] INFO org.apache.bookkeeper.bookie.Bookie - Finished replaying journal in 94 ms. 2022-02-15T20:08:11,753+0000 [SyncThread-7-1] INFO org.apache.bookkeeper.bookie.EntryLogManagerBase - Creating a new entry log file because current active log channel has not initialized yet 2022-02-15T20:08:11,756+0000 [SyncThread-7-1] INFO org.apache.bookkeeper.bookie.EntryLoggerAllocator - Created new entry log file data/standalone/bookkeeper0/current/2.log for logId 2. 2022-02-15T20:08:11,840+0000 [pool-6-thread-1] INFO org.apache.bookkeeper.bookie.EntryLoggerAllocator - Created new entry log file data/standalone/bookkeeper0/current/3.log for logId 3. 2022-02-15T20:08:11,859+0000 [SyncThread-7-1] INFO org.apache.bookkeeper.bookie.SyncThread - Flush ledger storage at checkpoint CheckpointList{checkpoints=[LogMark: logFileId - 1644953547840 , logFileOffset - 62468]}. 2022-02-15T20:08:11,861+0000 [main] INFO org.apache.bookkeeper.bookie.Bookie - Finished reading journal, starting bookie 2022-02-15T20:08:11,940+0000 [BookieJournal-3181] INFO org.apache.bookkeeper.bookie.Journal - Starting journal on data/standalone/bookkeeper0/current 2022-02-15T20:08:11,942+0000 [ForceWriteThread] INFO org.apache.bookkeeper.bookie.Journal - ForceWrite Thread started 2022-02-15T20:08:11,943+0000 [BookieJournal-3181] INFO org.apache.bookkeeper.bookie.JournalChannel - Opening journal data/standalone/bookkeeper0/current/17efedf3441.txn 2022-02-15T20:08:12,600+0000 [main] WARN org.apache.curator.retry.ExponentialBackoffRetry - maxRetries too large (2147483647). Pinning to 29 2022-02-15T20:08:13,053+0000 [main] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting 2022-02-15T20:08:13,141+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=60000 watcher=org.apache.curator.ConnectionState@40147317 2022-02-15T20:08:13,142+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes 2022-02-15T20:08:13,143+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false 2022-02-15T20:08:13,144+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. 2022-02-15T20:08:13,145+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error) 2022-02-15T20:08:13,145+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41158, server: localhost/127.0.0.1:2181 2022-02-15T20:08:13,242+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60002, negotiated timeout = 60000 2022-02-15T20:08:13,342+0000 [main-EventThread] INFO org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED 2022-02-15T20:08:13,345+0000 [main] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - Default schema 2022-02-15T20:08:13,350+0000 [main-EventThread] INFO org.apache.curator.framework.imps.EnsembleTracker - New config event received: {} 2022-02-15T20:08:13,443+0000 [main-EventThread] INFO org.apache.curator.framework.imps.EnsembleTracker - New config event received: {} 2022-02-15T20:08:13,742+0000 [main] INFO org.apache.bookkeeper.stream.storage.impl.cluster.ZkClusterInitializer - Loaded cluster metadata : num_storage_containers: 2

2022-02-15T20:08:13,743+0000 [Curator-Framework-0] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - backgroundOperationsLoop exiting 2022-02-15T20:08:13,944+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60002. org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60002, likely server has closed socket at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] 2022-02-15T20:08:14,052+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60002 2022-02-15T20:08:14,052+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60002 closed 2022-02-15T20:08:14,066+0000 [main] WARN org.apache.bookkeeper.stream.server.StorageServer - Determining hostname for stream storage 2022-02-15T20:08:14,139+0000 [main] WARN org.apache.bookkeeper.stream.server.StorageServer - Decided to use hostname 172.31.24.239 2022-02-15T20:08:14,147+0000 [main] INFO org.apache.bookkeeper.stream.server.StorageServer - Dlog configuration : { "bkcEnsembleSize" : "1", "bkcWriteQuorumSize" : "1", "bkcAckQuorumSize" : "1" } 2022-02-15T20:08:14,148+0000 [main] INFO org.apache.bookkeeper.stream.server.StorageServer - Storage configuration : { "range.store.dirs" : "data/standalone/bookkeeper/ranges/data" } 2022-02-15T20:08:14,148+0000 [main] INFO org.apache.bookkeeper.stream.server.StorageServer - Server configuration : { "grpc.port" : "4181" } 2022-02-15T20:08:14,253+0000 [main] WARN org.apache.curator.retry.ExponentialBackoffRetry - maxRetries too large (2147483647). Pinning to 29 2022-02-15T20:08:14,662+0000 [main] INFO org.apache.bookkeeper.meta.zk.ZKMetadataDriverBase - Initialize zookeeper metadata driver at metadata service uri zk://127.0.0.1:2181/ledgers : zkServers = 127.0.0.1:2181, ledgersRootPath = /ledgers. 2022-02-15T20:08:14,662+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=10000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@77cc6a28 2022-02-15T20:08:14,662+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes 2022-02-15T20:08:14,663+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false 2022-02-15T20:08:14,740+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. 2022-02-15T20:08:14,740+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error) 2022-02-15T20:08:14,741+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41162, server: localhost/127.0.0.1:2181 2022-02-15T20:08:14,743+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60003, negotiated timeout = 10000 2022-02-15T20:08:14,744+0000 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now. 2022-02-15T20:08:14,853+0000 [main-EventThread] INFO org.apache.bookkeeper.discover.ZKRegistrationClient - Update BookieInfoCache (writable bookie) 127.0.0.1:3181 -> BookieServiceInfo{properties={}, endpoints=[EndpointInfo{id=127.0.0.1:3181, port=3181, host=127.0.0.1, protocol=bookie-rpc, auth=[], extensions=[]}]} 2022-02-15T20:08:14,939+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60003. org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60003, likely server has closed socket at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] 2022-02-15T20:08:15,040+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60003 closed 2022-02-15T20:08:15,040+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60003 2022-02-15T20:08:15,041+0000 [main] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - Starting 2022-02-15T20:08:15,042+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=60000 watcher=org.apache.curator.ConnectionState@65262308 2022-02-15T20:08:15,042+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes 2022-02-15T20:08:15,042+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false 2022-02-15T20:08:15,044+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. 2022-02-15T20:08:15,044+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error) 2022-02-15T20:08:15,045+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41164, server: localhost/127.0.0.1:2181 2022-02-15T20:08:15,046+0000 [main] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - Default schema 2022-02-15T20:08:15,052+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60004, negotiated timeout = 60000 2022-02-15T20:08:15,046+0000 [main] INFO org.apache.bookkeeper.stream.server.service.CuratorProviderService - Provided curator clients to zookeeper 127.0.0.1:2181. 2022-02-15T20:08:15,053+0000 [main-EventThread] INFO org.apache.curator.framework.state.ConnectionStateManager - State change: CONNECTED 2022-02-15T20:08:15,140+0000 [main-EventThread] INFO org.apache.curator.framework.imps.EnsembleTracker - New config event received: {} 2022-02-15T20:08:15,142+0000 [main-EventThread] INFO org.apache.curator.framework.imps.EnsembleTracker - New config event received: {} 2022-02-15T20:08:15,149+0000 [main] INFO org.apache.bookkeeper.stream.server.service.DLNamespaceProviderService - Initializing dlog namespace at distributedlog://127.0.0.1:2181/stream/storage 2022-02-15T20:08:15,242+0000 [main] INFO org.apache.distributedlog.namespace.NamespaceDriverManager - DistributedLog NamespaceDriverManager initialized 2022-02-15T20:08:15,342+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=30000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@7ac1b6c0 2022-02-15T20:08:15,342+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes 2022-02-15T20:08:15,343+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false 2022-02-15T20:08:15,344+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. 2022-02-15T20:08:15,344+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error) 2022-02-15T20:08:15,345+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41168, server: localhost/127.0.0.1:2181 2022-02-15T20:08:15,350+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60005, negotiated timeout = 30000 2022-02-15T20:08:15,351+0000 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now. 2022-02-15T20:08:15,441+0000 [main] INFO org.apache.distributedlog.ZooKeeperClient - Close zookeeper client default. 2022-02-15T20:08:15,441+0000 [main] INFO org.apache.distributedlog.ZooKeeperClient - Closing zookeeper client default. 2022-02-15T20:08:15,544+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60005 closed 2022-02-15T20:08:15,544+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60005 2022-02-15T20:08:15,544+0000 [main] INFO org.apache.distributedlog.ZooKeeperClient - Closed zookeeper client default. 2022-02-15T20:08:15,550+0000 [main] INFO org.apache.distributedlog.api.namespace.NamespaceBuilder - No feature provider is set. All features are disabled now. 2022-02-15T20:08:15,554+0000 [main] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Created shared zooKeeper client builder dlzk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared: zkServers = 127.0.0.1:2181, numRetries = 3, sessionTimeout = 30000, retryBackoff = 5000, maxRetryBackoff = 30000, zkAclId = null. 2022-02-15T20:08:15,556+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=30000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@58f97013 2022-02-15T20:08:15,556+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes 2022-02-15T20:08:15,557+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false 2022-02-15T20:08:15,557+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. 2022-02-15T20:08:15,558+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error) 2022-02-15T20:08:15,558+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41170, server: localhost/127.0.0.1:2181 2022-02-15T20:08:15,642+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60006, negotiated timeout = 30000 2022-02-15T20:08:15,642+0000 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now. 2022-02-15T20:08:15,646+0000 [main] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Created shared client builder bk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared : zkServers = 127.0.0.1:2181, ledgersPath = /ledgers, numIOThreads = 1 2022-02-15T20:08:15,649+0000 [main] INFO org.apache.distributedlog.impl.metadata.BKDLConfig - Propagate BKDLConfig to DLConfig : encodeRegionID = false, firstLogSegmentSequenceNumber = 1, createStreamIfNotExists = true, isFederated = false. 2022-02-15T20:08:15,658+0000 [main] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Initialized BK namespace driver: clientId = storage-server, regionId = 0, federated = false. 2022-02-15T20:08:15,758+0000 [main] INFO org.apache.distributedlog.logsegment.LogSegmentMetadataCache - Log segment cache is enabled = true 2022-02-15T20:08:15,839+0000 [main] INFO org.apache.bookkeeper.stream.server.service.DLNamespaceProviderService - Provided distributedlog namespace at distributedlog://127.0.0.1:2181/stream/storage. 2022-02-15T20:08:20,741+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - Client session timed out, have not heard from server in 4397ms for session id 0x10053c489f60000 2022-02-15T20:08:20,742+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - Session 0x10053c489f60000 for sever localhost/127.0.0.1:2181, Closing socket connection. Attempting reconnect except it is a SessionExpiredException. org.apache.zookeeper.ClientCnxn$SessionTimeoutException: Client session timed out, have not heard from server in 4397ms for session id 0x10053c489f60000 at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1258) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] 2022-02-15T20:08:20,744+0000 [NIOWorkerThread-1] WARN org.apache.zookeeper.server.NIOServerCnxn - Unexpected exception org.apache.zookeeper.server.ServerCnxn$EndOfStreamException: Unable to read additional data from client, it probably closed the socket: address = /127.0.0.1:41092, session = 0x10053c489f60000 at org.apache.zookeeper.server.NIOServerCnxn.handleFailedRead(NIOServerCnxn.java:163) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.server.NIOServerCnxn.doIO(NIOServerCnxn.java:326) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.server.NIOServerCnxnFactory$IOWorkRequest.doWork(NIOServerCnxnFactory.java:522) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.server.WorkerService$ScheduledWorkRequest.run(WorkerService.java:154) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_312] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_312] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312] 2022-02-15T20:08:23,650+0000 [main] INFO org.apache.bookkeeper.stream.storage.impl.sc.ZkStorageContainerManager - Watched cluster assignment data. 2022-02-15T20:08:23,740+0000 [main] INFO org.apache.bookkeeper.stream.storage.impl.sc.ZkStorageContainerManager - Scheduled storage container probe task at every 15000 ms 2022-02-15T20:08:23,743+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. 2022-02-15T20:08:23,743+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error) 2022-02-15T20:08:23,744+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41204, server: localhost/127.0.0.1:2181 2022-02-15T20:08:23,841+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60000, negotiated timeout = 6000 2022-02-15T20:08:24,047+0000 [zk-storage-container-manager] INFO org.apache.bookkeeper.stream.storage.impl.sc.ZkStorageContainerManager - Servers joined : [hostname: "172.31.29.87" port: 4181 ] 2022-02-15T20:08:24,255+0000 [main] INFO org.apache.bookkeeper.stream.storage.impl.grpc.GrpcMetaRangeService - Created MetaRange service 2022-02-15T20:08:24,342+0000 [main] INFO org.apache.bookkeeper.stream.storage.impl.grpc.GrpcTableService - Created Table service 2022-02-15T20:08:24,939+0000 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=127.0.0.1:2181 sessionTimeout=10000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@5f190cfe 2022-02-15T20:08:24,940+0000 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes 2022-02-15T20:08:24,940+0000 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=false 2022-02-15T20:08:24,949+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server localhost/127.0.0.1:2181. 2022-02-15T20:08:24,950+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - SASL config status: Will not attempt to authenticate using SASL (unknown error) 2022-02-15T20:08:24,950+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /127.0.0.1:41212, server: localhost/127.0.0.1:2181 2022-02-15T20:08:25,041+0000 [main-SendThread(127.0.0.1:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server localhost/127.0.0.1:2181, session id = 0x10053c489f60007, negotiated timeout = 10000 2022-02-15T20:08:25,041+0000 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now. 2022-02-15T20:08:25,047+0000 [main] INFO org.apache.bookkeeper.stream.server.service.RegistrationStateService - Successfully register myself under registration path /stream/servers/172.31.24.239:4181 2022-02-15T20:08:25,152+0000 [main] INFO org.apache.bookkeeper.stream.server.service.ClusterControllerService - Successfully started the cluster controller. 2022-02-15T20:08:29,139+0000 [client-scheduler-OrderedScheduler-0-0] INFO org.apache.bookkeeper.clients.impl.channel.StorageServerChannelManager - Added range server (hostname: "172.31.29.87" port: 4181 ) into the channel manager. 2022-02-15T20:08:29,340+0000 [client-scheduler-OrderedScheduler-0-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {} io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.Status.asRuntimeException(Status.java:533) ~[io.grpc-grpc-api-1.33.0.jar:1.33.0] at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[io.grpc-grpc-stub-1.33.0.jar:1.33.0] at io.grpc.internal.DelayedClientCall$DelayedListener$3.run(DelayedClientCall.java:463) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.DelayedClientCall$DelayedListener.delayOrExecute(DelayedClientCall.java:427) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.DelayedClientCall$DelayedListener.onClose(DelayedClientCall.java:460) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_312] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_312] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312] Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: No route to host: /172.31.29.87:4181 Caused by: java.net.ConnectException: finishConnect(..) failed: No route to host at io.grpc.netty.shaded.io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:672) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:649) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:529) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:465) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] ... 1 more 2022-02-15T20:08:30,346+0000 [client-scheduler-OrderedScheduler-1-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {} io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.Status.asRuntimeException(Status.java:533) ~[io.grpc-grpc-api-1.33.0.jar:1.33.0] at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[io.grpc-grpc-stub-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_312] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_312] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312] Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: No route to host: /172.31.29.87:4181 Caused by: java.net.ConnectException: finishConnect(..) failed: No route to host at io.grpc.netty.shaded.io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:672) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:649) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:529) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:465) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] ... 1 more 2022-02-15T20:08:31,339+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd0009, timeout of 30000ms exceeded 2022-02-15T20:08:31,340+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd0008, timeout of 30000ms exceeded 2022-02-15T20:08:31,340+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd0006, timeout of 30000ms exceeded 2022-02-15T20:08:31,340+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd000e, timeout of 30000ms exceeded 2022-02-15T20:08:31,341+0000 [SessionTracker] INFO org.apache.zookeeper.server.ZooKeeperServer - Expiring session 0x10053a3d1cd000c, timeout of 30000ms exceeded 2022-02-15T20:08:31,969+0000 [client-scheduler-OrderedScheduler-0-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {} io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.Status.asRuntimeException(Status.java:533) ~[io.grpc-grpc-api-1.33.0.jar:1.33.0] at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[io.grpc-grpc-stub-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_312] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_312] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312] Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: No route to host: /172.31.29.87:4181 Caused by: java.net.ConnectException: finishConnect(..) failed: No route to host at io.grpc.netty.shaded.io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:672) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:649) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:529) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:465) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] ... 1 more ^C2022-02-15T20:08:33,849+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60007. org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60007, likely server has closed socket at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] 2022-02-15T20:08:34,040+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60007 2022-02-15T20:08:34,040+0000 [Thread-1] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60007 closed 2022-02-15T20:08:34,042+0000 [Thread-1] INFO org.apache.distributedlog.BookKeeperClient - BookKeeper Client closed bk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared 2022-02-15T20:08:34,043+0000 [Thread-1] INFO org.apache.distributedlog.ZooKeeperClient - Close zookeeper client dlzk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared. 2022-02-15T20:08:34,043+0000 [Thread-1] INFO org.apache.distributedlog.ZooKeeperClient - Closing zookeeper client dlzk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared. 2022-02-15T20:08:34,045+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60006. org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60006, likely server has closed socket at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] 2022-02-15T20:08:34,145+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60006 2022-02-15T20:08:34,146+0000 [Thread-1] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60006 closed 2022-02-15T20:08:34,146+0000 [Thread-1] INFO org.apache.distributedlog.ZooKeeperClient - Closed zookeeper client dlzk:distributedlog://127.0.0.1:2181/stream/storage:factory_writer_shared. 2022-02-15T20:08:34,146+0000 [Thread-1] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Release external resources used by channel factory. 2022-02-15T20:08:34,147+0000 [Thread-1] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Stopped request timer 2022-02-15T20:08:34,148+0000 [Thread-1] INFO org.apache.distributedlog.BKDistributedLogNamespace - Executor Service Stopped. 2022-02-15T20:08:34,148+0000 [Curator-Framework-0] INFO org.apache.curator.framework.imps.CuratorFrameworkImpl - backgroundOperationsLoop exiting 2022-02-15T20:08:34,155+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60004. org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60004, likely server has closed socket at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] 2022-02-15T20:08:34,256+0000 [Thread-1] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60004 closed 2022-02-15T20:08:34,257+0000 [Thread-1] INFO org.apache.bookkeeper.proto.BookieServer - Shutting down BookieServer 2022-02-15T20:08:34,257+0000 [Thread-1] INFO org.apache.bookkeeper.proto.BookieNettyServer - Shutting down BookieNettyServer 2022-02-15T20:08:34,258+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60004 2022-02-15T20:08:34,340+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.Bookie - Shutting down Bookie-3181 with exitCode 0 2022-02-15T20:08:34,340+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.Bookie - Turning bookie to read only during shut down 2022-02-15T20:08:34,340+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.SyncThread - Shutting down SyncThread 2022-02-15T20:08:34,348+0000 [SyncThread-7-1] INFO org.apache.bookkeeper.bookie.SyncThread - Flush ledger storage at checkpoint CheckpointList{checkpoints=[LogMark: logFileId - 1644953547840 , logFileOffset - 62468]}. 2022-02-15T20:08:34,351+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.Journal - Shutting down Journal 2022-02-15T20:08:34,352+0000 [ForceWriteThread] INFO org.apache.bookkeeper.bookie.Journal - ForceWrite thread interrupted 2022-02-15T20:08:34,352+0000 [BookieJournal-3181] INFO org.apache.bookkeeper.bookie.Journal - Journal exits when shutting down 2022-02-15T20:08:34,353+0000 [BookieJournal-3181] INFO org.apache.bookkeeper.bookie.Journal - Journal exited loop! 2022-02-15T20:08:34,353+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.Journal - Finished Shutting down Journal thread 2022-02-15T20:08:34,354+0000 [Bookie-3181] INFO org.apache.bookkeeper.bookie.Bookie - Journal thread(s) quit. 2022-02-15T20:08:34,366+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.GarbageCollectorThread - Shutting down GarbageCollectorThread 2022-02-15T20:08:34,367+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.EntryLogger - Stopping EntryLogger 2022-02-15T20:08:34,367+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.EntryLoggerAllocator - Stopped entry logger preallocator. 2022-02-15T20:08:34,369+0000 [Thread-1] INFO org.apache.bookkeeper.bookie.LedgerDirsMonitor - Shutting down LedgerDirsMonitor 2022-02-15T20:08:34,440+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60001. org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60001, likely server has closed socket at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] 2022-02-15T20:08:34,463+0000 [client-scheduler-OrderedScheduler-1-0] ERROR org.apache.bookkeeper.clients.impl.internal.RootRangeClientImplWithRetries - Reason for the failure {} io.grpc.StatusRuntimeException: UNAVAILABLE: io exception at io.grpc.Status.asRuntimeException(Status.java:533) ~[io.grpc-grpc-api-1.33.0.jar:1.33.0] at io.grpc.stub.ClientCalls$UnaryStreamToFuture.onClose(ClientCalls.java:533) ~[io.grpc-grpc-stub-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.closeObserver(ClientCallImpl.java:616) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl.access$300(ClientCallImpl.java:69) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInternal(ClientCallImpl.java:802) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ClientCallImpl$ClientStreamListenerImpl$1StreamClosed.runInContext(ClientCallImpl.java:781) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.ContextRunnable.run(ContextRunnable.java:37) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at io.grpc.internal.SerializingExecutor.run(SerializingExecutor.java:123) ~[io.grpc-grpc-core-1.33.0.jar:1.33.0] at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) ~[?:1.8.0_312] at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) ~[?:1.8.0_312] at java.lang.Thread.run(Thread.java:748) [?:1.8.0_312] Caused by: io.grpc.netty.shaded.io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..) failed: No route to host: /172.31.29.87:4181 Caused by: java.net.ConnectException: finishConnect(..) failed: No route to host at io.grpc.netty.shaded.io.netty.channel.unix.Errors.throwConnectException(Errors.java:124) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.unix.Socket.finishConnect(Socket.java:243) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.doFinishConnect(AbstractEpollChannel.java:672) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.finishConnect(AbstractEpollChannel.java:649) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.AbstractEpollChannel$AbstractEpollUnsafe.epollOutReady(AbstractEpollChannel.java:529) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.processReady(EpollEventLoop.java:465) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.channel.epoll.EpollEventLoop.run(EpollEventLoop.java:378) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.concurrent.SingleThreadEventExecutor$4.run(SingleThreadEventExecutor.java:989) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.internal.ThreadExecutorMap$2.run(ThreadExecutorMap.java:74) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] at io.grpc.netty.shaded.io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) ~[io.grpc-grpc-netty-shaded-1.33.0.jar:1.33.0] ... 1 more 2022-02-15T20:08:34,541+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60001 2022-02-15T20:08:34,542+0000 [Thread-1] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60001 closed 2022-02-15T20:08:34,550+0000 [main-SendThread(127.0.0.1:2181)] WARN org.apache.zookeeper.ClientCnxn - An exception was thrown while closing send thread for session 0x10053c489f60000. org.apache.zookeeper.ClientCnxn$EndOfStreamException: Unable to read additional data from server sessionid 0x10053c489f60000, likely server has closed socket at org.apache.zookeeper.ClientCnxnSocketNIO.doIO(ClientCnxnSocketNIO.java:77) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxnSocketNIO.doTransport(ClientCnxnSocketNIO.java:350) ~[org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] at org.apache.zookeeper.ClientCnxn$SendThread.run(ClientCnxn.java:1290) [org.apache.zookeeper-zookeeper-3.6.3.jar:3.6.3] 2022-02-15T20:08:34,651+0000 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x10053c489f60000 2022-02-15T20:08:34,651+0000 [Thread-1] INFO org.apache.zookeeper.ZooKeeper - Session: 0x10053c489f60000 closed 2022-02-15T20:08:34,652+0000 [Thread-1] INFO org.apache.zookeeper.server.ZooKeeperServer - shutting down 2022-02-15T20:08:34,652+0000 [Thread-1] INFO org.apache.zookeeper.server.RequestThrottler - Shutting down 2022-02-15T20:08:34,652+0000 [RequestThrottler] INFO org.apache.zookeeper.server.RequestThrottler - Draining request throttler queue 2022-02-15T20:08:34,653+0000 [RequestThrottler] INFO org.apache.zookeeper.server.RequestThrottler - RequestThrottler shutdown. Dropped 0 requests 2022-02-15T20:08:34,653+0000 [Thread-1] INFO org.apache.zookeeper.server.SessionTrackerImpl - Shutting down 2022-02-15T20:08:34,653+0000 [Thread-1] INFO org.apache.zookeeper.server.PrepRequestProcessor - Shutting down 2022-02-15T20:08:34,653+0000 [Thread-1] INFO org.apache.zookeeper.server.SyncRequestProcessor - Shutting down 2022-02-15T20:08:34,654+0000 [SyncThread:0] INFO org.apache.zookeeper.server.SyncRequestProcessor - SyncRequestProcessor exited! 2022-02-15T20:08:34,654+0000 [ProcessThread(sid:0 cport:2181):] INFO org.apache.zookeeper.server.PrepRequestProcessor - PrepRequestProcessor exited loop! 2022-02-15T20:08:34,654+0000 [Thread-1] INFO org.apache.zookeeper.server.FinalRequestProcessor - shutdown of request processor complete 2022-02-15T20:08:34,656+0000 [NIOServerCxnFactory.AcceptThread:0.0.0.0/0.0.0.0:2181] INFO org.apache.zookeeper.server.NIOServerCnxnFactory - accept thread exitted run method 2022-02-15T20:08:34,657+0000 [ConnnectionExpirer] INFO org.apache.zookeeper.server.NIOServerCnxnFactory - ConnnectionExpirerThread interrupted 2022-02-15T20:08:34,657+0000 [NIOServerCxnFactory.SelectorThread-0] INFO org.apache.zookeeper.server.NIOServerCnxnFactory - selector thread exitted run method 2022-02-15T20:08:34,660+0000 [Thread-1] INFO org.apache.zookeeper.server.DatadirCleanupManager - Shutting down purge task.`

github-actions[bot] commented 2 years ago

The issue had no activity for 30 days, mark with Stale label.

github-actions[bot] commented 2 years ago

The issue had no activity for 30 days, mark with Stale label.