· 5 years ago · Mar 06, 2020, 05:34 PM
1[conf/pulsar_env.sh] Applying config PULSAR_EXTRA_OPTS = -Dpulsar.log.root.level=info
2[conf/pulsar_env.sh] Applying config PULSAR_GC = "-XX:+UseG1GC -XX:MaxGCPauseMillis=10"
3[conf/pulsar_env.sh] Applying config PULSAR_MEM = "-Xms128m -Xmx256m -XX:MaxDirectMemorySize=128m -Dio.netty.leakDetectionLevel=disabled -Dio.netty.recycler.linkCapacity=1024 -XX:+ParallelRefProcEnabled -XX:+UnlockExperimentalVMOptions -XX:+AggressiveOpts -XX:+DoEscapeAnalysis -XX:ParallelGCThreads=32 -XX:ConcGCThreads=32 -XX:G1NewSizePercent=50 -XX:+DisableExplicitGC -XX:-ResizePLAB -XX:+ExitOnOutOfMemoryError -XX:+PerfDisableSharedMem"
4[conf/pulsar_env.sh] Applying config PULSAR_EXTRA_OPTS = -Dpulsar.log.root.level=info
5[conf/pulsar_env.sh] Applying config PULSAR_GC = "-XX:+UseG1GC -XX:MaxGCPauseMillis=10"
6[conf/pulsar_env.sh] Applying config PULSAR_MEM = "-Xms128m -Xmx256m -XX:MaxDirectMemorySize=128m -Dio.netty.leakDetectionLevel=disabled -Dio.netty.recycler.linkCapacity=1024 -XX:+ParallelRefProcEnabled -XX:+UnlockExperimentalVMOptions -XX:+AggressiveOpts -XX:+DoEscapeAnalysis -XX:ParallelGCThreads=32 -XX:ConcGCThreads=32 -XX:G1NewSizePercent=50 -XX:+DisableExplicitGC -XX:-ResizePLAB -XX:+ExitOnOutOfMemoryError -XX:+PerfDisableSharedMem"
7[conf/pulsar_env.sh] Applying config PULSAR_EXTRA_OPTS = -Dpulsar.log.root.level=info
8[conf/pulsar_env.sh] Applying config PULSAR_GC = "-XX:+UseG1GC -XX:MaxGCPauseMillis=10"
9[conf/pulsar_env.sh] Applying config PULSAR_MEM = "-Xms128m -Xmx256m -XX:MaxDirectMemorySize=128m -Dio.netty.leakDetectionLevel=disabled -Dio.netty.recycler.linkCapacity=1024 -XX:+ParallelRefProcEnabled -XX:+UnlockExperimentalVMOptions -XX:+AggressiveOpts -XX:+DoEscapeAnalysis -XX:ParallelGCThreads=32 -XX:ConcGCThreads=32 -XX:G1NewSizePercent=50 -XX:+DisableExplicitGC -XX:-ResizePLAB -XX:+ExitOnOutOfMemoryError -XX:+PerfDisableSharedMem"
1012:43:54.101 [main] INFO org.apache.pulsar.functions.worker.Worker - Checking if pulsar service at http://pulsar-broker:8080 is up...
1112:43:54.855 [main] INFO org.apache.pulsar.functions.worker.Worker - Initializing Pulsar Functions namespace...
1212:43:54.987 [main] INFO org.apache.distributedlog.namespace.NamespaceDriverManager - DistributedLog NamespaceDriverManager initialized
1312:43:55.017 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:zookeeper.version=3.5.6-c11b7e26bc554b8523dc929761dd28808913f091, built on 10/08/2019 20:18 GMT
1412:43:55.017 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:host.name=pulsar-function-0.pulsar-function.default.svc.cluster.local
1512:43:55.018 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.version=1.8.0_232
1612:43:55.018 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.vendor=Oracle Corporation
1712:43:55.018 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.home=/usr/local/openjdk-8/jre
1812:43:55.018 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.class.path=/pulsar/conf:::/pulsar/lib/org.glassfish.hk2-hk2-utils-2.5.0-b42.jar:/pulsar/lib/io.jsonwebtoken-jjwt-impl-0.10.5.jar:/pulsar/lib/com.typesafe.netty-netty-reactive-streams-2.0.0.jar:/pulsar/lib/org.glassfish.jersey.core-jersey-common-2.27.jar:/pulsar/lib/org.asynchttpclient-async-http-client-2.7.0.jar:/pulsar/lib/io.grpc-grpc-testing-1.18.0.jar:/pulsar/lib/io.prometheus-simpleclient_hotspot-0.5.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-client-original-2.5.0.jar:/pulsar/lib/org.eclipse.jetty.websocket-websocket-server-9.4.20.v20190813.jar:/pulsar/lib/io.swagger-swagger-annotations-1.5.21.jar:/pulsar/lib/com.google.protobuf-protobuf-java-3.5.1.jar:/pulsar/lib/org.apache.pulsar-pulsar-functions-secrets-2.5.0.jar:/pulsar/lib/io.netty-netty-transport-4.1.43.Final.jar:/pulsar/lib/io.grpc-grpc-core-1.18.0.jar:/pulsar/lib/com.google.j2objc-j2objc-annotations-1.1.jar:/pulsar/lib/org.apache.bookkeeper-cpu-affinity-4.10.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-client-tools-2.5.0.jar:/pulsar/lib/org.apache.bookkeeper-statelib-4.10.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-broker-2.5.0.jar:/pulsar/lib/org.eclipse.jetty-jetty-xml-9.4.20.v20190813.jar:/pulsar/lib/org.glassfish.hk2.external-aopalliance-repackaged-2.5.0-b42.jar:/pulsar/lib/org.glassfish.jersey.media-jersey-media-jaxb-2.27.jar:/pulsar/lib/org.xerial.snappy-snappy-java-1.1.1.3.jar:/pulsar/lib/javax.annotation-javax.annotation-api-1.2.jar:/pulsar/lib/org.yaml-snakeyaml-1.24.jar:/pulsar/lib/org.apache.pulsar-pulsar-transaction-coordinator-2.5.0.jar:/pulsar/lib/org.aspectj-aspectjweaver-1.9.2.jar:/pulsar/lib/org.apache.pulsar-protobuf-shaded-2.1.0-incubating.jar:/pulsar/lib/org.eclipse.jetty-jetty-proxy-9.4.20.v20190813.jar:/pulsar/lib/io.grpc-grpc-okhttp-1.18.0.jar:/pulsar/lib/io.grpc-grpc-protobuf-1.18.0.jar:/pulsar/lib/org.apache.bookkeeper.http-http-server-4.10.0.jar:/pulsar/lib/org.apache.logging.log4j-log4j-slf4j-impl-2.10.0.jar:/pulsar/lib/com.google.api.grpc-proto-google-common-protos-1.12.0.jar:/pulsar/lib/org.apache.bookkeeper-bookkeeper-common-4.10.0.jar:/pulsar/lib/jakarta.xml.bind-jakarta.xml.bind-api-2.3.2.jar:/pulsar/lib/org.codehaus.jackson-jackson-core-asl-1.9.13.jar:/pulsar/lib/org.apache.pulsar-pulsar-testclient-2.5.0.jar:/pulsar/lib/io.netty-netty-resolver-4.1.43.Final.jar:/pulsar/lib/org.eclipse.jetty-jetty-servlet-9.4.20.v20190813.jar:/pulsar/lib/javax.websocket-javax.websocket-client-api-1.0.jar:/pulsar/lib/io.netty-netty-handler-proxy-4.1.43.Final.jar:/pulsar/lib/com.yahoo.datasketches-memory-0.8.3.jar:/pulsar/lib/org.eclipse.jetty.websocket-websocket-api-9.4.20.v20190813.jar:/pulsar/lib/javax.xml.bind-jaxb-api-2.3.1.jar:/pulsar/lib/org.reactivestreams-reactive-streams-1.0.2.jar:/pulsar/lib/io.swagger-swagger-core-1.5.21.jar:/pulsar/lib/org.apache.httpcomponents-httpcore-4.4.9.jar:/pulsar/lib/org.apache.commons-commons-lang3-3.4.jar:/pulsar/lib/org.bouncycastle-bcprov-ext-jdk15on-1.60.jar:/pulsar/lib/log4j-log4j-1.2.17.jar:/pulsar/lib/commons-codec-commons-codec-1.10.jar:/pulsar/lib/io.netty-netty-handler-4.1.43.Final.jar:/pulsar/lib/org.eclipse.jetty-jetty-client-9.4.20.v20190813.jar:/pulsar/lib/io.netty-netty-common-4.1.43.Final.jar:/pulsar/lib/org.tukaani-xz-1.5.jar:/pulsar/lib/com.fasterxml.jackson.core-jackson-core-2.10.1.jar:/pulsar/lib/org.apache.bookkeeper.http-vertx-http-server-4.10.0.jar:/pulsar/lib/org.glassfish.hk2-hk2-api-2.5.0-b42.jar:/pulsar/lib/org.apache.pulsar-pulsar-common-2.5.0.jar:/pulsar/lib/org.glassfish.jersey.core-jersey-client-2.27.jar:/pulsar/lib/org.checkerframework-checker-qual-2.0.0.jar:/pulsar/lib/io.netty-netty-transport-native-unix-common-4.1.43.Final.jar:/pulsar/lib/io.prometheus-simpleclient_servlet-0.5.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-broker-common-2.5.0.jar:/pulsar/lib/com.fasterxml.jackson.module-jackson-module-jaxb-annotations-2.10.1.jar:/pulsar/lib/org.checkerframework-checker-compat-qual-2.5.2.jar:/pulsar/lib/com.sun.activation-javax.activation-1.2.0.jar:/pulsar/lib/org.glassfish.jersey.containers-jersey-container-servlet-2.27.jar:/pulsar/lib/org.apache.pulsar-pulsar-transaction-common-2.5.0.jar:/pulsar/lib/org.apache.bookkeeper-stream-storage-proto-4.10.0.jar:/pulsar/lib/io.netty-netty-buffer-4.1.43.Final.jar:/pulsar/lib/io.netty-netty-transport-native-epoll-4.1.43.Final.jar:/pulsar/lib/org.apache.zookeeper-zookeeper-jute-3.5.6.jar:/pulsar/lib/commons-lang-commons-lang-2.6.jar:/pulsar/lib/org.apache.bookkeeper-bookkeeper-tools-framework-4.10.0.jar:/pulsar/lib/io.vertx-vertx-auth-common-3.4.1.jar:/pulsar/lib/org.slf4j-jul-to-slf4j-1.7.25.jar:/pulsar/lib/org.apache.pulsar-pulsar-broker-auth-sasl-2.5.0.jar:/pulsar/lib/net.jcip-jcip-annotations-1.0.jar:/pulsar/lib/com.squareup.okhttp-logging-interceptor-2.7.5.jar:/pulsar/lib/org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:/pulsar/lib/io.netty-netty-resolver-dns-4.1.43.Final.jar:/pulsar/lib/com.beust-jcommander-1.48.jar:/pulsar/lib/org.bouncycastle-bcpkix-jdk15on-1.60.jar:/pulsar/lib/com.squareup.okhttp-okhttp-2.5.0.jar:/pulsar/lib/io.opencensus-opencensus-contrib-grpc-metrics-0.18.0.jar:/pulsar/lib/org.apache.commons-commons-collections4-4.1.jar:/pulsar/lib/org.apache.pulsar-pulsar-zookeeper-utils-2.5.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-functions-api-2.5.0.jar:/pulsar/lib/io.kubernetes-client-java-proto-2.0.0.jar:/pulsar/lib/org.apache.curator-curator-client-4.0.1.jar:/pulsar/lib/com.fasterxml.jackson.core-jackson-annotations-2.10.1.jar:/pulsar/lib/org.apache.distributedlog-distributedlog-core-4.10.0-tests.jar:/pulsar/lib/com.google.protobuf.nano-protobuf-javanano-3.0.0-alpha-5.jar:/pulsar/lib/org.apache.pulsar-pulsar-client-admin-original-2.5.0.jar:/pulsar/lib/com.carrotsearch-hppc-0.7.3.jar:/pulsar/lib/org.apache.bookkeeper-stream-storage-api-4.10.0.jar:/pulsar/lib/com.google.guava-guava-25.1-jre.jar:/pulsar/lib/io.jsonwebtoken-jjwt-api-0.10.5.jar:/pulsar/lib/org.slf4j-jcl-over-slf4j-1.7.25.jar:/pulsar/lib/com.squareup.okhttp-okhttp-ws-2.7.5.jar:/pulsar/lib/io.dropwizard.metrics-metrics-jvm-3.1.0.jar:/pulsar/lib/org.codehaus.mojo-animal-sniffer-annotations-1.14.jar:/pulsar/lib/org.apache.bookkeeper-stream-storage-service-api-4.10.0.jar:/pulsar/lib/io.swagger-swagger-models-1.5.21.jar:/pulsar/lib/org.apache.pulsar-managed-ledger-2.5.0.jar:/pulsar/lib/org.apache.bookkeeper-circe-checksum-4.10.0.jar:/pulsar/lib/com.fasterxml.jackson.dataformat-jackson-dataformat-yaml-2.10.1.jar:/pulsar/lib/commons-cli-commons-cli-1.2.jar:/pulsar/lib/org.asynchttpclient-async-http-client-netty-utils-2.7.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-client-api-2.5.0.jar:/pulsar/lib/org.glassfish.jersey.ext-jersey-entity-filtering-2.27.jar:/pulsar/lib/joda-time-joda-time-2.10.1.jar:/pulsar/lib/commons-logging-commons-logging-1.1.1.jar:/pulsar/lib/io.prometheus-simpleclient-0.5.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-websocket-2.5.0.jar:/pulsar/lib/io.grpc-grpc-netty-1.18.0.jar:/pulsar/lib/org.glassfish.jersey.core-jersey-server-2.27.jar:/pulsar/lib/io.grpc-grpc-auth-1.18.0.jar:/pulsar/lib/com.fasterxml.jackson.jaxrs-jackson-jaxrs-json-provider-2.10.1.jar:/pulsar/lib/org.apache.pulsar-pulsar-functions-runtime-2.5.0.jar:/pulsar/lib/org.eclipse.jetty-jetty-continuation-9.4.20.v20190813.jar:/pulsar/lib/io.netty-netty-codec-http-4.1.43.Final.jar:/pulsar/lib/org.eclipse.jetty-jetty-util-9.4.20.v20190813.jar:/pulsar/lib/org.apache.distributedlog-distributedlog-common-4.10.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-functions-instance-2.5.0.jar:/pulsar/lib/io.netty-netty-codec-http2-4.1.43.Final.jar:/pulsar/lib/jakarta.activation-jakarta.activation-api-1.2.1.jar:/pulsar/lib/net.jodah-typetools-0.5.0.jar:/pulsar/lib/net.java.dev.jna-jna-4.2.0.jar:/pulsar/lib/org.apache.commons-commons-compress-1.19.jar:/pulsar/lib/org.rocksdb-rocksdbjni-5.13.3.jar:/pulsar/lib/io.grpc-grpc-protobuf-nano-1.18.0.jar:/pulsar/lib/com.google.code.findbugs-jsr305-3.0.2.jar:/pulsar/lib/io.prometheus-simpleclient_httpserver-0.5.0.jar:/pulsar/lib/io.prometheus-simpleclient_jetty-0.5.0.jar:/pulsar/lib/commons-collections-commons-collections-3.2.2.jar:/pulsar/lib/io.prometheus-simpleclient_log4j2-0.5.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-functions-local-runner-original-2.5.0.jar:/pulsar/lib/org.apache.yetus-audience-annotations-0.5.0.jar:/pulsar/lib/io.prometheus-simpleclient_common-0.5.0.jar:/pulsar/lib/org.eclipse.jetty-jetty-security-9.4.20.v20190813.jar:/pulsar/lib/org.glassfish.jersey.media-jersey-media-json-jackson-2.27.jar:/pulsar/lib/io.dropwizard.metrics-metrics-graphite-3.1.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-functions-utils-2.5.0.jar:/pulsar/lib/org.inferred-freebuilder-1.14.9.jar:/pulsar/lib/org.apache.logging.log4j-log4j-core-2.10.0.jar:/pulsar/lib/org.jctools-jctools-core-2.1.2.jar:/pulsar/lib/io.prometheus.jmx-collector-0.12.0.jar:/pulsar/lib/org.apache.bookkeeper-stream-storage-common-4.10.0.jar:/pulsar/lib/io.dropwizard.metrics-metrics-core-3.1.0.jar:/pulsar/lib/org.glassfish.hk2-hk2-locator-2.5.0-b42.jar:/pulsar/lib/org.glassfish.hk2.external-javax.inject-2.5.0-b42.jar:/pulsar/lib/org.apache.pulsar-pulsar-proxy-2.5.0.jar:/pulsar/lib/com.squareup.okio-okio-1.13.0.jar:/pulsar/lib/org.eclipse.jetty.websocket-websocket-client-9.4.20.v20190813.jar:/pulsar/lib/org.apache.curator-curator-framework-4.0.1.jar:/pulsar/lib/org.lz4-lz4-java-1.5.0.jar:/pulsar/lib/org.apache.bookkeeper.stats-prometheus-metrics-provider-4.10.0.jar:/pulsar/lib/org.eclipse.jetty.websocket-javax-websocket-client-impl-9.4.20.v20190813.jar:/pulsar/lib/org.eclipse.jetty-jetty-http-9.4.20.v20190813.jar:/pulsar/lib/org.apache.bookkeeper-bookkeeper-common-allocator-4.10.0.jar:/pulsar/lib/commons-io-commons-io-2.5.jar:/pulsar/lib/com.google.protobuf-protobuf-java-util-3.5.1.jar:/pulsar/lib/org.hamcrest-hamcrest-core-1.3.jar:/pulsar/lib/org.apache.pulsar-pulsar-functions-api-examples-2.5.0.jar:/pulsar/lib/org.apache.bookkeeper-stream-storage-server-4.10.0.jar:/pulsar/lib/org.apache.bookkeeper-bookkeeper-proto-4.10.0.jar:/pulsar/lib/com.github.ben-manes.caffeine-caffeine-2.6.2.jar:/pulsar/lib/io.jsonwebtoken-jjwt-jackson-0.10.5.jar:/pulsar/lib/javax.inject-javax.inject-1.jar:/pulsar/lib/org.apache.httpcomponents-httpclient-4.5.5.jar:/pulsar/lib/org.apache.bookkeeper-stream-storage-java-client-base-4.10.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-zookeeper-2.5.0.jar:/pulsar/lib/io.vertx-vertx-core-3.4.1.jar:/pulsar/lib/io.kubernetes-client-java-2.0.0.jar:/pulsar/lib/org.hdrhistogram-HdrHistogram-2.1.9.jar:/pulsar/lib/org.glassfish.jersey.containers-jersey-container-servlet-core-2.27.jar:/pulsar/lib/org.apache.curator-curator-recipes-4.0.1.jar:/pulsar/lib/javax.ws.rs-javax.ws.rs-api-2.1.jar:/pulsar/lib/org.eclipse.jetty-jetty-servlets-9.4.20.v20190813.jar:/pulsar/lib/org.glassfish.jersey.inject-jersey-hk2-2.27.jar:/pulsar/lib/com.google.auth-google-auth-library-credentials-0.9.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-functions-proto-2.5.0.jar:/pulsar/lib/com.fasterxml.jackson.jaxrs-jackson-jaxrs-base-2.10.1.jar:/pulsar/lib/org.apache.bookkeeper-stream-storage-service-impl-4.10.0.jar:/pulsar/lib/com.github.luben-zstd-jni-1.3.7-3.jar:/pulsar/lib/io.netty-netty-tcnative-boringssl-static-2.0.26.Final.jar:/pulsar/lib/javax.servlet-javax.servlet-api-3.1.0.jar:/pulsar/lib/io.opencensus-opencensus-api-0.18.0.jar:/pulsar/lib/org.apache.bookkeeper-bookkeeper-server-4.10.0.jar:/pulsar/lib/io.grpc-grpc-stub-1.18.0.jar:/pulsar/lib/org.apache.logging.log4j-log4j-web-2.10.0.jar:/pulsar/lib/com.thoughtworks.paranamer-paranamer-2.7.jar:/pulsar/lib/org.eclipse.jetty.websocket-websocket-servlet-9.4.20.v20190813.jar:/pulsar/lib/org.apache.bookkeeper.stats-codahale-metrics-provider-4.10.0.jar:/pulsar/lib/io.grpc-grpc-context-1.18.0.jar:/pulsar/lib/org.eclipse.jetty-jetty-server-9.4.20.v20190813.jar:/pulsar/lib/io.vertx-vertx-web-3.4.1.jar:/pulsar/lib/com.fasterxml.jackson.core-jackson-databind-2.10.1.jar:/pulsar/lib/org.apache.pulsar-pulsar-discovery-service-2.5.0.jar:/pulsar/lib/com.yahoo.datasketches-sketches-core-0.8.3.jar:/pulsar/lib/org.eclipse.jetty-jetty-io-9.4.20.v20190813.jar:/pulsar/lib/javax.validation-validation-api-1.1.0.Final.jar:/pulsar/lib/org.codehaus.jackson-jackson-mapper-asl-1.9.13.jar:/pulsar/lib/org.apache.bookkeeper.tests-stream-storage-tests-common-4.10.0.jar:/pulsar/lib/org.javassist-javassist-3.25.0-GA.jar:/pulsar/lib/org.apache.pulsar-pulsar-io-core-2.5.0.jar:/pulsar/lib/org.apache.avro-avro-1.8.2.jar:/pulsar/lib/io.kubernetes-client-java-api-2.0.0.jar:/pulsar/lib/org.apache.avro-avro-protobuf-1.8.2.jar:/pulsar/lib/org.eclipse.jetty.websocket-websocket-common-9.4.20.v20190813.jar:/pulsar/lib/org.apache.distributedlog-distributedlog-protocol-4.10.0.jar:/pulsar/lib/org.apache.bookkeeper.stats-bookkeeper-stats-api-4.10.0.jar:/pulsar/lib/org.apache.pulsar-pulsar-client-auth-sasl-2.5.0.jar:/pulsar/lib/com.fasterxml.jackson.module-jackson-module-jsonSchema-2.10.1.jar:/pulsar/lib/com.google.code.gson-gson-2.8.2.jar:/pulsar/lib/io.grpc-grpc-all-1.18.0.jar:/pulsar/lib/org.jvnet.mimepull-mimepull-1.9.6.jar:/pulsar/lib/io.prometheus-simpleclient_caffeine-0.5.0.jar:/pulsar/lib/org.bouncycastle-bcprov-jdk15on-1.60.jar:/pulsar/lib/org.aspectj-aspectjrt-1.9.2.jar:/pulsar/lib/io.netty-netty-codec-dns-4.1.43.Final.jar:/pulsar/lib/org.glassfish.jersey.media-jersey-media-multipart-2.27.jar:/pulsar/lib/org.apache.logging.log4j-log4j-api-2.10.0.jar:/pulsar/lib/com.google.errorprone-error_prone_annotations-2.1.3.jar:/pulsar/lib/org.apache.distributedlog-distributedlog-core-4.10.0.jar:/pulsar/lib/org.slf4j-slf4j-api-1.7.25.jar:/pulsar/lib/io.netty-netty-codec-socks-4.1.43.Final.jar:/pulsar/lib/io.netty-netty-codec-4.1.43.Final.jar:/pulsar/lib/org.glassfish.hk2-osgi-resource-locator-1.0.1.jar:/pulsar/lib/commons-configuration-commons-configuration-1.10.jar:/pulsar/lib/com.github.zafarkhaja-java-semver-0.9.0.jar:/pulsar/lib/io.grpc-grpc-protobuf-lite-1.18.0.jar:/pulsar/lib/org.apache.bookkeeper-stream-storage-java-client-4.10.0.jar:
1912:43:55.019 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.library.path=/usr/java/packages/lib/amd64:/usr/lib64:/lib64:/lib:/usr/lib
2012:43:55.019 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.io.tmpdir=/tmp
2112:43:55.019 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:java.compiler=<NA>
2212:43:55.019 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.name=Linux
2312:43:55.019 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.arch=amd64
2412:43:55.019 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.version=4.19.88
2512:43:55.019 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.name=root
2612:43:55.019 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.home=/root
2712:43:55.019 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:user.dir=/pulsar
2812:43:55.020 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.free=141MB
2912:43:55.020 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.max=256MB
3012:43:55.020 [main] INFO org.apache.zookeeper.ZooKeeper - Client environment:os.memory.total=192MB
3112:43:55.023 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=pulsar-zookeeper-0.pulsar-zookeeper sessionTimeout=30000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@455824ad
3212:43:55.029 [main] INFO org.apache.zookeeper.common.X509Util - Setting -D jdk.tls.rejectClientInitiatedRenegotiation=true to disable client-initiated TLS renegotiation
3312:43:55.032 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes
3412:43:55.038 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=
3512:43:55.063 [main-SendThread(pulsar-zookeeper-0.pulsar-zookeeper:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server pulsar-zookeeper-0.pulsar-zookeeper/172.17.0.8:2181. Will not attempt to authenticate using SASL (unknown error)
3612:43:55.064 [main-SendThread(pulsar-zookeeper-0.pulsar-zookeeper:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /172.17.0.7:45652, server: pulsar-zookeeper-0.pulsar-zookeeper/172.17.0.8:2181
3712:43:55.073 [main-SendThread(pulsar-zookeeper-0.pulsar-zookeeper:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server pulsar-zookeeper-0.pulsar-zookeeper/172.17.0.8:2181, sessionid = 0x1002ce2a23e001b, negotiated timeout = 30000
3812:43:55.076 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now.
3912:43:55.103 [main] INFO org.apache.distributedlog.ZooKeeperClient - Close zookeeper client default.
4012:43:55.103 [main] INFO org.apache.distributedlog.ZooKeeperClient - Closing zookeeper client default.
4112:43:55.210 [main] INFO org.apache.zookeeper.ZooKeeper - Session: 0x1002ce2a23e001b closed
4212:43:55.210 [main-EventThread] INFO org.apache.zookeeper.ClientCnxn - EventThread shut down for session: 0x1002ce2a23e001b
4312:43:55.211 [main] INFO org.apache.distributedlog.ZooKeeperClient - Closed zookeeper client default.
4412:43:55.224 [main] INFO org.apache.pulsar.broker.authentication.AuthenticationService - Authentication is disabled
4512:43:55.225 [main] INFO org.apache.pulsar.functions.worker.WorkerService - Starting worker pulsar-function-0...
4612:43:55.257 [main] INFO org.apache.pulsar.functions.worker.WorkerService - Worker Configs: {
47 "workerId" : "pulsar-function-0",
48 "workerHostname" : "pulsar-function-0.pulsar-function",
49 "workerPort" : 6750,
50 "workerPortTls" : null,
51 "jvmGCMetricsLoggerClassName" : null,
52 "numHttpServerThreads" : 8,
53 "configurationStoreServers" : "pulsar-zookeeper-0.pulsar-zookeeper",
54 "zooKeeperSessionTimeoutMillis" : 30000,
55 "zooKeeperOperationTimeoutSeconds" : 30,
56 "connectorsDirectory" : "./connectors",
57 "functionMetadataTopicName" : "metadata",
58 "functionWebServiceUrl" : null,
59 "pulsarServiceUrl" : "pulsar://pulsar-broker:6650",
60 "pulsarWebServiceUrl" : "http://pulsar-broker:8080",
61 "clusterCoordinationTopicName" : "coordinate",
62 "pulsarFunctionsNamespace" : "public/functions",
63 "pulsarFunctionsCluster" : "pulsar",
64 "numFunctionPackageReplicas" : 1,
65 "downloadDirectory" : "/tmp/pulsar_functions",
66 "stateStorageServiceUrl" : "bk://pulsar-bookkeeper:4181",
67 "functionAssignmentTopicName" : "assignments",
68 "schedulerClassName" : "org.apache.pulsar.functions.worker.scheduler.RoundRobinScheduler",
69 "failureCheckFreqMs" : 30000,
70 "rescheduleTimeoutMs" : 60000,
71 "initialBrokerReconnectMaxRetries" : 60,
72 "assignmentWriteMaxRetries" : 60,
73 "instanceLivenessCheckFreqMs" : 30000,
74 "clientAuthenticationPlugin" : null,
75 "clientAuthenticationParameters" : null,
76 "bookkeeperClientAuthenticationPlugin" : null,
77 "bookkeeperClientAuthenticationParametersName" : null,
78 "bookkeeperClientAuthenticationParameters" : null,
79 "topicCompactionFrequencySec" : 1800,
80 "tlsEnabled" : false,
81 "tlsCertificateFilePath" : null,
82 "tlsKeyFilePath" : null,
83 "tlsTrustCertsFilePath" : "",
84 "tlsAllowInsecureConnection" : false,
85 "tlsRequireTrustedClientCertOnConnect" : false,
86 "useTls" : false,
87 "tlsHostnameVerificationEnable" : false,
88 "tlsCertRefreshCheckDurationSec" : 300,
89 "authenticationEnabled" : false,
90 "authenticationProviders" : [ ],
91 "authorizationEnabled" : false,
92 "authorizationProvider" : "org.apache.pulsar.broker.authorization.PulsarAuthorizationProvider",
93 "superUserRoles" : [ ],
94 "properties" : { },
95 "functionRuntimeFactoryClassName" : null,
96 "functionRuntimeFactoryConfigs" : null,
97 "secretsProviderConfiguratorClassName" : null,
98 "secretsProviderConfiguratorConfig" : null,
99 "functionInstanceMinResources" : null,
100 "functionAuthProviderClassName" : null,
101 "runtimeCustomizerClassName" : null,
102 "runtimeCustomizerConfig" : { },
103 "threadContainerFactory" : null,
104 "processContainerFactory" : {
105 "javaInstanceJarLocation" : null,
106 "pythonInstanceLocation" : null,
107 "logDirectory" : null,
108 "extraFunctionDependenciesDir" : null
109 },
110 "kubernetesContainerFactory" : null,
111 "functionMetadataTopic" : "persistent://public/functions/metadata",
112 "clusterCoordinationTopic" : "persistent://public/functions/coordinate",
113 "functionAssignmentTopic" : "persistent://public/functions/assignments",
114 "tlsTrustChainBytes" : null,
115 "workerWebAddress" : "http://pulsar-function-0.pulsar-function:6750"
116}
11712:43:55.275 [main] INFO org.apache.distributedlog.api.namespace.NamespaceBuilder - No feature provider is set. All features are disabled now.
11812:43:55.286 [main] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Created shared zooKeeper client builder dlzk:distributedlog://pulsar-zookeeper-0.pulsar-zookeeper/pulsar/functions:factory_writer_shared: zkServers = pulsar-zookeeper-0.pulsar-zookeeper, numRetries = 3, sessionTimeout = 30000, retryBackoff = 5000, maxRetryBackoff = 30000, zkAclId = null.
11912:43:55.290 [main] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=pulsar-zookeeper-0.pulsar-zookeeper sessionTimeout=30000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@575d48db
12012:43:55.291 [main] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes
12112:43:55.291 [main] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=
12212:43:55.297 [main-SendThread(pulsar-zookeeper-0.pulsar-zookeeper:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server pulsar-zookeeper-0.pulsar-zookeeper/172.17.0.8:2181. Will not attempt to authenticate using SASL (unknown error)
12312:43:55.297 [main-SendThread(pulsar-zookeeper-0.pulsar-zookeeper:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /172.17.0.7:45654, server: pulsar-zookeeper-0.pulsar-zookeeper/172.17.0.8:2181
12412:43:55.303 [main-SendThread(pulsar-zookeeper-0.pulsar-zookeeper:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server pulsar-zookeeper-0.pulsar-zookeeper/172.17.0.8:2181, sessionid = 0x1002ce2a23e001c, negotiated timeout = 30000
12512:43:55.304 [main-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now.
12612:43:55.322 [main] WARN org.apache.distributedlog.impl.BKNamespaceDriver - Could not use Netty Epoll event loop for bookie server:
127java.lang.UnsatisfiedLinkError: failed to load the required native library
128 at io.netty.channel.epoll.Epoll.ensureAvailability(Epoll.java:80) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
129 at io.netty.channel.epoll.EpollEventLoop.<clinit>(EpollEventLoop.java:52) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
130 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:142) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
131 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:35) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
132 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:84) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
133 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:58) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
134 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:47) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
135 at io.netty.channel.MultithreadEventLoopGroup.<init>(MultithreadEventLoopGroup.java:59) ~[io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
136 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:104) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
137 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:91) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
138 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:68) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
139 at org.apache.distributedlog.impl.BKNamespaceDriver.getDefaultEventLoopGroup(BKNamespaceDriver.java:257) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
140 at org.apache.distributedlog.impl.BKNamespaceDriver.initializeBookKeeperClients(BKNamespaceDriver.java:268) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
141 at org.apache.distributedlog.impl.BKNamespaceDriver.initialize(BKNamespaceDriver.java:206) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
142 at org.apache.distributedlog.api.namespace.NamespaceBuilder.build(NamespaceBuilder.java:239) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
143 at org.apache.pulsar.functions.worker.WorkerService.start(WorkerService.java:105) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
144 at org.apache.pulsar.functions.worker.Worker.start(Worker.java:69) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
145 at org.apache.pulsar.functions.worker.FunctionWorkerStarter.main(FunctionWorkerStarter.java:67) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
146Caused by: java.lang.UnsatisfiedLinkError: could not load a native library: netty_transport_native_epoll_x86_64
147 at io.netty.util.internal.NativeLibraryLoader.load(NativeLibraryLoader.java:224) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
148 at io.netty.channel.epoll.Native.loadNativeLibrary(Native.java:228) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
149 at io.netty.channel.epoll.Native.<clinit>(Native.java:57) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
150 at io.netty.channel.epoll.Epoll.<clinit>(Epoll.java:39) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
151 ... 17 more
152 Suppressed: java.lang.UnsatisfiedLinkError: could not load a native library: netty_transport_native_epoll
153 at io.netty.util.internal.NativeLibraryLoader.load(NativeLibraryLoader.java:224) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
154 at io.netty.channel.epoll.Native.loadNativeLibrary(Native.java:231) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
155 at io.netty.channel.epoll.Native.<clinit>(Native.java:57) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
156 at io.netty.channel.epoll.Epoll.<clinit>(Epoll.java:39) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
157 at io.netty.channel.epoll.EpollEventLoop.<clinit>(EpollEventLoop.java:52) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
158 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:142) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
159 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:35) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
160 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:84) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
161 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:58) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
162 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:47) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
163 at io.netty.channel.MultithreadEventLoopGroup.<init>(MultithreadEventLoopGroup.java:59) ~[io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
164 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:104) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
165 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:91) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
166 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:68) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
167 at org.apache.distributedlog.impl.BKNamespaceDriver.getDefaultEventLoopGroup(BKNamespaceDriver.java:257) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
168 at org.apache.distributedlog.impl.BKNamespaceDriver.initializeBookKeeperClients(BKNamespaceDriver.java:268) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
169 at org.apache.distributedlog.impl.BKNamespaceDriver.initialize(BKNamespaceDriver.java:206) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
170 at org.apache.distributedlog.api.namespace.NamespaceBuilder.build(NamespaceBuilder.java:239) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
171 at org.apache.pulsar.functions.worker.WorkerService.start(WorkerService.java:105) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
172 at org.apache.pulsar.functions.worker.Worker.start(Worker.java:69) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
173 at org.apache.pulsar.functions.worker.FunctionWorkerStarter.main(FunctionWorkerStarter.java:67) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
174 Caused by: java.io.FileNotFoundException: META-INF/native/libnetty_transport_native_epoll.so
175 at io.netty.util.internal.NativeLibraryLoader.load(NativeLibraryLoader.java:173) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
176 ... 20 more
177 Suppressed: java.lang.UnsatisfiedLinkError: no netty_transport_native_epoll in java.library.path
178 at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1860) ~[?:1.8.0_232]
179 at java.lang.Runtime.loadLibrary0(Runtime.java:870) ~[?:1.8.0_232]
180 at java.lang.System.loadLibrary(System.java:1122) ~[?:1.8.0_232]
181 at io.netty.util.internal.NativeLibraryUtil.loadLibrary(NativeLibraryUtil.java:38) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
182 at io.netty.util.internal.NativeLibraryLoader.loadLibrary(NativeLibraryLoader.java:349) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
183 at io.netty.util.internal.NativeLibraryLoader.load(NativeLibraryLoader.java:136) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
184 at io.netty.channel.epoll.Native.loadNativeLibrary(Native.java:231) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
185 at io.netty.channel.epoll.Native.<clinit>(Native.java:57) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
186 at io.netty.channel.epoll.Epoll.<clinit>(Epoll.java:39) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
187 at io.netty.channel.epoll.EpollEventLoop.<clinit>(EpollEventLoop.java:52) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
188 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:142) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
189 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:35) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
190 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:84) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
191 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:58) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
192 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:47) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
193 at io.netty.channel.MultithreadEventLoopGroup.<init>(MultithreadEventLoopGroup.java:59) ~[io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
194 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:104) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
195 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:91) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
196 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:68) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
197 at org.apache.distributedlog.impl.BKNamespaceDriver.getDefaultEventLoopGroup(BKNamespaceDriver.java:257) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
198 at org.apache.distributedlog.impl.BKNamespaceDriver.initializeBookKeeperClients(BKNamespaceDriver.java:268) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
199 at org.apache.distributedlog.impl.BKNamespaceDriver.initialize(BKNamespaceDriver.java:206) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
200 at org.apache.distributedlog.api.namespace.NamespaceBuilder.build(NamespaceBuilder.java:239) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
201 at org.apache.pulsar.functions.worker.WorkerService.start(WorkerService.java:105) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
202 at org.apache.pulsar.functions.worker.Worker.start(Worker.java:69) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
203 at org.apache.pulsar.functions.worker.FunctionWorkerStarter.main(FunctionWorkerStarter.java:67) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
204 Suppressed: java.lang.UnsatisfiedLinkError: no netty_transport_native_epoll in java.library.path
205 at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1860) ~[?:1.8.0_232]
206 at java.lang.Runtime.loadLibrary0(Runtime.java:870) ~[?:1.8.0_232]
207 at java.lang.System.loadLibrary(System.java:1122) ~[?:1.8.0_232]
208 at io.netty.util.internal.NativeLibraryUtil.loadLibrary(NativeLibraryUtil.java:38) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
209 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_232]
210 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_232]
211 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_232]
212 at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_232]
213 at io.netty.util.internal.NativeLibraryLoader$1.run(NativeLibraryLoader.java:369) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
214 at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_232]
215 at io.netty.util.internal.NativeLibraryLoader.loadLibraryByHelper(NativeLibraryLoader.java:361) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
216 at io.netty.util.internal.NativeLibraryLoader.loadLibrary(NativeLibraryLoader.java:339) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
217 at io.netty.util.internal.NativeLibraryLoader.load(NativeLibraryLoader.java:136) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
218 at io.netty.channel.epoll.Native.loadNativeLibrary(Native.java:231) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
219 at io.netty.channel.epoll.Native.<clinit>(Native.java:57) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
220 at io.netty.channel.epoll.Epoll.<clinit>(Epoll.java:39) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
221 at io.netty.channel.epoll.EpollEventLoop.<clinit>(EpollEventLoop.java:52) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
222 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:142) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
223 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:35) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
224 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:84) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
225 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:58) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
226 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:47) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
227 at io.netty.channel.MultithreadEventLoopGroup.<init>(MultithreadEventLoopGroup.java:59) ~[io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
228 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:104) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
229 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:91) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
230 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:68) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
231 at org.apache.distributedlog.impl.BKNamespaceDriver.getDefaultEventLoopGroup(BKNamespaceDriver.java:257) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
232 at org.apache.distributedlog.impl.BKNamespaceDriver.initializeBookKeeperClients(BKNamespaceDriver.java:268) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
233 at org.apache.distributedlog.impl.BKNamespaceDriver.initialize(BKNamespaceDriver.java:206) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
234 at org.apache.distributedlog.api.namespace.NamespaceBuilder.build(NamespaceBuilder.java:239) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
235 at org.apache.pulsar.functions.worker.WorkerService.start(WorkerService.java:105) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
236 at org.apache.pulsar.functions.worker.Worker.start(Worker.java:69) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
237 at org.apache.pulsar.functions.worker.FunctionWorkerStarter.main(FunctionWorkerStarter.java:67) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
238Caused by: java.io.FileNotFoundException: META-INF/native/libnetty_transport_native_epoll_x86_64.so
239 at io.netty.util.internal.NativeLibraryLoader.load(NativeLibraryLoader.java:173) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
240 at io.netty.channel.epoll.Native.loadNativeLibrary(Native.java:228) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
241 at io.netty.channel.epoll.Native.<clinit>(Native.java:57) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
242 at io.netty.channel.epoll.Epoll.<clinit>(Epoll.java:39) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
243 ... 17 more
244 Suppressed: java.lang.UnsatisfiedLinkError: no netty_transport_native_epoll_x86_64 in java.library.path
245 at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1860) ~[?:1.8.0_232]
246 at java.lang.Runtime.loadLibrary0(Runtime.java:870) ~[?:1.8.0_232]
247 at java.lang.System.loadLibrary(System.java:1122) ~[?:1.8.0_232]
248 at io.netty.util.internal.NativeLibraryUtil.loadLibrary(NativeLibraryUtil.java:38) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
249 at io.netty.util.internal.NativeLibraryLoader.loadLibrary(NativeLibraryLoader.java:349) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
250 at io.netty.util.internal.NativeLibraryLoader.load(NativeLibraryLoader.java:136) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
251 at io.netty.channel.epoll.Native.loadNativeLibrary(Native.java:228) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
252 at io.netty.channel.epoll.Native.<clinit>(Native.java:57) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
253 at io.netty.channel.epoll.Epoll.<clinit>(Epoll.java:39) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
254 at io.netty.channel.epoll.EpollEventLoop.<clinit>(EpollEventLoop.java:52) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
255 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:142) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
256 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:35) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
257 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:84) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
258 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:58) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
259 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:47) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
260 at io.netty.channel.MultithreadEventLoopGroup.<init>(MultithreadEventLoopGroup.java:59) ~[io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
261 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:104) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
262 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:91) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
263 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:68) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
264 at org.apache.distributedlog.impl.BKNamespaceDriver.getDefaultEventLoopGroup(BKNamespaceDriver.java:257) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
265 at org.apache.distributedlog.impl.BKNamespaceDriver.initializeBookKeeperClients(BKNamespaceDriver.java:268) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
266 at org.apache.distributedlog.impl.BKNamespaceDriver.initialize(BKNamespaceDriver.java:206) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
267 at org.apache.distributedlog.api.namespace.NamespaceBuilder.build(NamespaceBuilder.java:239) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
268 at org.apache.pulsar.functions.worker.WorkerService.start(WorkerService.java:105) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
269 at org.apache.pulsar.functions.worker.Worker.start(Worker.java:69) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
270 at org.apache.pulsar.functions.worker.FunctionWorkerStarter.main(FunctionWorkerStarter.java:67) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
271 Suppressed: java.lang.UnsatisfiedLinkError: no netty_transport_native_epoll_x86_64 in java.library.path
272 at java.lang.ClassLoader.loadLibrary(ClassLoader.java:1860) ~[?:1.8.0_232]
273 at java.lang.Runtime.loadLibrary0(Runtime.java:870) ~[?:1.8.0_232]
274 at java.lang.System.loadLibrary(System.java:1122) ~[?:1.8.0_232]
275 at io.netty.util.internal.NativeLibraryUtil.loadLibrary(NativeLibraryUtil.java:38) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
276 at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[?:1.8.0_232]
277 at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62) ~[?:1.8.0_232]
278 at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[?:1.8.0_232]
279 at java.lang.reflect.Method.invoke(Method.java:498) ~[?:1.8.0_232]
280 at io.netty.util.internal.NativeLibraryLoader$1.run(NativeLibraryLoader.java:369) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
281 at java.security.AccessController.doPrivileged(Native Method) ~[?:1.8.0_232]
282 at io.netty.util.internal.NativeLibraryLoader.loadLibraryByHelper(NativeLibraryLoader.java:361) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
283 at io.netty.util.internal.NativeLibraryLoader.loadLibrary(NativeLibraryLoader.java:339) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
284 at io.netty.util.internal.NativeLibraryLoader.load(NativeLibraryLoader.java:136) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
285 at io.netty.channel.epoll.Native.loadNativeLibrary(Native.java:228) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
286 at io.netty.channel.epoll.Native.<clinit>(Native.java:57) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
287 at io.netty.channel.epoll.Epoll.<clinit>(Epoll.java:39) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
288 at io.netty.channel.epoll.EpollEventLoop.<clinit>(EpollEventLoop.java:52) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
289 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:142) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
290 at io.netty.channel.epoll.EpollEventLoopGroup.newChild(EpollEventLoopGroup.java:35) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
291 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:84) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
292 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:58) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
293 at io.netty.util.concurrent.MultithreadEventExecutorGroup.<init>(MultithreadEventExecutorGroup.java:47) ~[io.netty-netty-common-4.1.43.Final.jar:4.1.43.Final]
294 at io.netty.channel.MultithreadEventLoopGroup.<init>(MultithreadEventLoopGroup.java:59) ~[io.netty-netty-transport-4.1.43.Final.jar:4.1.43.Final]
295 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:104) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
296 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:91) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
297 at io.netty.channel.epoll.EpollEventLoopGroup.<init>(EpollEventLoopGroup.java:68) ~[io.netty-netty-transport-native-epoll-4.1.43.Final.jar:4.1.43.Final]
298 at org.apache.distributedlog.impl.BKNamespaceDriver.getDefaultEventLoopGroup(BKNamespaceDriver.java:257) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
299 at org.apache.distributedlog.impl.BKNamespaceDriver.initializeBookKeeperClients(BKNamespaceDriver.java:268) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
300 at org.apache.distributedlog.impl.BKNamespaceDriver.initialize(BKNamespaceDriver.java:206) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
301 at org.apache.distributedlog.api.namespace.NamespaceBuilder.build(NamespaceBuilder.java:239) [org.apache.distributedlog-distributedlog-core-4.10.0.jar:4.10.0]
302 at org.apache.pulsar.functions.worker.WorkerService.start(WorkerService.java:105) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
303 at org.apache.pulsar.functions.worker.Worker.start(Worker.java:69) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
304 at org.apache.pulsar.functions.worker.FunctionWorkerStarter.main(FunctionWorkerStarter.java:67) [org.apache.pulsar-pulsar-functions-worker-2.5.0.jar:2.5.0]
30512:43:55.328 [main] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Created shared client builder bk:distributedlog://pulsar-zookeeper-0.pulsar-zookeeper/pulsar/functions:factory_writer_shared : zkServers = pulsar-zookeeper-0.pulsar-zookeeper, ledgersPath = /ledgers, numIOThreads = 1
30612:43:55.336 [main] INFO org.apache.distributedlog.impl.metadata.BKDLConfig - Propagate BKDLConfig to DLConfig : encodeRegionID = false, firstLogSegmentSequenceNumber = 1, createStreamIfNotExists = true, isFederated = false.
30712:43:55.348 [main] INFO org.apache.distributedlog.impl.BKNamespaceDriver - Initialized BK namespace driver: clientId = function-worker-pulsar-function-0, regionId = 0, federated = false.
30812:43:55.353 [main] INFO org.apache.distributedlog.logsegment.LogSegmentMetadataCache - Log segment cache is enabled = true
30912:43:57.146 [main] INFO org.apache.pulsar.functions.worker.WorkerService - Created Pulsar client
31012:43:57.416 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x1e581d24, L:/172.17.0.7:36962 - R:pulsar-broker.default.svc.cluster.local/10.101.70.38:6650]] Connected to server
31112:43:57.471 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {
312 "topicName" : "persistent://public/functions/assignments",
313 "producerName" : null,
314 "sendTimeoutMs" : 0,
315 "blockIfQueueFull" : true,
316 "maxPendingMessages" : 1000,
317 "maxPendingMessagesAcrossPartitions" : 50000,
318 "messageRoutingMode" : "RoundRobinPartition",
319 "hashingScheme" : "JavaStringHash",
320 "cryptoFailureAction" : "FAIL",
321 "batchingMaxPublishDelayMicros" : 1000,
322 "batchingPartitionSwitchFrequencyByPublishDelay" : 10,
323 "batchingMaxMessages" : 1000,
324 "batchingMaxBytes" : 131072,
325 "batchingEnabled" : false,
326 "compressionType" : "LZ4",
327 "initialSequenceId" : null,
328 "autoUpdatePartitions" : true,
329 "multiSchema" : true,
330 "properties" : { }
331}
33212:43:57.474 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {
333 "serviceUrl" : "pulsar://pulsar-broker:6650",
334 "authPluginClassName" : null,
335 "authParams" : null,
336 "operationTimeoutMs" : 30000,
337 "statsIntervalSeconds" : 60,
338 "numIoThreads" : 1,
339 "numListenerThreads" : 1,
340 "connectionsPerBroker" : 1,
341 "useTcpNoDelay" : true,
342 "useTls" : false,
343 "tlsTrustCertsFilePath" : "",
344 "tlsAllowInsecureConnection" : false,
345 "tlsHostnameVerificationEnable" : false,
346 "concurrentLookupRequest" : 5000,
347 "maxLookupRequest" : 50000,
348 "maxNumberOfRejectedRequestPerConnection" : 50,
349 "keepAliveIntervalSeconds" : 30,
350 "connectionTimeoutMs" : 10000,
351 "requestTimeoutMs" : 60000,
352 "initialBackoffIntervalNanos" : 100000000,
353 "maxBackoffIntervalNanos" : 60000000000
354}
35512:43:57.483 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xea2130aa, L:/172.17.0.7:33296 - R:/172.17.0.4:6650]] Connected to server
35612:43:57.485 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://public/functions/assignments] [null] Creating producer on cnx [id: 0xea2130aa, L:/172.17.0.7:33296 - R:/172.17.0.4:6650]
35712:43:57.496 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://public/functions/assignments] [pulsar-3-1182] Created producer on cnx [id: 0xea2130aa, L:/172.17.0.7:33296 - R:/172.17.0.4:6650]
35812:43:57.515 [main] INFO org.apache.pulsar.functions.utils.Actions - Sucessfully completed action [ Creating producer for assignment topic persistent://public/functions/assignments ]
35912:43:57.530 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Starting Pulsar producer perf with config: {
360 "topicName" : "persistent://public/functions/metadata",
361 "producerName" : null,
362 "sendTimeoutMs" : 30000,
363 "blockIfQueueFull" : false,
364 "maxPendingMessages" : 1000,
365 "maxPendingMessagesAcrossPartitions" : 50000,
366 "messageRoutingMode" : "RoundRobinPartition",
367 "hashingScheme" : "JavaStringHash",
368 "cryptoFailureAction" : "FAIL",
369 "batchingMaxPublishDelayMicros" : 1000,
370 "batchingPartitionSwitchFrequencyByPublishDelay" : 10,
371 "batchingMaxMessages" : 1000,
372 "batchingMaxBytes" : 131072,
373 "batchingEnabled" : true,
374 "compressionType" : "NONE",
375 "initialSequenceId" : null,
376 "autoUpdatePartitions" : true,
377 "multiSchema" : true,
378 "properties" : { }
379}
38012:43:57.532 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - Pulsar client config: {
381 "serviceUrl" : "pulsar://pulsar-broker:6650",
382 "authPluginClassName" : null,
383 "authParams" : null,
384 "operationTimeoutMs" : 30000,
385 "statsIntervalSeconds" : 60,
386 "numIoThreads" : 1,
387 "numListenerThreads" : 1,
388 "connectionsPerBroker" : 1,
389 "useTcpNoDelay" : true,
390 "useTls" : false,
391 "tlsTrustCertsFilePath" : "",
392 "tlsAllowInsecureConnection" : false,
393 "tlsHostnameVerificationEnable" : false,
394 "concurrentLookupRequest" : 5000,
395 "maxLookupRequest" : 50000,
396 "maxNumberOfRejectedRequestPerConnection" : 50,
397 "keepAliveIntervalSeconds" : 30,
398 "connectionTimeoutMs" : 10000,
399 "requestTimeoutMs" : 60000,
400 "initialBackoffIntervalNanos" : 100000000,
401 "maxBackoffIntervalNanos" : 60000000000
402}
40312:43:57.534 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://public/functions/metadata] [null] Creating producer on cnx [id: 0xea2130aa, L:/172.17.0.7:33296 - R:/172.17.0.4:6650]
40412:43:57.537 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ProducerImpl - [persistent://public/functions/metadata] [pulsar-3-1183] Created producer on cnx [id: 0xea2130aa, L:/172.17.0.7:33296 - R:/172.17.0.4:6650]
40512:43:57.539 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Searching for connectors in /pulsar/./connectors
40612:43:58.708 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=kinesis, description=Kinesis connectors, sourceClass=org.apache.pulsar.io.kinesis.KinesisSource, sinkClass=org.apache.pulsar.io.kinesis.KinesisSink) from /pulsar/./connectors/pulsar-io-kinesis-2.5.0.nar
40712:43:58.808 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=kafka, description=Kafka source and sink connector, sourceClass=org.apache.pulsar.io.kafka.KafkaBytesSource, sinkClass=org.apache.pulsar.io.kafka.KafkaBytesSink) from /pulsar/./connectors/pulsar-io-kafka-2.5.0.nar
40812:43:59.244 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=rabbitmq, description=RabbitMQ source and sink connector, sourceClass=org.apache.pulsar.io.rabbitmq.RabbitMQSource, sinkClass=org.apache.pulsar.io.rabbitmq.RabbitMQSink) from /pulsar/./connectors/pulsar-io-rabbitmq-2.5.0.nar
40912:43:59.314 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=mongo, description=MongoDB source and sink connector, sourceClass=org.apache.pulsar.io.mongodb.MongoSource, sinkClass=org.apache.pulsar.io.mongodb.MongoSink) from /pulsar/./connectors/pulsar-io-mongo-2.5.0.nar
41012:43:59.469 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=canal, description=canal source and read data from mysql, sourceClass=org.apache.pulsar.io.canal.CanalStringSource, sinkClass=null) from /pulsar/./connectors/pulsar-io-canal-2.5.0.nar
41112:43:59.911 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=influxdb, description=Writes data into InfluxDB database, sourceClass=null, sinkClass=org.apache.pulsar.io.influxdb.InfluxDBGenericRecordSink) from /pulsar/./connectors/pulsar-io-influxdb-2.5.0.nar
41212:44:00.389 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=solr, description=Writes data into solr collection, sourceClass=null, sinkClass=org.apache.pulsar.io.solr.SolrGenericRecordSink) from /pulsar/./connectors/pulsar-io-solr-2.5.0.nar
41312:44:00.591 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=elastic_search, description=Writes data into Elastic Search, sourceClass=null, sinkClass=org.apache.pulsar.io.elasticsearch.ElasticSearchSink) from /pulsar/./connectors/pulsar-io-elastic-search-2.5.0.nar
41412:44:01.074 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=jdbc, description=Jdbc sink, sourceClass=null, sinkClass=org.apache.pulsar.io.jdbc.JdbcAutoSchemaSink) from /pulsar/./connectors/pulsar-io-jdbc-2.5.0.nar
41512:44:01.303 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=flume, description=flume source and sink connector, sourceClass=org.apache.pulsar.io.flume.source.StringSource, sinkClass=org.apache.pulsar.io.flume.sink.StringSink) from /pulsar/./connectors/pulsar-io-flume-2.5.0.nar
41612:44:01.987 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=debezium-postgres, description=Debezium Postgres Source, sourceClass=org.apache.pulsar.io.debezium.postgres.DebeziumPostgresSource, sinkClass=null) from /pulsar/./connectors/pulsar-io-debezium-postgres-2.5.0.nar
41712:44:02.619 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=hdfs3, description=Writes data into HDFS 3.x, sourceClass=null, sinkClass=org.apache.pulsar.io.hdfs3.sink.text.HdfsStringSink) from /pulsar/./connectors/pulsar-io-hdfs3-2.5.0.nar
41812:44:03.494 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=hbase, description=Writes data into hbase table, sourceClass=null, sinkClass=org.apache.pulsar.io.hbase.sink.HbaseGenericRecordSink) from /pulsar/./connectors/pulsar-io-hbase-2.5.0.nar
41912:44:03.596 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=aerospike, description=Aerospike database sink, sourceClass=null, sinkClass=org.apache.pulsar.io.aerospike.AerospikeStringSink) from /pulsar/./connectors/pulsar-io-aerospike-2.5.0.nar
42012:44:03.672 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=twitter, description=Ingest data from Twitter firehose, sourceClass=org.apache.pulsar.io.twitter.TwitterFireHose, sinkClass=null) from /pulsar/./connectors/pulsar-io-twitter-2.5.0.nar
42112:44:03.972 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=hdfs2, description=Writes data into HDFS 2.x, sourceClass=null, sinkClass=org.apache.pulsar.io.hdfs2.sink.text.HdfsStringSink) from /pulsar/./connectors/pulsar-io-hdfs2-2.5.0.nar
42212:44:04.122 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=file, description=Reads data from local filesystem, sourceClass=org.apache.pulsar.io.file.FileSource, sinkClass=null) from /pulsar/./connectors/pulsar-io-file-2.5.0.nar
42312:44:04.219 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=cassandra, description=Writes data into Cassandra, sourceClass=null, sinkClass=org.apache.pulsar.io.cassandra.CassandraStringSink) from /pulsar/./connectors/pulsar-io-cassandra-2.5.0.nar
42412:44:04.305 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=netty, description=Netty Tcp or Udp Source Connector, sourceClass=org.apache.pulsar.io.netty.NettySource, sinkClass=null) from /pulsar/./connectors/pulsar-io-netty-2.5.0.nar
42512:44:05.073 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=debezium-mongodb, description=Debezium MongoDb Source, sourceClass=org.apache.pulsar.io.debezium.mongodb.DebeziumMongoDbSource, sinkClass=null) from /pulsar/./connectors/pulsar-io-debezium-mongodb-2.5.0.nar
42612:44:05.964 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=debezium-mysql, description=Debezium MySql Source, sourceClass=org.apache.pulsar.io.debezium.mysql.DebeziumMysqlSource, sinkClass=null) from /pulsar/./connectors/pulsar-io-debezium-mysql-2.5.0.nar
42712:44:06.162 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=data-generator, description=Test data generator source, sourceClass=org.apache.pulsar.io.datagenerator.DataGeneratorSource, sinkClass=org.apache.pulsar.io.datagenerator.DataGeneratorPrintSink) from /pulsar/./connectors/pulsar-io-data-generator-2.5.0.nar
42812:44:06.852 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=kafka-connect-adaptor, description=Kafka source connect adaptor, sourceClass=org.apache.pulsar.io.kafka.connect.KafkaConnectSource, sinkClass=null) from /pulsar/./connectors/pulsar-io-kafka-connect-adaptor-2.5.0.nar
42912:44:07.789 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Found connector ConnectorDefinition(name=redis, description=Writes data into Redis, sourceClass=null, sinkClass=org.apache.pulsar.io.redis.sink.RedisSink) from /pulsar/./connectors/pulsar-io-redis-2.5.0.nar
43012:44:07.824 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer status recorder with config: {
431 "topicNames" : [ "persistent://public/functions/coordinate" ],
432 "topicsPattern" : null,
433 "subscriptionName" : "participants",
434 "subscriptionType" : "Failover",
435 "receiverQueueSize" : 1000,
436 "acknowledgementsGroupTimeMicros" : 100000,
437 "negativeAckRedeliveryDelayMicros" : 60000000,
438 "maxTotalReceiverQueueSizeAcrossPartitions" : 50000,
439 "consumerName" : null,
440 "ackTimeoutMillis" : 0,
441 "tickDurationMillis" : 1000,
442 "priorityLevel" : 0,
443 "cryptoFailureAction" : "FAIL",
444 "properties" : {
445 "id" : "pulsar-function-0:pulsar-function-0.pulsar-function:6750"
446 },
447 "readCompacted" : false,
448 "subscriptionInitialPosition" : "Latest",
449 "patternAutoDiscoveryPeriod" : 1,
450 "regexSubscriptionMode" : "PersistentOnly",
451 "deadLetterPolicy" : null,
452 "autoUpdatePartitions" : true,
453 "replicateSubscriptionState" : false,
454 "resetIncludeHead" : false,
455 "keySharedPolicy" : null
456}
45712:44:07.826 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {
458 "serviceUrl" : "pulsar://pulsar-broker:6650",
459 "authPluginClassName" : null,
460 "authParams" : null,
461 "operationTimeoutMs" : 30000,
462 "statsIntervalSeconds" : 60,
463 "numIoThreads" : 1,
464 "numListenerThreads" : 1,
465 "connectionsPerBroker" : 1,
466 "useTcpNoDelay" : true,
467 "useTls" : false,
468 "tlsTrustCertsFilePath" : "",
469 "tlsAllowInsecureConnection" : false,
470 "tlsHostnameVerificationEnable" : false,
471 "concurrentLookupRequest" : 5000,
472 "maxLookupRequest" : 50000,
473 "maxNumberOfRejectedRequestPerConnection" : 50,
474 "keepAliveIntervalSeconds" : 30,
475 "connectionTimeoutMs" : 10000,
476 "requestTimeoutMs" : 60000,
477 "initialBackoffIntervalNanos" : 100000000,
478 "maxBackoffIntervalNanos" : 60000000000
479}
48012:44:07.840 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/coordinate][participants] Subscribing to topic on cnx [id: 0xea2130aa, L:/172.17.0.7:33296 - R:/172.17.0.4:6650]
48112:44:07.861 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/coordinate][participants] Subscribed to topic on /172.17.0.4:6650 -- consumer: 0
48212:44:07.889 [main] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntimeFactory - Java instance jar location is not defined, using the location defined in system environment : /pulsar/instances/java-instance.jar
48312:44:07.889 [main] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntimeFactory - Python instance file location is not defined using the location defined in system environment : /pulsar/instances/python-instance/python_instance_main.py
48412:44:07.889 [main] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntimeFactory - Extra dependencies location is not defined using the location defined in system environment : /pulsar/instances/deps
48512:44:07.892 [main] INFO org.apache.pulsar.functions.worker.FunctionMetaDataManager - /** Initializing Function Metadata Manager **/
48612:44:07.904 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer status recorder with config: {
487 "topicNames" : [ "persistent://public/functions/metadata" ],
488 "topicsPattern" : null,
489 "subscriptionName" : "reader-d65b41d542",
490 "subscriptionType" : "Exclusive",
491 "receiverQueueSize" : 1000,
492 "acknowledgementsGroupTimeMicros" : 100000,
493 "negativeAckRedeliveryDelayMicros" : 60000000,
494 "maxTotalReceiverQueueSizeAcrossPartitions" : 50000,
495 "consumerName" : null,
496 "ackTimeoutMillis" : 0,
497 "tickDurationMillis" : 1000,
498 "priorityLevel" : 0,
499 "cryptoFailureAction" : "FAIL",
500 "properties" : { },
501 "readCompacted" : false,
502 "subscriptionInitialPosition" : "Latest",
503 "patternAutoDiscoveryPeriod" : 1,
504 "regexSubscriptionMode" : "PersistentOnly",
505 "deadLetterPolicy" : null,
506 "autoUpdatePartitions" : true,
507 "replicateSubscriptionState" : false,
508 "resetIncludeHead" : false,
509 "keySharedPolicy" : null
510}
51112:44:07.905 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {
512 "serviceUrl" : "pulsar://pulsar-broker:6650",
513 "authPluginClassName" : null,
514 "authParams" : null,
515 "operationTimeoutMs" : 30000,
516 "statsIntervalSeconds" : 60,
517 "numIoThreads" : 1,
518 "numListenerThreads" : 1,
519 "connectionsPerBroker" : 1,
520 "useTcpNoDelay" : true,
521 "useTls" : false,
522 "tlsTrustCertsFilePath" : "",
523 "tlsAllowInsecureConnection" : false,
524 "tlsHostnameVerificationEnable" : false,
525 "concurrentLookupRequest" : 5000,
526 "maxLookupRequest" : 50000,
527 "maxNumberOfRejectedRequestPerConnection" : 50,
528 "keepAliveIntervalSeconds" : 30,
529 "connectionTimeoutMs" : 10000,
530 "requestTimeoutMs" : 60000,
531 "initialBackoffIntervalNanos" : 100000000,
532 "maxBackoffIntervalNanos" : 60000000000
533}
53412:44:07.906 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][reader-d65b41d542] Subscribing to topic on cnx [id: 0xea2130aa, L:/172.17.0.7:33296 - R:/172.17.0.4:6650]
53512:44:07.910 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][reader-d65b41d542] Subscribed to topic on /172.17.0.4:6650 -- consumer: 1
53612:44:07.921 [main] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][reader-d65b41d542] Get topic last message Id
53712:44:07.933 [pulsar-client-io-17-1] INFO com.scurrilous.circe.checksum.Crc32cIntChecksum - SSE4.2 CRC32C provider initialized
53812:44:07.940 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][reader-d65b41d542] Successfully getLastMessageId 10:1
53912:44:08.016 [main] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][reader-d65b41d542] Get topic last message Id
54012:44:08.017 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/metadata][reader-d65b41d542] Successfully getLastMessageId 10:1
54112:44:08.019 [main] INFO org.apache.pulsar.functions.worker.FunctionRuntimeManager - /** Initializing Runtime Manager **/
54212:44:08.033 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer status recorder with config: {
543 "topicNames" : [ "persistent://public/functions/assignments" ],
544 "topicsPattern" : null,
545 "subscriptionName" : "reader-371ca1d057",
546 "subscriptionType" : "Exclusive",
547 "receiverQueueSize" : 1000,
548 "acknowledgementsGroupTimeMicros" : 100000,
549 "negativeAckRedeliveryDelayMicros" : 60000000,
550 "maxTotalReceiverQueueSizeAcrossPartitions" : 50000,
551 "consumerName" : null,
552 "ackTimeoutMillis" : 0,
553 "tickDurationMillis" : 1000,
554 "priorityLevel" : 0,
555 "cryptoFailureAction" : "FAIL",
556 "properties" : { },
557 "readCompacted" : true,
558 "subscriptionInitialPosition" : "Latest",
559 "patternAutoDiscoveryPeriod" : 1,
560 "regexSubscriptionMode" : "PersistentOnly",
561 "deadLetterPolicy" : null,
562 "autoUpdatePartitions" : true,
563 "replicateSubscriptionState" : false,
564 "resetIncludeHead" : false,
565 "keySharedPolicy" : null
566}
56712:44:08.036 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {
568 "serviceUrl" : "pulsar://pulsar-broker:6650",
569 "authPluginClassName" : null,
570 "authParams" : null,
571 "operationTimeoutMs" : 30000,
572 "statsIntervalSeconds" : 60,
573 "numIoThreads" : 1,
574 "numListenerThreads" : 1,
575 "connectionsPerBroker" : 1,
576 "useTcpNoDelay" : true,
577 "useTls" : false,
578 "tlsTrustCertsFilePath" : "",
579 "tlsAllowInsecureConnection" : false,
580 "tlsHostnameVerificationEnable" : false,
581 "concurrentLookupRequest" : 5000,
582 "maxLookupRequest" : 50000,
583 "maxNumberOfRejectedRequestPerConnection" : 50,
584 "keepAliveIntervalSeconds" : 30,
585 "connectionTimeoutMs" : 10000,
586 "requestTimeoutMs" : 60000,
587 "initialBackoffIntervalNanos" : 100000000,
588 "maxBackoffIntervalNanos" : 60000000000
589}
59012:44:08.037 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][reader-371ca1d057] Subscribing to topic on cnx [id: 0xea2130aa, L:/172.17.0.7:33296 - R:/172.17.0.4:6650]
59112:44:08.039 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][reader-371ca1d057] Subscribed to topic on /172.17.0.4:6650 -- consumer: 2
59212:44:08.041 [main] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][reader-371ca1d057] Get topic last message Id
59312:44:08.049 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][reader-371ca1d057] Successfully getLastMessageId 12:1
59412:44:08.065 [main] INFO org.apache.pulsar.functions.worker.FunctionAssignmentTailer - Received assignment update: instance {
595 functionMetaData {
596 functionDetails {
597 tenant: "public"
598 namespace: "default"
599 name: "word-count"
600 className: "org.apache.pulsar.functions.api.examples.WordCountFunction"
601 autoAck: true
602 parallelism: 1
603 source {
604 typeClassName: "java.lang.String"
605 inputSpecs {
606 key: "persistent://public/default/word-count-input"
607 value {
608 }
609 }
610 cleanupSubscription: true
611 }
612 sink {
613 topic: "persistent://public/default/word-count-output"
614 typeClassName: "java.lang.Void"
615 }
616 resources {
617 cpu: 1.0
618 ram: 1073741824
619 disk: 10737418240
620 }
621 componentType: FUNCTION
622 }
623 packageLocation {
624 packagePath: "public/default/word-count/acef2471-22e5-4704-9515-1b300a2f8326-api-examples.jar"
625 originalFileName: "api-examples.jar"
626 }
627 createTime: 1583496357839
628 }
629}
630workerId: "pulsar-function-0"
631
63212:44:08.087 [main] INFO org.apache.pulsar.functions.worker.FunctionRuntimeManager - infos: {}
63312:44:08.088 [main] INFO org.apache.pulsar.functions.worker.FunctionAssignmentTailer - Received assignment update: instance {
634 functionMetaData {
635 functionDetails {
636 tenant: "public"
637 namespace: "default"
638 name: "exclamation"
639 className: "org.apache.pulsar.functions.api.examples.ExclamationFunction"
640 autoAck: true
641 parallelism: 1
642 source {
643 typeClassName: "java.lang.String"
644 inputSpecs {
645 key: "persistent://public/default/exclamation-input"
646 value {
647 }
648 }
649 cleanupSubscription: true
650 }
651 sink {
652 topic: "persistent://public/default/exclamation-output"
653 typeClassName: "java.lang.String"
654 }
655 resources {
656 cpu: 1.0
657 ram: 1073741824
658 disk: 10737418240
659 }
660 componentType: FUNCTION
661 }
662 packageLocation {
663 packagePath: "public/default/exclamation/15f2e88c-9a11-4e3e-bd4c-cea6237d3014-api-examples.jar"
664 originalFileName: "api-examples.jar"
665 }
666 createTime: 1583498148076
667 }
668}
669workerId: "pulsar-function-0"
670
67112:44:08.089 [main] INFO org.apache.pulsar.functions.worker.FunctionRuntimeManager - infos: {}
67212:44:08.089 [main] INFO org.apache.pulsar.functions.worker.FunctionAssignmentTailer - Received assignment update: instance {
673 functionMetaData {
674 functionDetails {
675 tenant: "public"
676 namespace: "default"
677 name: "word-count"
678 className: "org.apache.pulsar.functions.api.examples.WordCountFunction"
679 autoAck: true
680 parallelism: 1
681 source {
682 typeClassName: "java.lang.String"
683 inputSpecs {
684 key: "persistent://public/default/word-count-input"
685 value {
686 }
687 }
688 cleanupSubscription: true
689 }
690 sink {
691 topic: "persistent://public/default/word-count-output"
692 typeClassName: "java.lang.Void"
693 }
694 resources {
695 cpu: 1.0
696 ram: 1073741824
697 disk: 10737418240
698 }
699 componentType: FUNCTION
700 }
701 packageLocation {
702 packagePath: "public/default/word-count/acef2471-22e5-4704-9515-1b300a2f8326-api-examples.jar"
703 originalFileName: "api-examples.jar"
704 }
705 createTime: 1583496357839
706 }
707}
708workerId: "pulsar-function-0"
709
71012:44:08.092 [main] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][reader-371ca1d057] Get topic last message Id
71112:44:08.093 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][reader-371ca1d057] Successfully getLastMessageId 12:3
71212:44:08.094 [main] INFO org.apache.pulsar.functions.worker.FunctionAssignmentTailer - Received assignment update: instance {
713 functionMetaData {
714 functionDetails {
715 tenant: "public"
716 namespace: "default"
717 name: "exclamation"
718 className: "org.apache.pulsar.functions.api.examples.ExclamationFunction"
719 autoAck: true
720 parallelism: 1
721 source {
722 typeClassName: "java.lang.String"
723 inputSpecs {
724 key: "persistent://public/default/exclamation-input"
725 value {
726 }
727 }
728 cleanupSubscription: true
729 }
730 sink {
731 topic: "persistent://public/default/exclamation-output"
732 typeClassName: "java.lang.String"
733 }
734 resources {
735 cpu: 1.0
736 ram: 1073741824
737 disk: 10737418240
738 }
739 componentType: FUNCTION
740 }
741 packageLocation {
742 packagePath: "public/default/exclamation/15f2e88c-9a11-4e3e-bd4c-cea6237d3014-api-examples.jar"
743 originalFileName: "api-examples.jar"
744 }
745 createTime: 1583498148076
746 }
747}
748workerId: "pulsar-function-0"
749
75012:44:08.095 [main] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][reader-371ca1d057] Get topic last message Id
75112:44:08.101 [pulsar-client-io-17-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [persistent://public/functions/assignments][reader-371ca1d057] Successfully getLastMessageId 12:3
75212:44:08.101 [main] INFO org.apache.pulsar.functions.worker.FunctionRuntimeManager - infos: {}
75312:44:08.102 [main] INFO org.apache.pulsar.functions.worker.FunctionActioner - public/default/word-count-0 Starting function ...
75412:44:08.103 [main] INFO org.apache.pulsar.functions.worker.FunctionActioner - /tmp/pulsar_functions/public/default/word-count/0/api-examples.jar.0.465aee5f-1fcb-4b55-a132-4ac3a6abf4c1/public/default Function package file word-count will be downloaded from packagePath: "public/default/word-count/acef2471-22e5-4704-9515-1b300a2f8326-api-examples.jar"
755originalFileName: "api-examples.jar"
756
75712:44:08.103 [main] INFO org.apache.pulsar.functions.worker.WorkerUtils - Downloading public/default/word-count/acef2471-22e5-4704-9515-1b300a2f8326-api-examples.jar from BK...
75812:44:08.125 [main] INFO org.apache.distributedlog.BKDistributedLogManager - Create sync reader starting from DLSN{logSegmentSequenceNo=1, entryId=0, slotId=0}
75912:44:08.170 [main-EventThread] INFO org.apache.distributedlog.logsegment.PerStreamLogSegmentCache - public/default/word-count/acef2471-22e5-4704-9515-1b300a2f8326-api-examples.jar added log segment (logrecs_000000000000000001 : [LogSegmentId:14, firstTxId:1024, lastTxId:9223372036854775807, version:VERSION_V5_SEQUENCE_ID, completionTime:1583496358226, recordCount:41, regionId:0, status:0, logSegmentSequenceNumber:1, lastEntryId:2, lastSlotId:0, inprogress:false, minActiveDLSN:DLSN{logSegmentSequenceNo=1, entryId=0, slotId=0}, startSequenceId:0]) to cache.
76012:44:08.173 [main-EventThread] INFO org.apache.distributedlog.ReadAheadEntryReader - Starting the readahead entry reader for public/default/word-count/acef2471-22e5-4704-9515-1b300a2f8326-api-examples.jar:<default> : segments = [[LogSegmentId:14, firstTxId:1024, lastTxId:9223372036854775807, version:VERSION_V5_SEQUENCE_ID, completionTime:1583496358226, recordCount:41, regionId:0, status:0, logSegmentSequenceNumber:1, lastEntryId:2, lastSlotId:0, inprogress:false, minActiveDLSN:DLSN{logSegmentSequenceNo=1, entryId=0, slotId=0}, startSequenceId:0]]
76112:44:08.194 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.zookeeper.ZooKeeper - Initiating client connection, connectString=pulsar-zookeeper-0.pulsar-zookeeper sessionTimeout=30000 watcher=org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase@4858bdb2
76212:44:08.194 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.zookeeper.ClientCnxnSocket - jute.maxbuffer value is 10485760 Bytes
76312:44:08.195 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.zookeeper.ClientCnxn - zookeeper.request.timeout value is 0. feature enabled=
76412:44:08.197 [DLM-/pulsar/functions-OrderedScheduler-0-0-SendThread(pulsar-zookeeper-0.pulsar-zookeeper:2181)] INFO org.apache.zookeeper.ClientCnxn - Opening socket connection to server pulsar-zookeeper-0.pulsar-zookeeper/172.17.0.8:2181. Will not attempt to authenticate using SASL (unknown error)
76512:44:08.198 [DLM-/pulsar/functions-OrderedScheduler-0-0-SendThread(pulsar-zookeeper-0.pulsar-zookeeper:2181)] INFO org.apache.zookeeper.ClientCnxn - Socket connection established, initiating session, client: /172.17.0.7:45756, server: pulsar-zookeeper-0.pulsar-zookeeper/172.17.0.8:2181
76612:44:08.200 [DLM-/pulsar/functions-OrderedScheduler-0-0-SendThread(pulsar-zookeeper-0.pulsar-zookeeper:2181)] INFO org.apache.zookeeper.ClientCnxn - Session establishment complete on server pulsar-zookeeper-0.pulsar-zookeeper/172.17.0.8:2181, sessionid = 0x1002ce2a23e001d, negotiated timeout = 30000
76712:44:08.201 [DLM-/pulsar/functions-OrderedScheduler-0-0-EventThread] INFO org.apache.bookkeeper.zookeeper.ZooKeeperWatcherBase - ZooKeeper client is connected now.
76812:44:08.215 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.bookkeeper.meta.MetadataDrivers - BookKeeper metadata driver manager initialized
76912:44:08.216 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.bookkeeper.meta.MetadataDrivers - BookKeeper metadata driver manager initialized
77012:44:08.216 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.bookkeeper.meta.MetadataDrivers - BookKeeper metadata driver manager initialized
77112:44:08.217 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.bookkeeper.meta.zk.ZKMetadataDriverBase - Initialize zookeeper metadata driver with external zookeeper client : ledgersRootPath = /ledgers.
77212:44:08.241 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl - Initialize rackaware ensemble placement policy @ <Bookie:172.17.0.7:0> @ /default-region/default-rack : org.apache.distributedlog.net.DNSResolverForRacks.
77312:44:08.241 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl - Not weighted
77412:44:08.246 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.bookkeeper.client.BookKeeper - Weighted ledger placement is not enabled
77512:44:08.256 [BookKeeperClientScheduler-OrderedScheduler-0-0] INFO org.apache.bookkeeper.net.NetworkTopologyImpl - Adding a new node: /default-region/default-rack/pulsar-bookkeeper-0.pulsar-bookkeeper.default.svc.cluster.local:3181
77612:44:08.256 [BookKeeperClientScheduler-OrderedScheduler-0-0] INFO org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl - Initialize rackaware ensemble placement policy @ <Bookie:172.17.0.7:0> @ /default-region/default-rack : org.apache.bookkeeper.client.TopologyAwareEnsemblePlacementPolicy$DNSResolverDecorator.
77712:44:08.256 [BookKeeperClientScheduler-OrderedScheduler-0-0] INFO org.apache.bookkeeper.client.RackawareEnsemblePlacementPolicyImpl - Not weighted
77812:44:08.257 [BookKeeperClientScheduler-OrderedScheduler-0-0] INFO org.apache.bookkeeper.net.NetworkTopologyImpl - Adding a new node: /default-region/default-rack/pulsar-bookkeeper-0.pulsar-bookkeeper.default.svc.cluster.local:3181
77912:44:08.274 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.distributedlog.BookKeeperClient - BookKeeper Client created bk:distributedlog://pulsar-zookeeper-0.pulsar-zookeeper/pulsar/functions:factory_writer_shared with its own ZK Client : ledgersPath = /ledgers, numRetries = 3, sessionTimeout = 30000, backoff = 5000, maxBackoff = 30000, dnsResolver =
78012:44:08.358 [DL-io-0] INFO org.apache.bookkeeper.proto.PerChannelBookieClient - Successfully connected to bookie: [id: 0x1c4dd873, L:/172.17.0.7:34758 - R:pulsar-bookkeeper-0.pulsar-bookkeeper.default.svc.cluster.local/172.17.0.9:3181]
78112:44:08.359 [DL-io-0] INFO org.apache.bookkeeper.proto.PerChannelBookieClient - Successfully connected to bookie: pulsar-bookkeeper-0.pulsar-bookkeeper.default.svc.cluster.local:3181
78212:44:08.378 [DL-io-0] INFO org.apache.bookkeeper.proto.PerChannelBookieClient - connection [id: 0x1c4dd873, L:/172.17.0.7:34758 - R:pulsar-bookkeeper-0.pulsar-bookkeeper.default.svc.cluster.local/172.17.0.9:3181] authenticated as BookKeeperPrincipal{ANONYMOUS}
78312:44:08.437 [main] INFO org.apache.pulsar.functions.worker.FunctionActioner - Function package file is linked from /tmp/pulsar_functions/public/default/word-count/0/api-examples.jar.0.465aee5f-1fcb-4b55-a132-4ac3a6abf4c1 to /tmp/pulsar_functions/public/default/word-count/0/api-examples.jar
78412:44:08.822 [main] INFO org.apache.pulsar.functions.runtime.RuntimeSpawner - public/default/word-count-0 RuntimeSpawner starting function
78512:44:08.822 [main] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntime - Creating function log directory /pulsar/logs/functions/public/default/word-count
78612:44:08.824 [main] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntime - Created or found function log directory /pulsar/logs/functions/public/default/word-count
78712:44:08.825 [main] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntime - ProcessBuilder starting the process with args java -cp /pulsar/instances/java-instance.jar:/pulsar/instances/deps/* -Dpulsar.functions.extra.dependencies.dir=/pulsar/instances/deps -Dpulsar.functions.instance.classpath=/pulsar/conf:::/pulsar/lib/*: -Dlog4j.configurationFile=java_instance_log4j2.xml -Dpulsar.function.log.dir=/pulsar/logs/functions/public/default/word-count -Dpulsar.function.log.file=word-count-0 -Xmx1073741824 org.apache.pulsar.functions.instance.JavaInstanceMain --jar /tmp/pulsar_functions/public/default/word-count/0/api-examples.jar --instance_id 0 --function_id cc897c48-b468-404e-bc6e-f15e9c319619 --function_version 523c2f71-95fa-4518-b51f-4223977cf028 --function_details '{"tenant":"public","namespace":"default","name":"word-count","className":"org.apache.pulsar.functions.api.examples.WordCountFunction","autoAck":true,"parallelism":1,"source":{"typeClassName":"java.lang.String","inputSpecs":{"persistent://public/default/word-count-input":{}},"cleanupSubscription":true},"sink":{"topic":"persistent://public/default/word-count-output","typeClassName":"java.lang.Void"},"resources":{"cpu":1.0,"ram":"1073741824","disk":"10737418240"},"componentType":"FUNCTION"}' --pulsar_serviceurl pulsar://pulsar-broker:6650 --max_buffered_tuples 1024 --port 36559 --metrics_port 34963 --state_storage_serviceurl bk://pulsar-bookkeeper:4181 --expected_healthcheck_interval 30 --secrets_provider org.apache.pulsar.functions.secretsprovider.ClearTextSecretsProvider --cluster_name pulsar
78812:44:08.830 [main] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntime - Started process successfully
78912:44:08.841 [main] INFO org.apache.pulsar.functions.worker.FunctionRuntimeManager - infos: {public/default/word-count:0=FunctionRuntimeInfo(functionInstance=functionMetaData {
790 functionDetails {
791 tenant: "public"
792 namespace: "default"
793 name: "word-count"
794 className: "org.apache.pulsar.functions.api.examples.WordCountFunction"
795 autoAck: true
796 parallelism: 1
797 source {
798 typeClassName: "java.lang.String"
799 inputSpecs {
800 key: "persistent://public/default/word-count-input"
801 value {
802 }
803 }
804 cleanupSubscription: true
805 }
806 sink {
807 topic: "persistent://public/default/word-count-output"
808 typeClassName: "java.lang.Void"
809 }
810 resources {
811 cpu: 1.0
812 ram: 1073741824
813 disk: 10737418240
814 }
815 componentType: FUNCTION
816 }
817 packageLocation {
818 packagePath: "public/default/word-count/acef2471-22e5-4704-9515-1b300a2f8326-api-examples.jar"
819 originalFileName: "api-examples.jar"
820 }
821 createTime: 1583496357839
822}
823, runtimeSpawner=org.apache.pulsar.functions.runtime.RuntimeSpawner@35e59c13, startupException=null)}
82412:44:08.842 [main] INFO org.apache.pulsar.functions.worker.FunctionActioner - public/default/exclamation-0 Starting function ...
82512:44:08.842 [main] INFO org.apache.pulsar.functions.worker.FunctionActioner - /tmp/pulsar_functions/public/default/exclamation/0/api-examples.jar.0.74b6c3ed-c145-4ab2-a57f-647639091993/public/default Function package file exclamation will be downloaded from packagePath: "public/default/exclamation/15f2e88c-9a11-4e3e-bd4c-cea6237d3014-api-examples.jar"
826originalFileName: "api-examples.jar"
827
82812:44:08.842 [main] INFO org.apache.pulsar.functions.worker.WorkerUtils - Downloading public/default/exclamation/15f2e88c-9a11-4e3e-bd4c-cea6237d3014-api-examples.jar from BK...
82912:44:08.848 [main] INFO org.apache.distributedlog.BKDistributedLogManager - Create sync reader starting from DLSN{logSegmentSequenceNo=1, entryId=0, slotId=0}
83012:44:08.854 [main-EventThread] INFO org.apache.distributedlog.logsegment.PerStreamLogSegmentCache - public/default/exclamation/15f2e88c-9a11-4e3e-bd4c-cea6237d3014-api-examples.jar added log segment (logrecs_000000000000000001 : [LogSegmentId:21, firstTxId:1024, lastTxId:9223372036854775807, version:VERSION_V5_SEQUENCE_ID, completionTime:1583498148154, recordCount:41, regionId:0, status:0, logSegmentSequenceNumber:1, lastEntryId:2, lastSlotId:0, inprogress:false, minActiveDLSN:DLSN{logSegmentSequenceNo=1, entryId=0, slotId=0}, startSequenceId:0]) to cache.
83112:44:08.854 [main-EventThread] INFO org.apache.distributedlog.ReadAheadEntryReader - Starting the readahead entry reader for public/default/exclamation/15f2e88c-9a11-4e3e-bd4c-cea6237d3014-api-examples.jar:<default> : segments = [[LogSegmentId:21, firstTxId:1024, lastTxId:9223372036854775807, version:VERSION_V5_SEQUENCE_ID, completionTime:1583498148154, recordCount:41, regionId:0, status:0, logSegmentSequenceNumber:1, lastEntryId:2, lastSlotId:0, inprogress:false, minActiveDLSN:DLSN{logSegmentSequenceNo=1, entryId=0, slotId=0}, startSequenceId:0]]
83212:44:08.855 [main-EventThread] INFO org.apache.distributedlog.ReadAheadEntryReader - segments is updated with [[LogSegmentId:21, firstTxId:1024, lastTxId:9223372036854775807, version:VERSION_V5_SEQUENCE_ID, completionTime:1583498148154, recordCount:41, regionId:0, status:0, logSegmentSequenceNumber:1, lastEntryId:2, lastSlotId:0, inprogress:false, minActiveDLSN:DLSN{logSegmentSequenceNo=1, entryId=0, slotId=0}, startSequenceId:0]]
83312:44:08.857 [DLM-/pulsar/functions-OrderedScheduler-0-0] INFO org.apache.distributedlog.ReadAheadEntryReader - Reinitialize log segments with [[LogSegmentId:21, firstTxId:1024, lastTxId:9223372036854775807, version:VERSION_V5_SEQUENCE_ID, completionTime:1583498148154, recordCount:41, regionId:0, status:0, logSegmentSequenceNumber:1, lastEntryId:2, lastSlotId:0, inprogress:false, minActiveDLSN:DLSN{logSegmentSequenceNo=1, entryId=0, slotId=0}, startSequenceId:0]]
83412:44:08.885 [main] INFO org.apache.pulsar.functions.worker.FunctionActioner - Function package file is linked from /tmp/pulsar_functions/public/default/exclamation/0/api-examples.jar.0.74b6c3ed-c145-4ab2-a57f-647639091993 to /tmp/pulsar_functions/public/default/exclamation/0/api-examples.jar
83512:44:08.888 [main] INFO org.apache.pulsar.functions.runtime.RuntimeSpawner - public/default/exclamation-0 RuntimeSpawner starting function
83612:44:08.888 [main] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntime - Creating function log directory /pulsar/logs/functions/public/default/exclamation
83712:44:08.888 [main] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntime - Created or found function log directory /pulsar/logs/functions/public/default/exclamation
83812:44:08.888 [main] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntime - ProcessBuilder starting the process with args java -cp /pulsar/instances/java-instance.jar:/pulsar/instances/deps/* -Dpulsar.functions.extra.dependencies.dir=/pulsar/instances/deps -Dpulsar.functions.instance.classpath=/pulsar/conf:::/pulsar/lib/*: -Dlog4j.configurationFile=java_instance_log4j2.xml -Dpulsar.function.log.dir=/pulsar/logs/functions/public/default/exclamation -Dpulsar.function.log.file=exclamation-0 -Xmx1073741824 org.apache.pulsar.functions.instance.JavaInstanceMain --jar /tmp/pulsar_functions/public/default/exclamation/0/api-examples.jar --instance_id 0 --function_id 34ee4317-5698-4178-b176-d88df5c03342 --function_version fcd8d52a-3982-4a40-9712-90ba84eecc53 --function_details '{"tenant":"public","namespace":"default","name":"exclamation","className":"org.apache.pulsar.functions.api.examples.ExclamationFunction","autoAck":true,"parallelism":1,"source":{"typeClassName":"java.lang.String","inputSpecs":{"persistent://public/default/exclamation-input":{}},"cleanupSubscription":true},"sink":{"topic":"persistent://public/default/exclamation-output","typeClassName":"java.lang.String"},"resources":{"cpu":1.0,"ram":"1073741824","disk":"10737418240"},"componentType":"FUNCTION"}' --pulsar_serviceurl pulsar://pulsar-broker:6650 --max_buffered_tuples 1024 --port 37259 --metrics_port 43645 --state_storage_serviceurl bk://pulsar-bookkeeper:4181 --expected_healthcheck_interval 30 --secrets_provider org.apache.pulsar.functions.secretsprovider.ClearTextSecretsProvider --cluster_name pulsar
83912:44:08.902 [main] INFO org.apache.pulsar.functions.runtime.process.ProcessRuntime - Started process successfully
84012:44:08.903 [main] INFO org.apache.pulsar.functions.worker.WorkerService - Start cluster services...
84112:44:08.905 [main] INFO org.apache.pulsar.functions.worker.FunctionRuntimeManager - /** Starting Function Runtime Manager **/
84212:44:08.905 [main] INFO org.apache.pulsar.functions.worker.FunctionRuntimeManager - Starting function assignment tailer...
84312:44:08.936 [main] INFO org.eclipse.jetty.util.log - Logging initialized @18777ms to org.eclipse.jetty.util.log.Slf4jLog
844Using function root classloader: sun.misc.Launcher$AppClassLoader@7852e922
845Using function instance classloader: java.net.URLClassLoader@5c647e05
846Using function root classloader: sun.misc.Launcher$AppClassLoader@7852e922
847Using function instance classloader: java.net.URLClassLoader@5c647e05
84812:44:09.154 [main] INFO org.eclipse.jetty.server.Server - jetty-9.4.20.v20190813; built: 2019-08-13T21:28:18.144Z; git: 84700530e645e812b336747464d6fbbf370c9a20; jvm 1.8.0_232-b09
849Starting function instance...
850Starting function instance...
85112:44:09.724 [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@62cd39d3{/admin,null,AVAILABLE}
85212:44:09.896 [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@7c465f15{/admin/v2,null,AVAILABLE}
85312:44:10.805 [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@58fd0074{/admin/v3,null,AVAILABLE}
85412:44:10.922 [main] INFO org.eclipse.jetty.server.handler.ContextHandler - Started o.e.j.s.ServletContextHandler@630a32f8{/,null,AVAILABLE}
85512:44:10.942 [main] INFO org.eclipse.jetty.server.AbstractConnector - Started ServerConnector@337348de{HTTP/1.1,[http/1.1]}{0.0.0.0:6750}
85612:44:10.943 [main] INFO org.eclipse.jetty.server.Server - Started @20785ms
85712:44:10.943 [main] INFO org.apache.pulsar.functions.worker.rest.WorkerServer - Worker Server started at http://172.17.0.7:6750/admin
85812:44:10.943 [main] INFO org.apache.pulsar.functions.worker.Worker - Start worker server on port 6750...
85912:44:57.479 [pulsar-timer-19-1] INFO org.apache.pulsar.client.impl.ProducerStatsRecorderImpl - [persistent://public/functions/assignments] [pulsar-3-1182] Pending messages: 0 --- Publish throughput: 0.03 msg/s --- 0.00 Mbit/s --- Latency: med: 0.019 ms - 95pct: 0.019 ms - 99pct: 0.019 ms - 99.9pct: 0.019 ms - max: 0.019 ms --- Ack received rate: 0.03 ack/s --- Failed messages: 0
86012:45:07.907 [pulsar-timer-19-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - [persistent://public/functions/metadata] [reader-d65b41d542] [fbd41] Prefetched messages: 0 --- Consume throughput received: 0.03 msgs/s --- 0.00 Mbit/s --- Ack sent rate: 0.00 ack/s --- Failed messages: 0 --- batch messages: 0 ---Failed acks: 0
86112:45:08.036 [pulsar-timer-19-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - [persistent://public/functions/assignments] [reader-371ca1d057] [19dde] Prefetched messages: 0 --- Consume throughput received: 0.07 msgs/s --- 0.00 Mbit/s --- Ack sent rate: 0.00 ack/s --- Failed messages: 0 --- batch messages: 0 ---Failed acks: 0
86212:58:40.941 [function-web-28-4] INFO org.eclipse.jetty.util.TypeUtil - JVM Runtime does not support Modules
86312:58:41.148 [function-web-28-4] ERROR org.apache.pulsar.functions.worker.rest.api.FunctionsImpl - Function public/default/exclamation already exists
86412:58:41.169 [function-web-28-4] INFO org.eclipse.jetty.server.RequestLog - 172.17.0.5 - - [06/Mar/2020:12:58:40 +0000] "POST /admin/v3/functions/public/default/exclamation HTTP/1.1" 400 48 "-" "Pulsar-Java-v2.5.0" 225
86512:59:27.070 [function-web-28-1] INFO org.eclipse.jetty.server.RequestLog - 172.17.0.5 - - [06/Mar/2020:12:59:27 +0000] "GET /admin/v3/functions/public/default/word-count/status HTTP/1.1" 200 337 "-" "Pulsar-Java-v2.5.0" 53
86612:59:34.572 [function-web-28-5] INFO org.eclipse.jetty.server.RequestLog - 172.17.0.5 - - [06/Mar/2020:12:59:34 +0000] "GET /admin/v3/functions/public/default/exclamation/status HTTP/1.1" 200 337 "-" "Pulsar-Java-v2.5.0" 12
86713:05:17.715 [function-web-28-2] INFO org.eclipse.jetty.server.RequestLog - 172.17.0.5 - - [06/Mar/2020:13:05:17 +0000] "GET /admin/v3/functions/public/default/exclamation/status HTTP/1.1" 200 337 "-" "Pulsar-Java-v2.5.0" 9
86813:07:05.518 [function-web-28-2] INFO org.eclipse.jetty.server.RequestLog - 172.17.0.5 - - [06/Mar/2020:13:07:05 +0000] "GET /admin/v3/functions/public/default/word-count/status HTTP/1.1" 200 337 "-" "Pulsar-Java-v2.5.0" 5
86913:08:03.462 [function-web-28-1] INFO org.eclipse.jetty.server.RequestLog - 172.17.0.5 - - [06/Mar/2020:13:08:03 +0000] "GET /admin/v3/functions/public/default/exclamation/status HTTP/1.1" 200 337 "-" "Pulsar-Java-v2.5.0" 7
87013:23:37.833 [function-web-28-6] INFO org.eclipse.jetty.server.RequestLog - 172.17.0.5 - - [06/Mar/2020:13:23:37 +0000] "GET /admin/v3/functions/public/default/exclamation/status HTTP/1.1" 200 337 "-" "Pulsar-Java-v2.5.0" 7
87117:22:16.100 [function-web-28-5] INFO org.eclipse.jetty.server.RequestLog - 172.17.0.5 - - [06/Mar/2020:17:22:16 +0000] "GET /admin/v3/functions/public/default/exclamation/status HTTP/1.1" 200 337 "-" "Pulsar-Java-v2.5.0" 7