[influxdb] IllegalAccessError while writing to InfluxDB

[a***@reflektion.com]

I am working on a Flink batch job that writes data to InfluxDB, using this library ( https://github.com/paulgoldbaum/scala-influxdb-client )

relevant dependencies:
"com.paulgoldbaum" %% "scala-influxdb-client" % "0.5.2"
"org.apache.flink" %% "flink-scala" % "1.3.2"

Everything compiles and runs on my local computer, but when I do sbt assembly jar and run via flink run command, it gives the following error.

Caused by: java.lang.IllegalAccessError: tried to access field io.netty.handler.ssl.JdkSslContext.SUPPORTED_CIPHERS from class io.netty.handler.ssl.NettySslPackageAccessor
at io.netty.handler.ssl.NettySslPackageAccessor.jdkSupportedCipherSuites(NettySslPackageAccessor.java:24)
at org.asynchttpclient.config.AsyncHttpClientConfigDefaults.defaultEnabledCipherSuites(AsyncHttpClientConfigDefaults.java:85)
at org.asynchttpclient.DefaultAsyncHttpClientConfig$Builder.<init>(DefaultAsyncHttpClientConfig.java:635)
at org.asynchttpclient.DefaultAsyncHttpClient.<init>(DefaultAsyncHttpClient.java:67)
at com.paulgoldbaum.influxdbclient.HttpClient.<init>(HttpClient.scala:21)
at com.paulgoldbaum.influxdbclient.InfluxDB$.connect(InfluxDB.scala:16)
at com.rfk.dataplatform.batch.common.io.influxdb.InfluxOutputFormat.open(InfluxOutputFormat.scala:48)
at org.apache.flink.runtime.operators.DataSinkTask.invoke(DataSinkTask.java:178)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:655)
at java.lang.Thread.run(Thread.java:748)

I came across the same problem here https://stackoverflow.com/questions/41689643/illegalaccesserror-in-spark-caused-by-async-http-client
But even that solution doesn't work it.

Can anyone help me with this?

Thanks

[e***@apolloagriculture.com]

I'm seeing this error as well.

Post by a***@reflektion.com
I am working on a Flink batch job that writes data to InfluxDB, using this library ( https://github.com/paulgoldbaum/scala-influxdb-client )
"com.paulgoldbaum" %% "scala-influxdb-client" % "0.5.2"
"org.apache.flink" %% "flink-scala" % "1.3.2"
Everything compiles and runs on my local computer, but when I do sbt assembly jar and run via flink run command, it gives the following error.
Caused by: java.lang.IllegalAccessError: tried to access field io.netty.handler.ssl.JdkSslContext.SUPPORTED_CIPHERS from class io.netty.handler.ssl.NettySslPackageAccessor
at io.netty.handler.ssl.NettySslPackageAccessor.jdkSupportedCipherSuites(NettySslPackageAccessor.java:24)
at org.asynchttpclient.config.AsyncHttpClientConfigDefaults.defaultEnabledCipherSuites(AsyncHttpClientConfigDefaults.java:85)
at org.asynchttpclient.DefaultAsyncHttpClientConfig$Builder.<init>(DefaultAsyncHttpClientConfig.java:635)
at org.asynchttpclient.DefaultAsyncHttpClient.<init>(DefaultAsyncHttpClient.java:67)
at com.paulgoldbaum.influxdbclient.HttpClient.<init>(HttpClient.scala:21)
at com.paulgoldbaum.influxdbclient.InfluxDB$.connect(InfluxDB.scala:16)
at com.rfk.dataplatform.batch.common.io.influxdb.InfluxOutputFormat.open(InfluxOutputFormat.scala:48)
at org.apache.flink.runtime.operators.DataSinkTask.invoke(DataSinkTask.java:178)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:655)
at java.lang.Thread.run(Thread.java:748)
I came across the same problem here https://stackoverflow.com/questions/41689643/illegalaccesserror-in-spark-caused-by-async-http-client
But even that solution doesn't work it.
Can anyone help me with this?
Thanks