Caused by: java.lang.NoClassDefFoundError: Could not initialize class okhttp3.OkHttpClient
还没有人认领这个 Issue。
评估
调研方向
从 pom.xml 和经过 InfluxUtils.connect 与 SinkToInflux.open 的错误路径开始。将列出的依赖排除项和 classloader.resolve-order 设置与本地环境和集群环境进行比较，然后跟踪 okhttp3.OkHttpClient 的完整初始化原因。确定一个可复现的原因，并记录或实现针对集群故障的修复，即视为完成。
由索引模型根据 Issue 内容生成。
描述
==Usage scenario==
Flink sink to influxDB.
The code runs locally without problem, and after being submitted to the cluster, receives the following error.
Operating system: Centos8,
Flink version: 1.10.0,
Hadoop version: 2.8.3
InfluxDB version: 1.7.1
==flink-conf.xml==
classloader.resolve-order: child-first
==error log==
Caused by: java.lang.NoClassDefFoundError: Could not initialize class okhttp3.OkHttpClient
at okhttp3.OkHttpClient$Builder.(OkHttpClient.java:449)
at com.rexel.stream.utils.InfluxUtils.connect(InfluxUtils.java:57)
at com.rexel.stream.flink.sink.SinkToInflux.open(SinkToInflux.java:38)
at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:36)
at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:102)
at org.apache.flink.streaming.api.operators.StreamSink.open(StreamSink.java:48)
at org.apache.flink.streaming.runtime.tasks.StreamTask.initializeStateAndOpen(StreamTask.java:1007)
at org.apache.flink.streaming.runtime.tasks.StreamTask.lambda$beforeInvoke$0(StreamTask.java:454)
at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.runThrowing(StreamTaskActionExecutor.java:94)
at org.apache.flink.streaming.runtime.tasks.StreamTask.beforeInvoke(StreamTask.java:449)
at org.apache.flink.streaming.runtime.tasks.StreamTask.invoke(StreamTask.java:461)
at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:707)
at org.apache.flink.runtime.taskmanager.Task.run(Task.java:532)
at java.lang.Thread.run(Thread.java:748)
pom.xml
rexel-ids
com.rexel
1.0.0
4.0.0
rexel-stream
<maven.install.skip>true</maven.install.skip>
<commons-codec.version>1.10</commons-codec.version>
<flink.version>1.10.0</flink.version>
<fastjson.version>1.2.72</fastjson.version>
<influxdb-java.version>2.8</influxdb-java.version>
<logback.version>1.2.3</logback.version>
<lombok.version>1.18.12</lombok.version>
<mysql-connector-java.version>8.0.19</mysql-connector-java.version>
<rocketmq.version>4.5.0</rocketmq.version>
<qpid-jms-client.version>0.49.0</qpid-jms-client.version>
<rocketmq.version>4.5.0</rocketmq.version>
<taos-jdbcdriver.version>2.0.12</taos-jdbcdriver.version>
org.apache.flink
flink-java
${flink.version}
org.apache.flink
flink-streaming-java_2.11
${flink.version}
org.apache.flink
flink-clients_2.11
${flink.version}
ch.qos.logback
logback-core
${logback.version}
ch.qos.logback
logback-access
${logback.version}
ch.qos.logback
logback-classic
${logback.version}
com.alibaba
fastjson
${fastjson.version}
org.projectlombok
lombok
${lombok.version}
org.apache.qpid
qpid-jms-client
${qpid-jms-client.version}
mysql
mysql-connector-java
${mysql-connector-java.version}
org.apache.rocketmq
rocketmq-client
${rocketmq.version}
org.apache.rocketmq
rocketmq-acl
${rocketmq.version}
commons-cli
commons-cli
org.apache.rocketmq
rocketmq-tools
${rocketmq.version}
org.apache.rocketmq
rocketmq-common
${rocketmq.version}
commons-codec
commons-codec
${commons-codec.version}
com.taosdata.jdbc
taos-jdbcdriver
${taos-jdbcdriver.version}
org.influxdb
influxdb-java
${influxdb-java.version}
com.squareup.okio
okio
maven-compiler-plugin
3.1
1.8
1.8
maven-assembly-plugin
2.4
jar-with-dependencies
make-assembly
package
single
- 主要语言
- Java
- 星标
- 1.2k
- 派生
- 468
- PR 合并指标
- 30 天内没有已合并 PR
环境准备
这个项目没有提供开发容器、Dockerfile 或贡献指南，环境需要你自己搭建：先看它的 README，通用步骤见我们的新手贡献指南。
从这里开始
- 先读完整个 Issue，再读项目的贡献指南。
- 在 Issue 下留言说明你要接手 —— 这能避免两个人做同样的事。
- Fork 仓库，在一个分支上完成修改。
- 提交 Pull Request，并在描述里引用这个 Issue 编号。
influxdata/influxdb-java 的其他 Issue
-
难度 4/5 3-5 天 新手友好度 38/100
influxdata/influxdb-java#1012 ·
-
难度 5/5 一周以上 新手友好度 30/100
influxdata/influxdb-java#1006 · 1 条评论 · 1 个 reaction ·
-
难度 4/5 3-5 天 新手友好度 25/100
influxdata/influxdb-java#1005 · 3 条评论 ·
-
难度 3/5 1-2 天 新手友好度 35/100
influxdata/influxdb-java#999 ·
-
难度 4/5 3-5 天 新手友好度 35/100
influxdata/influxdb-java#970 ·
查看 influxdata/influxdb-java 的全部 Issue
相似的 Issue
-
难度 2/5 1-3 小时 新手友好度 65/100
wildfly/wildfly-launcher#99 ·
-
难度 2/5 1-3 小时 新手友好度 78/100
-
难度 2/5 1-3 小时 新手友好度 75/100
traccar/traccar#6076 · 2 条评论 ·
维护者通常 1 天内回复
-
Flight SQL JDBC parses boolean properties case-sensitively, silently disabling TLS for useEncryption=TRUE可能已有人在做 @Arawoof06 今天认领。 未关闭
难度 2/5 1-3 小时 新手友好度 79/100
apache/arrow-java#1357 ·
维护者通常 1 天内回复
-
[Bug] Demo alert imports accept empty and oversized rule documents可能已有人在做 关联的 PR 仍在进行中或已合并。 未关闭
难度 2/5 1-3 小时 新手友好度 77/100
apache/rocketmq-dashboard#6610 ·
维护者通常 3 天内回复