DTStack / DTStack/chunjun

[Question][chunjun-connectors] 加入chunjun-core.jar和chunjun-connector-dm.jar到flink的lib后,flinksql不识别dm-x

Open
#1,695 6 comments 0 reactions 0 assignees View on GitHub
question
Dominant language
Java
Stars
4.1k
Forks
1.7k
PR merge metrics
No merged PRs in 30d

Description

### Search before asking

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

- [X] I had googled my question but i didn't get any help.

- [X] I had read the documentation: [ChunJun doc](https://dtstack.github.io/chunjun) but it didn't help me.

### Description

chunjun的版本使用的是master分支,pom里面使用的flink是1.16.1
flink的版本使用的是1.17.0

### 问题1:
自己编译后,chunjun-connector-dm.jar 是23kb,而从官网下载的 chunjun-dist-1.12-SNAPSHOT.tar.gz 里面的 chunjun-connector-dm.jar 是13M,这是改了打包机制了吗?

### 问题2:
把 chunjun-core.jar 和 chunjun-connector-dm.jar 放到 自己的 flink-1.17.0 的 lib 目录,启动 bin/sql-client.sh ,然后测试dm插件
报错:
```
java.lang.NoSuchMethodError: org.apache.flink.streaming.api.graph.StreamGraph.setAutoParallelismEnabled(Z)V
```

重写了下 StreamGraph ,重新打包 chunjun-core.jar
再运行,报错:
```
[ERROR] Could not execute SQL statement. Reason:
org.apache.flink.table.api.ValidationException: Could not find any factory for identifier 'dm-x' that implements 'org.apache.flink.table.factories.DynamicTableFactory' in the classpath.

Available factory identifiers are:

blackhole
datagen
doris
filesystem
mysql-cdc
print
python-input-format
```

我已经把 chunjun-connector-dm.jar 加入到了 flink 的 lib 目录,为什么还是找不到 dm-x 呢?

### Code of Conduct

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

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.