@@ -130,19 +130,26 @@ https://mvnrepository.com/artifact/org.apache.flink/flink-shaded-hadoop-3-uber?r
130
130
│ ├── dlink-app-1.13-${VERSION}-jar-with-dependencies.jar -- 适配 Flink1.13.x application
131
131
│ ├── dlink-app-1.14-${VERSION}-jar-with-dependencies.jar -- 适配 Flink1.14.x application
132
132
│ ├── dlink-app-1.15-${VERSION}-jar-with-dependencies.jar -- 适配 Flink1.15.x application
133
- │ └── dlink-app-1.16-${VERSION}-jar-with-dependencies.jar -- 适配 Flink1.16.x application
133
+ │ ├── dlink-app-1.16-${VERSION}-jar-with-dependencies.jar -- 适配 Flink1.16.x application
134
+ │ └── dlink-app-1.17-${VERSION}-jar-with-dependencies.jar -- 适配 Flink1.17.x application
134
135
├── lib
135
136
│ ├── dlink-admin-${VERSION}.jar --主程序包
136
137
│ ├── dlink-alert-base-${VERSION}.jar
137
138
│ ├── dlink-alert-dingtalk-${VERSION}.jar
138
139
│ ├── dlink-alert-email-${VERSION}.jar
139
140
│ ├── dlink-alert-feishu-${VERSION}.jar
141
+ │ ├── dlink-alert-sms-${VERSION}.jar
140
142
│ ├── dlink-alert-wechat-${VERSION}.jar
143
+ │ ├── dlink-catalog-mysql-1.14-${VERSION}.jar
144
+ │ ├── dlink-cdc-core-${VERSION}.jar
141
145
│ ├── dlink-client-base-${VERSION}.jar
146
+ │ ├── dlink-client-${VERSION}.jar
147
+ │ ├── dlink-client-hadoop-${VERSION}.jar
142
148
│ ├── dlink-common-${VERSION}.jar
149
+ │ ├── dlink-connector-jdbc-1.14-${VERSION}.jar
143
150
│ ├── dlink-core-${VERSION}.jar
144
151
│ ├── dlink-daemon-${VERSION}.jar
145
- │ ├── dlink-executor -${VERSION}.jar
152
+ │ ├── dlink-flink-1.14 -${VERSION}.jar
146
153
│ ├── dlink-function-${VERSION}.jar
147
154
│ ├── dlink-gateway-${VERSION}.jar
148
155
│ ├── dlink-metadata-base-${VERSION}.jar
@@ -156,8 +163,84 @@ https://mvnrepository.com/artifact/org.apache.flink/flink-shaded-hadoop-3-uber?r
156
163
│ ├── dlink-metadata-presto-${VERSION}.jar
157
164
│ ├── dlink-metadata-sqlserver-${VERSION}.jar
158
165
│ ├── dlink-metadata-starrocks-${VERSION}.jar
159
- │ ├── dlink-process-${VERSION}.jar
160
166
│ ├── dlink-scheduler-${VERSION}.jar
167
+ │ ├── accessors-smart-2.4.9.jar
168
+ │ ├── activation-1.1.1.jar
169
+ │ ├── aircompressor-0.8.jar
170
+ │ ├── ant-1.6.5.jar
171
+ │ ├── ant-1.9.1.jar
172
+ │ ├── ant-launcher-1.9.1.jar
173
+ │ ├── antlr-runtime-3.5.2.jar
174
+ │ ├── aopalliance-1.0.jar
175
+ │ ├── argparse4j-0.8.1.jar
176
+ │ ├── asm-3.1.jar
177
+ │ ├── asm-9.3.jar
178
+ │ ├── asm-all-5.0.2.jar
179
+ │ ├── asm-commons-3.1.jar
180
+ │ ├── asm-tree-3.1.jar
181
+ │ ├── aspectjweaver-1.9.7.jar
182
+ │ ├── audience-annotations-0.5.0.jar
183
+ │ ├── avatica-core-1.17.0.jar
184
+ │ ├── avro-1.7.7.jar
185
+ │ ├── awaitility-4.2.0.jar
186
+ │ ├── aws-java-sdk-core-1.12.589.jar
187
+ │ ├── aws-java-sdk-kms-1.12.589.jar
188
+ │ ├── aws-java-sdk-s3-1.12.589.jar
189
+ │ ├── bcpkix-jdk15on-1.69.jar
190
+ │ ├── bcprov-ext-jdk15on-1.69.jar
191
+ │ ├── bcprov-jdk15on-1.69.jar
192
+ │ ├── bcutil-jdk15on-1.69.jar
193
+ │ ├── bonecp-0.8.0.RELEASE.jar
194
+ │ ├── byte-buddy-1.12.23.jar
195
+ │ ├── checker-qual-3.12.0.jar
196
+ │ ├── chill_2.12-0.7.6.jar
197
+ │ ├── chill-java-0.7.6.jar
198
+ │ ├── classgraph-4.1.7.jar
199
+ │ ├── classmate-1.5.1.jar
200
+ │ ├── clickhouse-jdbc-0.2.6.jar
201
+ │ ├── commonmark-0.21.0.jar
202
+ │ ├── commons-beanutils-1.9.4.jar
203
+ │ ├── commons-cli-1.3.1.jar
204
+ │ ├── commons-codec-1.15.jar
205
+ │ ├── commons-collections-3.2.2.jar
206
+ │ ├── commons-collections4-4.4.jar
207
+ │ ├── commons-compiler-3.1.9.jar
208
+ │ ├── commons-compress-1.21.jar
209
+ │ ├── commons-configuration2-2.1.1.jar
210
+ │ ├── commons-csv-1.0.jar
211
+ │ ├── commons-daemon-1.0.13.jar
212
+ │ ├── commons-dbcp-1.4.jar
213
+ │ ├── commons-el-1.0.jar
214
+ │ ├── commons-email-1.5.jar
215
+ │ ├── commons-httpclient-3.1.jar
216
+ │ ├── commons-io-2.11.0.jar
217
+ │ ├── commons-jexl3-3.2.1.jar
218
+ │ ├── commons-lang-2.6.jar
219
+ │ ├── commons-lang3-3.3.2.jar
220
+ │ ├── commons-logging-1.2.jar
221
+ │ ├── commons-math-2.2.jar
222
+ │ ├── commons-math3-3.6.1.jar
223
+ │ ├── commons-net-3.6.jar
224
+ │ ├── commons-pool-1.6.jar
225
+ │ ├── commons-text-1.4.jar
226
+ │ ├── curator-client-4.2.0.jar
227
+ │ ├── curator-framework-2.7.1.jar
228
+ │ ├── curator-recipes-4.2.0.jar
229
+ │ ├── curvesapi-1.07.jar
230
+ │ ├── datanucleus-api-jdo-4.2.4.jar
231
+ │ ├── datanucleus-core-4.1.17.jar
232
+ │ ├── datanucleus-rdbms-4.1.19.jar
233
+ │ ├── derby-10.14.2.0.jar
234
+ │ ├── disruptor-3.3.6.jar
235
+ │ ├── dnsjava-2.1.7.jar
236
+ │ ├── docker-java-api-3.2.14.jar
237
+ │ ├── docker-java-core-3.2.14.jar
238
+ │ ├── docker-java-transport-3.2.14.jar
239
+ │ ├── docker-java-transport-httpclient5-3.2.14.jar
240
+ │ ├── dropwizard-metrics-hadoop-metrics2-reporter-0.1.2.jar
241
+ │ ├── druid-1.2.8.jar
242
+ │ ├── druid-spring-boot-starter-1.2.8.jar
243
+ │ ├── easy-rules-core-4.1.0.jar
161
244
├── plugins
162
245
│ ├── flink1.13 -- 适配 Flink1.13.x
163
246
│ ├── dinky-connector-jdbc-1.13-${VERSION}.jar -- dlink 的 jdbc 连接器增强实现
@@ -170,9 +253,13 @@ https://mvnrepository.com/artifact/org.apache.flink/flink-shaded-hadoop-3-uber?r
170
253
│ ├── flink1.15 -- 适配 Flink1.15.x
171
254
│ │ ├── dlink-catalog-mysql-1.15-${VERSION}.jar -- dlink 的 catalog 实现
172
255
│ │ └── dlink-client-1.15-${VERSION}.jar
173
- │ └── flink1.16 -- 适配 Flink1.15.x
174
- │ ├── dlink-catalog-mysql-1.16-${VERSION}.jar -- dlink 的 catalog 实现
175
- │ └── dlink-client-1.16-${VERSION}.jar
256
+ │ ├── flink1.16 -- 适配 Flink1.15.x
257
+ │ │ ├── dlink-catalog-mysql-1.16-${VERSION}.jar -- dlink 的 catalog 实现
258
+ │ │ └── dlink-client-1.16-${VERSION}.jar
259
+ │ ├── flink1.16 -- 适配 Flink1.15.x
260
+ │ ├── dlink-catalog-mysql-1.17-${VERSION}.jar -- dlink 的 catalog 实现
261
+ │ │ └── dlink-client-1.17-${VERSION}.jar
262
+ │ └──
176
263
└── sql
177
264
├── dinky-mysql.sql -- Mysql 首次初始化脚本
178
265
└── upgrade -- 各个版本的升级 SQL
@@ -196,7 +283,7 @@ sh auto.sh status
196
283
```
197
284
198
285
#### 版本适配
199
- 启动指令的第二个参数则是版本选择,支持 【1.13, 1.14, 1.15, 1.16】,参考指令如下:
286
+ 启动指令的第二个参数则是版本选择,支持 【1.13, 1.14, 1.15, 1.16,1.17 】,参考指令如下:
200
287
``` shell
201
288
# 启动
202
289
sh auto.sh start 1.14
0 commit comments