Skip to content
Projects
Groups
Snippets
Help
Loading...
Help
Contribute to GitLab
Sign in / Register
Toggle navigation
D
dlink
Project
Project
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
zhaowei
dlink
Commits
bde28e87
Commit
bde28e87
authored
Jun 07, 2021
by
wenmo
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Update README.md
parent
f40622f5
Changes
1
Hide whitespace changes
Inline
Side-by-side
Showing
1 changed file
with
27 additions
and
8 deletions
+27
-8
README.md
README.md
+27
-8
No files found.
README.md
View file @
bde28e87
...
...
@@ -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 --程序包
...
...
@@ -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
前端
...
...
@@ -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从零边学边写,还请海涵~(> ^ <)~后续版本将优化代码逻辑。
...
...
@@ -172,9 +190,8 @@ maven clean install -Dmaven.test.skip=true
#### Studio
1.
在左侧目录区域创建文件夹或任务。右键打开任务。
2.
在中间编辑区编写FlinkSQL。
1.
在左侧目录区域创建文件夹或任务。
2.
在中间编辑区编写 FlinkSQL 。
3.
在右侧配置执行参数。
4.
Fragment开启后,可以这样写,为了您方便:
...
...
@@ -193,6 +210,8 @@ select * from student
10.
执行 SQL 时,如果您选中了部分SQL,则会执行选中的内容,否则执行全部内容。
11.
小火箭的提交功能是异步提交当前任务保存的FlinkSQL及配置到集群。无法提交草稿。
12.
执行信息或者历史中那个很长很长的就是集群上的 JobId。
13.
草稿是无法被异步远程提交的,只能同步执行。
14.
灰色按钮代表近期将实现。
#### 使用技巧
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment