Skip to content

Commit

Permalink
Merge pull request DataLinkDC#14 from aiwenmo/dev
Browse files Browse the repository at this point in the history
Update README.md
  • Loading branch information
aiwenmo authored Jun 7, 2021
2 parents 95bb133 + bde28e8 commit 17db331
Showing 1 changed file with 27 additions and 8 deletions.
35 changes: 27 additions & 8 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -91,12 +91,24 @@ DataLink 开源项目及社区正在建设,希望本项目可以帮助你更

## 部署

### 最新版本

dlink-0.1.0

### 从安装包开始

```
config/ -- 配置文件
|- application.yml
lib/ --外部依赖及Connector
lib/ -- 外部依赖及Connector
|- dlink-client-1.12.jar -- 必需
|- dlink-connector-jdbc.jar
|- flink-connector-jdbc_2.11-1.12.4.jar
|- flink-csv-1.12.4.jar
|- flink-json-1.12.4.jar
|- mysql-connector-java-8.0.21.jar
|- ojdbc6-11.2.0.3.jar
|- slf4j-api-1.7.30.jar -- 必需
sql/ --Mysql初始化脚本
|- auto.sh --启动停止脚本
|- dlink-admin.jar --程序包
Expand All @@ -122,7 +134,10 @@ sh auto.sh status
```java
dlink -- 父项目
|-dlink-admin -- 管理中心
|-dlink-connector -- Connector 中心
|-dlink-client -- Client 中心
| |-dlink-client-1.12 -- Client-1.12 实现
|-dlink-connectors -- Connectors 中心
| |-dlink-connector-jdbc -- Jdbc 扩展
|-dlink-core -- 执行中心
|-dlink-doc -- 文档
|-dlink-web -- React 前端
Expand All @@ -144,13 +159,16 @@ maven clean install -Dmaven.test.skip=true

#### 扩展Connector

当前版本扩展 FlinkSQL Connector 需要在源码中的 dlink-connector 的 pom 中引用依赖并重新编译打包进行扩展。后续版本将优化。
将 Flink 集群上已扩展好的 Connector 直接放入 Dlink 的 lib 下,然后重启即可。
定制 Connector 过程同 Flink 官方一样。

#### 扩展其他版本的Flink

当前版本默认为 Flink 1.12.4 API。如要扩展其他版本的 Flink ,需要在 dlink-connector 和 dlink-core 的 pom 中修改 flink.version 配置,编译时如出现类或方法找不到等异常则需要修改对应代码为对应版本的逻辑。
Flink 的版本取决于 lib 下的 dlink-client-1.12.jar。
当前版本默认为 Flink 1.12.4 API。
向其他版本的集群提交任务可能存在问题,未来将实现 1.13、1.11、1.10.

#### 源码质量较差问题
#### 源码质量一般问题

利用一个周写的项目所有代码,而且React从零边学边写,还请海涵~(> ^ <)~后续版本将优化代码逻辑。

Expand All @@ -172,9 +190,8 @@ maven clean install -Dmaven.test.skip=true

#### Studio

1. 在左侧目录区域创建文件夹或任务。右键打开任务。

2. 在中间编辑区编写FlinkSQL。
1. 在左侧目录区域创建文件夹或任务。
2. 在中间编辑区编写 FlinkSQL 。
3. 在右侧配置执行参数。
4. Fragment开启后,可以这样写,为了您方便:

Expand All @@ -193,6 +210,8 @@ select * from student
10. 执行 SQL 时,如果您选中了部分SQL,则会执行选中的内容,否则执行全部内容。
11. 小火箭的提交功能是异步提交当前任务保存的FlinkSQL及配置到集群。无法提交草稿。
12. 执行信息或者历史中那个很长很长的就是集群上的 JobId。
13. 草稿是无法被异步远程提交的,只能同步执行。
14. 灰色按钮代表近期将实现。

#### 使用技巧

Expand Down

0 comments on commit 17db331

Please sign in to comment.