← All tasks
javaDTStack/chunjun #1710Not a task: not reproduced

[Bug] [connector] [dm] [elasticsearch7] 找不到依赖包

envgap__DTStack__chunjun-1710

01 / FAILURE SIGNATURE

As reported upstream

java.lang.RuntimeException: java.lang.ClassNotFoundException: dm.jdbc.driver.DmDriver
Not a benchmark task.
  • In a clean container the reported failure did not reproduce, or the known fix did not make the project run.

02 / ENVIRONMENT RECIPE

Base commit
569412eade5e2ec3208dbfdea3cd1fa80bb2d5b1
Manifest
chunjun-connectors/chunjun-connector-dm/pom.xml
Reproduce
Awaiting issue-specific recipe
Run under trace
Awaiting a meaningful runtime command

03 / ORIGINAL ISSUE TEXT

DTStack/chunjun #1710 · read the original issue
### Search before asking

- [X] I had searched in the [issues](https://github.com/DTStack/chunjun/issues) and found no similar issues.


### What happened

找不到依赖包





```



2023-06-05 10:50:10,329 INFO  org.apache.flink.runtime.executiongraph.ExecutionGraph       [] - Source: source[1] -> Sink: sink[2] (1/1) (fdd3a2040c136b635aa9b7bfdab2dc68_cbc357ccb763df2852fee8c4fc7d55f2_0_0) switched from INITIALIZING to FAILED on container_e225_1683781588671_701059_01_000002 @ 10.x.x.x (dataPort=33044).

java.lang.RuntimeException: java.lang.ClassNotFoundException: dm.jdbc.driver.DmDriver

	at com.dtstack.chunjun.util.ClassUtil.forName(ClassUtil.java:34) ~[chunjun-core.jar:?]

	at com.dtstack.chunjun.connector.jdbc.util.JdbcUtil.getConnection(JdbcUtil.java:97) ~[chunjun-connector-hive-master.jar:?]

	at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.getConnection(JdbcOutputFormat.java:527) ~[chunjun-connector-hive-master.jar:?]

	at com.dtstack.chunjun.connector.jdbc.sink.JdbcOutputFormat.openInternal(JdbcOutputFormat.java:91) ~[chunjun-connector-hive-master.jar:?]

	at com.dtstack.chunjun.sink.format.BaseRichOutputFormat.open(BaseRichOutputFormat.java:280) ~[chunjun-core.jar:?]

	at com.dtstack.chunjun.sink.DtOutputFormatSinkFunction.open(DtOutputFormatSinkFunction.java:90) ~[chunjun-core.jar:?]

	at org.apache.flink.api.common.functions.util.FunctionUtils.openFunction(FunctionUtils.java:34) ~[flink-dist-1.16.1.jar:1.16.1]

	at org.apache.flink.streaming.api.operators.AbstractUdfStreamOperator.open(AbstractUdfStreamOperator.java:100) ~[flink-dist-1.16.1.jar:1.16.1]

	at org.apache.flink.table.runtime.operators.sink.SinkOperator.open(SinkOperator.java:58) ~[flink-table-runtime-1.16.1.jar:1.16.1]

	at org.apache.flink.streaming.runtime.tasks.RegularOperatorChain.initializeStateAndOpenOperators(RegularOperatorChain.java:107) ~[flink-dist-1.16.1.jar:1.16.1]

	at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreGates(StreamTask.java:726) ~[flink-dist-1.16.1.jar:1.16.1]

	at org.apache.flink.streaming.runtime.tasks.StreamTaskActionExecutor$SynchronizedStreamTaskActionExecutor.call(StreamTaskActionExecutor.java:100) ~[flink-dist-1.16.1.jar:1.16.1]

	at org.apache.flink.streaming.runtime.tasks.StreamTask.restoreInternal(StreamTask.java:702) ~[flink-dist-1.16.1.jar:1.16.1]

	at org.apache.flink.streaming.runtime.tasks.StreamTask.restore(StreamTask.java:669) ~[flink-dist-1.16.1.jar:1.16.1]

	at org.apache.flink.runtime.taskmanager.Task.runWithSystemExitMonitoring(Task.java:935) ~[flink-dist-1.16.1.jar:1.16.1]

	at org.apache.flink.runtime.taskmanager.Task.restoreAndInvoke(Task.java:904) ~[flink-dist-1.16.1.jar:1.16.1]

	at org.apache.flink.runtime.taskmanager.Task.doRun(Task.java:728) ~[flink-dist-1.16.1.jar:1.16.1]

	at org.apache.flink.runtime.taskmanager.Task.run(Task.java:550) ~[flink-dist-1.16.1.jar:1.16.1]

	at java.lang.Thread.run(Thread.java:745) ~[?:1.8.0_60]

Caused by: java.lang.ClassNotFoundException: dm.jdbc.driver.DmDriver

	at java.net.URLClassLoader.findClass(URLClassLoader.java:381) ~[?:1.8.0_60]

	at java.lang.ClassLoader.loadClass(ClassLoader.java:424) ~[?:1.8.0_60]

	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClassWithoutExceptionHandling(FlinkUserCodeClassLoader.java:67) ~[flink-dist-1.16.1.jar:1.16.1]

	at org.apache.flink.util.FlinkUserCodeClassLoader.loadClass(FlinkUserCodeClassLoader.java:51) ~[flink-dist-1.16.1.jar:1.16.1]

	at java.lang.ClassLoader.loadClass(ClassLoader.java:357) ~[?:1.8.0_60]

	at java.lang.Class.forName0(Native Method) ~[?:1.8.0_60]

	at java.lang.Class.forName(Class.java:348) ~[?:1.8.0_60]

	at com.dtstack.chunjun.util.ClassUtil.forName(ClassUtil.java:31) ~[chunjun-core.jar:?]

	... 18 more

2023-06-05 10:50:10,357 INFO  org.apache.flink.runtime.resourcemanager.slotmanager.DeclarativeSlotManager [] - Clearing resource requirements of job 78be9e309a665dcde9e747268f09a81b



```







```

Caused by: org.apache.flink.table.api.ValidationException: Cannot discover a connector using option: 'connector'='elasticsearch7-x'

	at org.apache.flink.table.factories.FactoryUtil.enrichNoMatchingConnectorError(FactoryUtil.java:735)

	at org.apache.flink.table.factories.FactoryUtil.discoverTableFactory(FactoryUtil.java:709)

	at org.apache.flink.table.factories.FactoryUtil.createDynamicTableSink(FactoryUtil.java:264)

	... 35 more

Caused by: org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'elasticsearch7-x' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.

```

### What you expected to happen

--

### How to reproduce

--

### Anything else

_No response_

### Version

master

### Are you willing to submit PR?

- [X] Yes I am willing to submit a PR!

### Code of Conduct

- [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct)
Continue on GitHub ↗

04 / LABELS

Labels from the report text only; not yet run

No supported category has been assigned.

Label rules and the text that matched
[]