Unable to Configure a JDBC sink

[jm7647]

Describe the bug
Pulsar 2.4.1 docker image is missing IO file.

To Reproduce
Steps to reproduce the behavior:

1. Get docker image:
   docker pull apachepulsar/pulsar:2.4.1
2. Make it running
3. Start pulsar:
   docker start pulsar
4. List connectors folder:
   docker exec -it pulsar /bin/bash -c "ls -l connectors"
5. See error:
   ls: cannot access 'connectors': No such file or directory

Expected behavior
File(s) should be listed.

Screenshots

Desktop (please complete the following information):

• OS: Ubuntu 14

Additional context
Creating sink connector will fail due to missing pulsar-io-jdbc-2.4.1.nar file:

$ bin/pulsar-admin sinks create
--archive ./connectors/pulsar-io-jdbc-2.4.1.nar
--inputs pulsar-mysql-jdbc-sink-topic
--name pulsar-mysql-jdbc-sink
--sink-config-file ./connectors/pulsar-mysql-jdbc-sink.yaml
--parallelism 1

[tuteng]

You can download nar packages from here . All connector files are put into containers, which will result in very large images.

[jm7647]

I followed your suggestion and download nar package. Then I followed tutorial:

       https://pulsar.apache.org/docs/en/io-quickstart/#connect-pulsar-to-mysql

Still jdbc connector is not working according to pulsar logs:

14:20:14.877 [function-timer-thread-86-1] INFO org.apache.pulsar.functions.runtime.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/pulsar-mysql-jdbc-sink -Dpulsar.function.log.file=pulsar-mysql-jdbc-sink-0 -Xmx1073741824 org.apache.pulsar.functions.instance.JavaInstanceMain --jar /tmp/pulsar_functions/public/default/pulsar-mysql-jdbc-sink/0/pulsar-io-jdbc-2.4.1.nar --instance_id 0 --function_id 993eb03e-f517-45ec-bb99-e4e29a58ae43 --function_version 3491094b-20c9-4117-b80e-ef8e686ebcd1 --function_details '{"tenant":"public","namespace":"default","name":"pulsar-mysql-jdbc-sink","className":"org.apache.pulsar.functions.api.utils.IdentityFunction","autoAck":true,"parallelism":1,"source":{"typeClassName":"org.apache.pulsar.client.api.schema.GenericRecord","inputSpecs":{"pulsar-mysql-jdbc-sink-topic":{}},"cleanupSubscription":true},"sink":{"className":"org.apache.pulsar.io.jdbc.JdbcAutoSchemaSink","configs":"{"userName":"root","password":"jdbc","jdbcUrl":"jdbc:mysql://127.0.0.1:3306/pulsar_mysql_jdbc_sink","tableName":"pulsar_mysql_jdbc_sink"}","typeClassName":"org.apache.pulsar.client.api.schema.GenericRecord"},"resources":{"cpu":1.0,"ram":"1073741824","disk":"10737418240"},"componentType":"SINK"}' --pulsar_serviceurl pulsar://mtn21cvaas04.mt.att.com:6650 --max_buffered_tuples 1024 --port 34596 --metrics_port 46333 --state_storage_serviceurl bk://127.0.0.1:4181 --expected_healthcheck_interval 30 --secrets_provider org.apache.pulsar.functions.secretsprovider.ClearTextSecretsProvider --cluster_name standalone
14:20:14.880 [function-timer-thread-86-1] INFO org.apache.pulsar.functions.runtime.ProcessRuntime - Started process successfully
Using function root classloader: sun.misc.Launcher$AppClassLoader@7852e922
Using function instance classloader: java.net.URLClassLoader@5c647e05
Starting function instance...
Loading class com.mysql.jdbc.Driver'. This is deprecated. The new driver class is com.mysql.cj.jdbc.Driver'. The driver is automatically registered via the SPI and manual loading of the driver class is generally unnecessary.
Mon Oct 21 14:20:17 UTC 2019 WARN: Establishing SSL connection without server's identity verification is not recommended. According to MySQL 5.5.45+, 5.6.26+ and 5.7.6+ requirements SSL connection must be established by default if explicit option isn't set. For compliance with existing applications not using SSL the verifyServerCertificate property is set to 'false'. You need either to explicitly disable SSL by setting useSSL=false, or set useSSL=true and provide truststore for server certificate verification.
14:20:18.482 [pulsar-io-50-4] INFO org.apache.pulsar.broker.service.ServerCnx - New connection from /135.25.67.33:38616
14:20:18.556 [pulsar-io-50-4] INFO org.apache.pulsar.broker.service.ServerCnx - Closed connection from /135.25.67.33:38616
14:20:29.003 [pulsar-web-57-8] INFO org.eclipse.jetty.server.RequestLog - 135.25.67.33 - - [21/Oct/2019:14:20:28 +0000] "GET /admin/v2/persistent/public/functions/coordinate/stats HTTP/1.1" 200 837 "-" "Pulsar-Java-v2.4.1" 4
14:20:44.876 [function-timer-thread-86-1] ERROR org.apache.pulsar.functions.runtime.ProcessRuntime - Extracted Process death exception
java.lang.RuntimeException:
at org.apache.pulsar.functions.runtime.ProcessRuntime.tryExtractingDeathException(ProcessRuntime.java:380) ~[org.apache.pulsar-pulsar-functions-runtime-2.4.1.jar:2.4.1]
at org.apache.pulsar.functions.runtime.ProcessRuntime.isAlive(ProcessRuntime.java:367) ~[org.apache.pulsar-pulsar-functions-runtime-2.4.1.jar:2.4.1]
at org.apache.pulsar.functions.runtime.RuntimeSpawner.lambda$start$0(RuntimeSpawner.java:88) ~[org.apache.pulsar-pulsar-functions-runtime-2.4.1.jar:2.4.1]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_212]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [?:1.8.0_212]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_212]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [?:1.8.0_212]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_212]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_212]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_212]
14:20:44.878 [function-timer-thread-86-1] ERROR org.apache.pulsar.functions.runtime.RuntimeSpawner - public/default/pulsar-mysql-jdbc-sink-java.lang.RuntimeException: Function Container is dead with exception.. restarting

[tuteng]

WARN: Establishing SSL connection without server's identity verification is not recommended. According to MySQL 5.5.45+, 5.6.26+ and 5.7.6+ requirements SSL connection must be established by default if explicit option isn't set. For compliance with existing applications not using SSL the verifyServerCertificate property is set to 'false'. You need either to explicitly disable SSL by setting useSSL=false, or set useSSL=true and provide truststore for server certificate verification.

Try adding useSSL parameter to the link.

jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=utf-8&useSSL=false

[jm7647]

I'm using now useSSL=false. Notice SSL warning is gone but jdbc sink connector continue to fail:

17:50:54.652 [function-timer-thread-86-1] INFO org.apache.pulsar.functions.runtime.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/pulsar-mysql-jdbc-sink -Dpulsar.function.log.file=pulsar-mysql-jdbc-sink-0 -Xmx1073741824 org.apache.pulsar.functions.instance.JavaInstanceMain --jar /tmp/pulsar_functions/public/default/pulsar-mysql-jdbc-sink/0/pulsar-io-jdbc-2.4.1.nar --instance_id 0 --function_id be5a9234-2964-4b96-8899-b92e045c9ef0 --function_version 72757313-5529-44d0-91ff-05f7d1f21860 --function_details '{"tenant":"public","namespace":"default","name":"pulsar-mysql-jdbc-sink","className":"org.apache.pulsar.functions.api.utils.IdentityFunction","autoAck":true,"parallelism":1,"source":{"typeClassName":"org.apache.pulsar.client.api.schema.GenericRecord","inputSpecs":{"pulsar-mysql-jdbc-sink-topic":{}},"cleanupSubscription":true},"sink":{"className":"org.apache.pulsar.io.jdbc.JdbcAutoSchemaSink","configs":"{"userName":"root","password":"jdbc","jdbcUrl":"jdbc:mysql://127.0.0.1:3306/pulsar_mysql_jdbc_sink","tableName":"pulsar_mysql_jdbc_sink","useSSL":"false"}","typeClassName":"org.apache.pulsar.client.api.schema.GenericRecord"},"resources":{"cpu":1.0,"ram":"1073741824","disk":"10737418240"},"componentType":"SINK"}' --pulsar_serviceurl pulsar://mtn21cvaas04.mt.att.com:6650 --max_buffered_tuples 1024 --port 38206 --metrics_port 43625 --state_storage_serviceurl bk://127.0.0.1:4181 --expected_healthcheck_interval 30 --secrets_provider org.apache.pulsar.functions.secretsprovider.ClearTextSecretsProvider --cluster_name standalone
17:50:54.656 [function-timer-thread-86-1] INFO org.apache.pulsar.functions.runtime.ProcessRuntime - Started process successfully
Using function root classloader: sun.misc.Launcher$AppClassLoader@7852e922
Using function instance classloader: java.net.URLClassLoader@5c647e05
Starting function instance...
17:51:02.473 [pulsar-web-57-8] INFO org.eclipse.jetty.server.RequestLog - 135.25.67.33 - - [21/Oct/2019:17:51:02 +0000] "GET /admin/v2/persistent/public/functions/coordinate/stats HTTP/1.1" 200 837 "-" "Pulsar-Java-v2.4.1" 2
17:51:24.651 [function-timer-thread-86-1] ERROR org.apache.pulsar.functions.runtime.ProcessRuntime - Extracted Process death exception
java.lang.RuntimeException:
at org.apache.pulsar.functions.runtime.ProcessRuntime.tryExtractingDeathException(ProcessRuntime.java:380) ~[org.apache.pulsar-pulsar-functions-runtime-2.4.1.jar:2.4.1]
at org.apache.pulsar.functions.runtime.ProcessRuntime.isAlive(ProcessRuntime.java:367) ~[org.apache.pulsar-pulsar-functions-runtime-2.4.1.jar:2.4.1]
at org.apache.pulsar.functions.runtime.RuntimeSpawner.lambda$start$0(RuntimeSpawner.java:88) ~[org.apache.pulsar-pulsar-functions-runtime-2.4.1.jar:2.4.1]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_212]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [?:1.8.0_212]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_212]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [?:1.8.0_212]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_212]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_212]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_212]
17:51:24.652 [function-timer-thread-86-1] ERROR org.apache.pulsar.functions.runtime.RuntimeSpawner - public/default/pulsar-mysql-jdbc-sink-java.lang.RuntimeException: Function Container is dead with exception.. restarting

[jm7647]

I looked directly at sink log and it seems to be some schema issue:

19:09:46.263 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Configuring schema for topic pulsar-mysql-jdbc-sink-topic : {
"name": "public/default/pulsar-mysql-jdbc-sink-topic",
"schema": "",
"type": "NONE",
"properties": {}
}
19:09:46.264 [public/default/pulsar-mysql-jdbc-sink-0] ERROR org.apache.pulsar.functions.instance.JavaInstanceRunnable - Source open produced uncaught exception:
java.util.concurrent.CompletionException: java.lang.RuntimeException: Currently auto consume only works for topics with avro or json schemas

[tuteng]

Have you created a schema for your topic, http://pulsar.apache.org/docs/en/io-quickstart/#configure-a-jdbc-sink

[jm7647]

That was side effect of me removing sink, so we can ignore it.
After spending some time with suggested solution I see two cases and both fail.

1. Passing useSSL=false to link in .yaml file
   jdbcUrl: "jdbc:mysql://127.0.0.1:3306/pulsar_mysql_jdbc_sink&useSSL=false"

        that brings mysql error:
        [Note] Unknown database 'pulsar_mysql_jdbc_sink&useSSL=false'
   

2. Adding useSSL=false as additional .yaml parameter:
   .....
   jdbcUrl: "jdbc:mysql://127.0.0.1:3306/pulsar_mysql_jdbc_sink"
   tableName: "pulsar_mysql_jdbc_sink"
   useSSL: "false"

        This removes SSL warning but sink log reports it as unrecognized field and also fails:
   
        15:03:26.939 [public/default/pulsar-mysql-jdbc-sink-0] ERROR org.apache.pulsar.functions.instance.JavaInstanceRunnable - Sink open produced uncaught exception:
   

com.fasterxml.jackson.databind.exc.UnrecognizedPropertyException: Unrecognized field "useSSL" (class org.apache.pulsar.io.jdbc.JdbcSinkConfig), not marked as ignorable (8 known properties: "nonKey", "jdbcUrl", "userName", "timeoutMs", "tableName", "password", "key", "batchSize"])

[jm7647]

OK, it looks like I have first case #1 working now. I had typo in that link.
Thank you for your support.

[rec7y33]

Hello, I have a similar problem/ error following this tutorial : https://pulsar.apache.org/docs/en/io-quickstart/#submit-a-jdbc-sink

When I try to submit a jdbc sink, the following error occurs:

01:37:38.550 [function-timer-thread-90-1] INFO org.apache.pulsar.functions.runtime.ProcessRuntime - Creating function log directory /pulsar/logs/functions/public/default/pulsar-mysql-jdbc-sink
01:37:38.551 [function-timer-thread-90-1] INFO org.apache.pulsar.functions.runtime.ProcessRuntime - Created or found function log directory /pulsar/logs/functions/public/default/pulsar-mysql-jdbc-sink
01:37:38.551 [function-timer-thread-90-1] INFO org.apache.pulsar.functions.runtime.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/pulsar-mysql-jdbc-sink -Dpulsar.function.log.file=pulsar-mysql-jdbc-sink-0 -Xmx1073741824 org.apache.pulsar.functions.instance.JavaInstanceMain --jar /tmp/pulsar_functions/public/default/pulsar-mysql-jdbc-sink/0/pulsar-io-jdbc-2.4.1.nar --instance_id 0 --function_id 605da720-4c22-4d44-a2fc-b0682a07165c --function_version 688a5760-b5f9-4e34-aa0f-a2997ff5e434 --function_details '{"tenant":"public","namespace":"default","name":"pulsar-mysql-jdbc-sink","className":"org.apache.pulsar.functions.api.utils.IdentityFunction","autoAck":true,"parallelism":1,"source":{"typeClassName":"org.apache.pulsar.client.api.schema.GenericRecord","inputSpecs":{"pulsar-mysql-jdbc-sink-topic":{}},"cleanupSubscription":true},"sink":{"className":"org.apache.pulsar.io.jdbc.JdbcAutoSchemaSink","configs":"{"userName":"root","password":"jdbc","jdbcUrl":"jdbc:mysql://127.0.0.1:3306/pulsar_mysql_jdbc_sink","tableName":"pulsar_mysql_jdbc_sink"}","typeClassName":"org.apache.pulsar.client.api.schema.GenericRecord"},"resources":{"cpu":1.0,"ram":"1073741824","disk":"10737418240"},"componentType":"SINK"}' --pulsar_serviceurl pulsar://a7d6eb0588a3:6650 --max_buffered_tuples 1024 --port 36885 --metrics_port 39587 --state_storage_serviceurl bk://127.0.0.1:4181 --expected_healthcheck_interval 30 --secrets_provider org.apache.pulsar.functions.secretsprovider.ClearTextSecretsProvider --cluster_name standalone
01:37:38.564 [function-timer-thread-90-1] INFO org.apache.pulsar.functions.runtime.ProcessRuntime - Started process successfully
Using function root classloader: sun.misc.Launcher$AppClassLoader@7852e922
Using function instance classloader: java.net.URLClassLoader@5c647e05
Starting function instance...
Loading class com.mysql.jdbc.Driver'. This is deprecated. The new driver class is com.mysql.cj.jdbc.Driver'. The driver is automatically registered via the SPI and manual loading of the driver class is generally unnecessary.
01:38:04.892 [pulsar-web-57-12] INFO org.eclipse.jetty.server.RequestLog - 172.17.0.2 - - [29/Oct/2019:01:38:04 +0000] "GET /admin/v2/persistent/public/functions/coordinate/stats HTTP/1.1" 200 812 "-" "Pulsar-Java-v2.4.1" 2
01:38:08.513 [function-timer-thread-90-1] ERROR org.apache.pulsar.functions.runtime.ProcessRuntime - Extracted Process death exception
java.lang.RuntimeException:
at org.apache.pulsar.functions.runtime.ProcessRuntime.tryExtractingDeathException(ProcessRuntime.java:380) ~[org.apache.pulsar-pulsar-functions-runtime-2.4.1.jar:2.4.1]
at org.apache.pulsar.functions.runtime.ProcessRuntime.isAlive(ProcessRuntime.java:367) ~[org.apache.pulsar-pulsar-functions-runtime-2.4.1.jar:2.4.1]
at org.apache.pulsar.functions.runtime.RuntimeSpawner.lambda$start$0(RuntimeSpawner.java:88) ~[org.apache.pulsar-pulsar-functions-runtime-2.4.1.jar:2.4.1]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_212]
at java.util.concurrent.FutureTask.runAndReset(FutureTask.java:308) [?:1.8.0_212]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(ScheduledThreadPoolExecutor.java:180) [?:1.8.0_212]
at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:294) [?:1.8.0_212]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_212]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_212]
at io.netty.util.concurrent.FastThreadLocalRunnable.run(FastThreadLocalRunnable.java:30) [io.netty-netty-all-4.1.32.Final.jar:4.1.32.Final]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_212]
01:38:08.517 [function-timer-thread-90-1] ERROR org.apache.pulsar.functions.runtime.RuntimeSpawner - public/default/pulsar-mysql-jdbc-sink-java.lang.RuntimeException: Function Container is dead with exception.. restarting

Please advise. Thanks.

[tuteng]

Please try use localrun to start and look at broker's log.

bin/pulsar-admin sinks localrun --archive ./connectors/pulsar-io-jdbc-2.4.1.nar --inputs pulsar-mysql-jdbc-sink-topic --name pulsar-mysql-jdbc-sink --sink-config-file ./connectors/pulsar-mysql-jdbc-sink.yaml --parallelism 1

References: http://pulsar.apache.org/docs/en/next/io-debug/#debug-in-localrun-mode

[rec7y33]

This is the log:

Warning: Nashorn engine is planned to be removed from a future JDK release
Warning: Nashorn engine is planned to be removed from a future JDK release
11:13:48.959 [main] INFO org.apache.pulsar.functions.utils.io.ConnectorUtils - Searching for connectors in /Users/meta/Documents/apache-pulsar-2.4.1/connectors
11:13:49.222 [main] INFO org.apache.pulsar.common.nar.NarClassLoader - Created class loader with paths: [file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/animal-sniffer-annotations-1.17.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/async-http-client-2.7.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/async-http-client-netty-utils-2.7.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/avro-1.8.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/avro-protobuf-1.8.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bcpkix-jdk15on-1.60.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bcprov-ext-jdk15on-1.60.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bcprov-jdk15on-1.60.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bookkeeper-common-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bookkeeper-common-allocator-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bookkeeper-stats-api-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/checker-compat-qual-2.5.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/circe-checksum-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/client-java-2.0.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/client-java-api-2.0.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/client-java-proto-2.0.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-codec-1.10.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-compress-1.15.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-configuration-1.10.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-lang-2.6.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-lang3-3.4.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-logging-1.1.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/cpu-affinity-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/error_prone_annotations-2.1.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/freebuilder-1.14.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/google-auth-library-credentials-0.9.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-all-1.18.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-auth-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-context-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-core-1.18.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-netty-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-okhttp-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-protobuf-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-protobuf-lite-1.18.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-protobuf-nano-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-stub-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-testing-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/gson-2.8.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/guava-21.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/hamcrest-core-1.3.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/httpclient-4.5.5.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/httpcore-4.4.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-annotations-2.9.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-core-2.9.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-core-asl-1.9.13.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-databind-2.9.9.3.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-dataformat-yaml-2.9.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-mapper-asl-1.9.13.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-module-jsonSchema-2.9.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/javax.activation-1.2.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/javax.annotation-api-1.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jcommander-1.48.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jctools-core-2.1.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jetty-util-9.4.12.v20180830.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/joda-time-2.10.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jsr305-3.0.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/junit-4.12.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/log4j-api-2.10.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/log4j-core-2.10.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/log4j-slf4j-impl-2.10.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/logging-interceptor-2.7.5.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/lz4-java-1.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/memory-0.8.3.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/mysql-connector-java-8.0.11.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-all-4.1.32.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-buffer-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-codec-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-codec-http-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-codec-http2-4.1.32.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-codec-socks-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-common-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-handler-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-handler-proxy-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-reactive-streams-2.0.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-resolver-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-tcnative-boringssl-static-2.0.20.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-transport-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/objenesis-2.6.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/okhttp-2.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/okhttp-ws-2.7.5.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/okio-1.13.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/opencensus-api-0.18.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/opencensus-contrib-grpc-metrics-0.18.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/paranamer-2.7.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/proto-google-common-protos-1.0.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/protobuf-java-2.6.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/protobuf-java-util-3.5.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/protobuf-javanano-3.0.0-alpha-5.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/protobuf-shaded-2.1.0-incubating.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-client-api-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-client-original-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-common-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-functions-api-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-functions-instance-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-functions-proto-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-functions-secrets-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-functions-utils-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-io-core-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/reactive-streams-1.0.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/simpleclient-0.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/simpleclient_common-0.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/simpleclient_hotspot-0.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/simpleclient_httpserver-0.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/sketches-core-0.8.3.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/slf4j-api-1.7.25.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/snakeyaml-1.23.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/snappy-java-1.1.1.3.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/sqlite-jdbc-3.8.11.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/stream-storage-java-client-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/swagger-annotations-1.5.21.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/typetools-0.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/validation-api-1.1.0.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/xz-1.5.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/zstd-jni-1.3.7-3.jar]
11:13:49.226 [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 /Users/meta/Documents/apache-pulsar-2.4.1/connectors/pulsar-io-jdbc-2.4.1.nar
11:13:49.495 [main] INFO org.apache.pulsar.common.nar.NarClassLoader - Created class loader with paths: [file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/animal-sniffer-annotations-1.17.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/async-http-client-2.7.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/async-http-client-netty-utils-2.7.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/avro-1.8.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/avro-protobuf-1.8.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bcpkix-jdk15on-1.60.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bcprov-ext-jdk15on-1.60.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bcprov-jdk15on-1.60.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bookkeeper-common-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bookkeeper-common-allocator-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/bookkeeper-stats-api-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/checker-compat-qual-2.5.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/circe-checksum-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/client-java-2.0.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/client-java-api-2.0.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/client-java-proto-2.0.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-codec-1.10.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-compress-1.15.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-configuration-1.10.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-lang-2.6.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-lang3-3.4.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/commons-logging-1.1.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/cpu-affinity-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/error_prone_annotations-2.1.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/freebuilder-1.14.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/google-auth-library-credentials-0.9.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-all-1.18.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-auth-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-context-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-core-1.18.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-netty-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-okhttp-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-protobuf-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-protobuf-lite-1.18.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-protobuf-nano-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-stub-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/grpc-testing-1.12.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/gson-2.8.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/guava-21.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/hamcrest-core-1.3.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/httpclient-4.5.5.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/httpcore-4.4.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-annotations-2.9.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-core-2.9.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-core-asl-1.9.13.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-databind-2.9.9.3.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-dataformat-yaml-2.9.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-mapper-asl-1.9.13.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jackson-module-jsonSchema-2.9.9.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/javax.activation-1.2.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/javax.annotation-api-1.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jcommander-1.48.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jctools-core-2.1.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jetty-util-9.4.12.v20180830.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/joda-time-2.10.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/jsr305-3.0.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/junit-4.12.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/log4j-api-2.10.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/log4j-core-2.10.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/log4j-slf4j-impl-2.10.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/logging-interceptor-2.7.5.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/lz4-java-1.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/memory-0.8.3.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/mysql-connector-java-8.0.11.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-all-4.1.32.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-buffer-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-codec-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-codec-http-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-codec-http2-4.1.32.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-codec-socks-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-common-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-handler-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-handler-proxy-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-reactive-streams-2.0.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-resolver-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-tcnative-boringssl-static-2.0.20.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/netty-transport-4.1.31.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/objenesis-2.6.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/okhttp-2.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/okhttp-ws-2.7.5.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/okio-1.13.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/opencensus-api-0.18.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/opencensus-contrib-grpc-metrics-0.18.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/paranamer-2.7.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/proto-google-common-protos-1.0.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/protobuf-java-2.6.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/protobuf-java-util-3.5.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/protobuf-javanano-3.0.0-alpha-5.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/protobuf-shaded-2.1.0-incubating.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-client-api-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-client-original-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-common-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-functions-api-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-functions-instance-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-functions-proto-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-functions-secrets-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-functions-utils-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/pulsar-io-core-2.4.1.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/reactive-streams-1.0.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/simpleclient-0.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/simpleclient_common-0.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/simpleclient_hotspot-0.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/simpleclient_httpserver-0.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/sketches-core-0.8.3.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/slf4j-api-1.7.25.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/snakeyaml-1.23.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/snappy-java-1.1.1.3.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/sqlite-jdbc-3.8.11.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/stream-storage-java-client-4.9.2.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/swagger-annotations-1.5.21.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/typetools-0.5.0.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/validation-api-1.1.0.Final.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/xz-1.5.jar, file:/var/folders/zb/yq032w7151396ftlxzgty5m80000gn/T/pulsar-nar/pulsar-io-jdbc-2.4.1.nar-unpacked/META-INF/bundled-dependencies/zstd-jni-1.3.7-3.jar]
WARNING: An illegal reflective access operation has occurred
WARNING: Illegal reflective access by com.google.protobuf.UnsafeUtil (file:/Users/meta/Documents/apache-pulsar-2.4.1/lib/com.google.protobuf-protobuf-java-3.5.1.jar) to field java.nio.Buffer.address
WARNING: Please consider reporting this to the maintainers of com.google.protobuf.UnsafeUtil
WARNING: Use --illegal-access=warn to enable warnings of further illegal reflective access operations
WARNING: All illegal access operations will be denied in a future release
11:13:49.931 [main] INFO org.apache.pulsar.functions.runtime.RuntimeSpawner - public/default/pulsar-mysql-jdbc-sink-0 RuntimeSpawner starting function
11:13:49.931 [main] INFO org.apache.pulsar.functions.runtime.ThreadRuntime - ThreadContainer starting function with instance config InstanceConfig(instanceId=0, functionId=6a9847e1-e6eb-4dd4-a107-0409522eabf4, functionVersion=397dd564-9a7c-475a-9706-54677c674a08, functionDetails=tenant: "public"
namespace: "default"
name: "pulsar-mysql-jdbc-sink"
className: "org.apache.pulsar.functions.api.utils.IdentityFunction"
autoAck: true
parallelism: 1
source {
typeClassName: "org.apache.pulsar.client.api.schema.GenericRecord"
inputSpecs {
key: "pulsar-mysql-jdbc-sink-topic"
value {
}
}
cleanupSubscription: true
}
sink {
className: "org.apache.pulsar.io.jdbc.JdbcAutoSchemaSink"
configs: "{"userName":"root","password":"jdbc","jdbcUrl":"jdbc:mysql://127.0.0.1:3306/pulsar_mysql_jdbc_sink","tableName":"pulsar_mysql_jdbc_sink"}"
typeClassName: "org.apache.pulsar.client.api.schema.GenericRecord"
}
resources {
cpu: 1.0
ram: 1073741824
disk: 10737418240
}
componentType: SINK
, maxBufferedTuples=1024, functionAuthenticationSpec=null, port=51222, clusterName=local)
Loading class com.mysql.jdbc.Driver'. This is deprecated. The new driver class is com.mysql.cj.jdbc.Driver'. The driver is automatically registered via the SPI and manual loading of the driver class is generally unnecessary.
Tue Oct 29 11:13:50 MYT 2019 WARN: Establishing SSL connection without server's identity verification is not recommended. According to MySQL 5.5.45+, 5.6.26+ and 5.7.6+ requirements SSL connection must be established by default if explicit option isn't set. For compliance with existing applications not using SSL the verifyServerCertificate property is set to 'false'. You need either to explicitly disable SSL by setting useSSL=false, or set useSSL=true and provide truststore for server certificate verification.
11:13:50.715 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xc569cd03, L:/127.0.0.1:51224 - R:localhost/127.0.0.1:6650]] Connected to server
11:13:50.742 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.PulsarClientImpl - Configuring schema for topic pulsar-mysql-jdbc-sink-topic : {
"name": "public/default/pulsar-mysql-jdbc-sink-topic",
"schema": {
"type": "record",
"name": "Test",
"fields": [
{
"name": "id",
"type": [
"null",
"int"
]
},
{
"name": "name",
"type": [
"null",
"string"
]
}
]
},
"type": "AVRO",
"properties": {}
}
11:13:50.893 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.schema.AutoConsumeSchema - Configure topic schema for topic pulsar-mysql-jdbc-sink-topic : {"type":"record","name":"Test","fields":[{"name":"id","type":["null","int"]},{"name":"name","type":["null","string"]}]}
11:13:50.925 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer perf with config: {
"topicNames" : [ "pulsar-mysql-jdbc-sink-topic" ],
"topicsPattern" : null,
"subscriptionName" : "public/default/pulsar-mysql-jdbc-sink",
"subscriptionType" : "Shared",
"receiverQueueSize" : 1000,
"acknowledgementsGroupTimeMicros" : 100000,
"negativeAckRedeliveryDelayMicros" : 60000000,
"maxTotalReceiverQueueSizeAcrossPartitions" : 50000,
"consumerName" : null,
"ackTimeoutMillis" : 0,
"tickDurationMillis" : 1000,
"priorityLevel" : 0,
"cryptoFailureAction" : "CONSUME",
"properties" : {
"application" : "pulsar-sink",
"id" : "public/default/pulsar-mysql-jdbc-sink",
"instance_id" : "0"
},
"readCompacted" : false,
"subscriptionInitialPosition" : "Latest",
"patternAutoDiscoveryPeriod" : 1,
"regexSubscriptionMode" : "PersistentOnly",
"deadLetterPolicy" : null,
"autoUpdatePartitions" : true,
"replicateSubscriptionState" : false,
"resetIncludeHead" : false
}
11:13:50.927 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: {
"serviceUrl" : "pulsar://localhost:6650",
"authPluginClassName" : null,
"authParams" : null,
"operationTimeoutMs" : 30000,
"statsIntervalSeconds" : 60,
"numIoThreads" : 1,
"numListenerThreads" : 1,
"connectionsPerBroker" : 1,
"useTcpNoDelay" : true,
"useTls" : false,
"tlsTrustCertsFilePath" : null,
"tlsAllowInsecureConnection" : false,
"tlsHostnameVerificationEnable" : false,
"concurrentLookupRequest" : 5000,
"maxLookupRequest" : 50000,
"maxNumberOfRejectedRequestPerConnection" : 50,
"keepAliveIntervalSeconds" : 30,
"connectionTimeoutMs" : 10000,
"requestTimeoutMs" : 60000,
"defaultBackoffIntervalNanos" : 100000000,
"maxBackoffIntervalNanos" : 30000000000
}
11:13:50.940 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0x3deb28ee, L:/127.0.0.1:51225 - R:localhost/127.0.0.1:6650]] Connected to server
11:13:50.940 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ClientCnx - [id: 0x3deb28ee, L:/127.0.0.1:51225 - R:localhost/127.0.0.1:6650] Connected through proxy to target broker at a7d6eb0588a3:6650
11:13:50.942 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [pulsar-mysql-jdbc-sink-topic][public/default/pulsar-mysql-jdbc-sink] Subscribing to topic on cnx [id: 0x3deb28ee, L:/127.0.0.1:51225 - R:localhost/127.0.0.1:6650]
11:13:50.961 [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConsumerImpl - [pulsar-mysql-jdbc-sink-topic][public/default/pulsar-mysql-jdbc-sink] Subscribed to topic on localhost/127.0.0.1:6650 -- consumer: 0

Seems running fine?