Skip to content

Commit 62f1a55

Browse files
committed
ui升级及优化
1 parent bf6df85 commit 62f1a55

File tree

159 files changed

+94
-19905
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

159 files changed

+94
-19905
lines changed

README.md

Lines changed: 4 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -18,8 +18,7 @@ https://xie.infoq.cn/article/1af0cb75be056fea788e6c86b
1818
**主要功能**:包含任务配置、启/停任务、告警、日志等功能,支持sql语法提示,格式化、sql语句校验。
1919

2020
**目的**:减少开发、降低成本 完全实现sql化 流计算任务。 😂
21-
22-
由于前端UI是本人自己写的,不够专业,样式有点丑 请多多包含!!!
21+
2322

2423
该项目获得 [Flink Forward Asia Hackathon (2021) 季军 ](https://mp.weixin.qq.com/s/J2OkX_D34ktfwSfhwdmXYQ)
2524

@@ -216,19 +215,12 @@ https://nightlies.apache.org/flink/flink-docs-release-1.13/zh/docs/connectors/ta
216215
## 七、RoadMap
217216

218217

219-
1、 支持除官方以外的连接器 如:阿里云的sls
220-
221-
2、 任务告警自动拉起 (完成)
222-
223-
3、 支持Application模式
224-
225-
4、 完善文档 (持续过程)
218+
1、支持多版本flink
226219

227-
5、 支持sql预校验,编写sql的时候语法提示等友好的用户体验(完成)
220+
2、 完善文档 (持续过程)
228221

229-
6、 checkpoint支持rocksDB (完成)
222+
3、UI
230223

231-
7、 支持jar模式提交任务 (完成)
232224

233225

234226

deployer/pom.xml

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@
1010
</parent>
1111
<modelVersion>4.0.0</modelVersion>
1212

13-
<groupId>com.streaming.platform.web</groupId>
1413
<artifactId>deployer</artifactId>
1514
<version>${flink_streaming_version}</version>
1615

deployer/src/main/bin/docker-deploy.sh

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,7 @@ ACTION=$1
66

77
##变量设置##
88
env=docker
9-
project="/data/projects/flink-streaming-platform-web/lib/flink-streaming-web-1.3.0.RELEASE.jar"
9+
project="/data/projects/flink-streaming-platform-web/lib/flink-streaming-web-1.4.0.RELEASE.jar"
1010

1111

1212
##JAVA_OPTS设置
Lines changed: 17 additions & 17 deletions
Original file line numberDiff line numberDiff line change
@@ -1,20 +1,20 @@
1-
# Nacos config
2-
nacos.core.auth.enabled=true
3-
nacos.config.bootstrap.enable=true
4-
nacos.config.server-addr=172.16.167.37:8848
5-
nacos.config.group=DEFAULT_GROUP
6-
nacos.config.data-id=flink-web.properties
7-
nacos.config.namespace=dev
8-
nacos.config.username=nacos
9-
nacos.config.password=nacos
10-
nacos.config.type=properties
11-
nacos.config.max-retry=10
12-
nacos.config.auto-refresh=true
13-
nacos.config.config-retry-time=2333
14-
nacos.config.config-long-poll-timeout=46000
1+
# 如果公司内部使用了nacos 可以将有些配置放到nacos 如果没有请不要填写相关配置
2+
#nacos.core.auth.enabled=true
3+
#nacos.config.bootstrap.enable=true
4+
#nacos.config.server-addr=172.16.167.37:8848
5+
#nacos.config.group=DEFAULT_GROUP
6+
#nacos.config.data-id=flink-web.properties
7+
#nacos.config.namespace=dev
8+
#nacos.config.username=nacos
9+
#nacos.config.password=nacos
10+
#nacos.config.type=properties
11+
#nacos.config.max-retry=10
12+
#nacos.config.auto-refresh=true
13+
#nacos.config.config-retry-time=2333
14+
#nacos.config.config-long-poll-timeout=46000
1515

1616
####jdbc信息
1717
server.port=9084
18-
spring.datasource.url=jdbc:mysql://db-master-fink-web-001.ch:3306/flink_web?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=false
19-
spring.datasource.username=xiaowu
20-
spring.datasource.password=xiaowu_8rt4BYy5T
18+
spring.datasource.url=jdbc:mysql://localhost:3306/flink_web?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=false
19+
spring.datasource.username=root
20+
spring.datasource.password=root

docs/idea-run.md

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
1919
6、将 flink-streaming-core/target/flink-streaming-core.jar 移动到 刚创建的lib 中
2020
21-
7、将 flink-streaming-core.jar 改名为 flink-streaming-core-1.3.0.RELEASE.jar
21+
7、将 flink-streaming-core.jar 改名为 flink-streaming-core-1.4.0.RELEASE.jar
2222
2323
8、flink-streaming-web 模块是REST服务模块,运行启动类是:com.flink.streaming.web.StartApplication
2424
@@ -38,9 +38,9 @@
3838
3939
2、command 类似于,下面这个命令是 平台生成的 使用 yarn 提交 批任务
4040
41-
/Users/gump/dreamware/flink-1.13.1/bin/flink run -yjm 1024m -ytm 1024m -p 1 -yqu default -ynm flink@my_batch_job -yd -m yarn-cluster -c com.flink.streaming.core.JobApplication /Users/gump/study/source/github/flink-streaming-platform-web/lib/flink-streaming-core-1.3.0.RELEASE.jar -sql /Users/gump/study/source/github/flink-streaming-platform-web/sql/job_sql_3.sql -type 2
41+
/Users/gump/dreamware/flink-1.13.1/bin/flink run -yjm 1024m -ytm 1024m -p 1 -yqu default -ynm flink@my_batch_job -yd -m yarn-cluster -c com.flink.streaming.core.JobApplication /Users/gump/study/source/github/flink-streaming-platform-web/lib/flink-streaming-core-1.4.0.RELEASE.jar -sql /Users/gump/study/source/github/flink-streaming-platform-web/sql/job_sql_3.sql -type 2
4242
43-
3、大家可以去分析这个命令,其实就是要知道 Flink 的客户端在哪个目录 ,提交的jar 就是导入到lib下的 flink-streaming-core-1.3.0.RELEASE.jar
43+
3、大家可以去分析这个命令,其实就是要知道 Flink 的客户端在哪个目录 ,提交的jar 就是导入到lib下的 flink-streaming-core-1.4.0.RELEASE.jar
4444
4545
4、yarn 的url 貌似只是 日志那里有使用
4646

docs/img.md

Lines changed: 6 additions & 21 deletions
Original file line numberDiff line numberDiff line change
@@ -24,24 +24,9 @@
2424

2525

2626

27-
![图片](http://img.ccblog.cn/flink/0.png)
28-
![图片](http://img.ccblog.cn/flink/1-1.png)
29-
![图片](http://img.ccblog.cn/flink/1.png)
30-
![图片](http://img.ccblog.cn/flink/2.png)
31-
![图片](http://img.ccblog.cn/flink/3-1.png)
32-
![图片](http://img.ccblog.cn/flink/3.png)
33-
![图片](http://img.ccblog.cn/flink/4.png)
34-
![图片](http://img.ccblog.cn/flink/5.png)
35-
![图片](http://img.ccblog.cn/flink/6.png)
36-
![图片](http://img.ccblog.cn/flink/7.png)
37-
![图片](http://img.ccblog.cn/flink/9.png)
38-
![图片](http://img.ccblog.cn/flink/10.png)
39-
![图片](http://img.ccblog.cn/flink/12.png)
40-
![图片](http://img.ccblog.cn/flink/13.png)
41-
![图片](http://img.ccblog.cn/flink/1-0.png)
42-
![图片](http://img.ccblog.cn/flink/1-2.png)
43-
![图片](http://img.ccblog.cn/flink/1-3.png)
44-
![图片](http://img.ccblog.cn/flink/1-4.png)
45-
![图片](http://img.ccblog.cn/flink/1-5.png)
46-
![图片](http://img.ccblog.cn/flink/1-6.png)
47-
![图片](http://img.ccblog.cn/flink/1-7.png)
27+
![图片](img_preview/1.png)
28+
![图片](img_preview/2.png)
29+
![图片](img_preview/6.png)
30+
![图片](img_preview/3.png)
31+
![图片](img_preview/4.png)
32+
![图片](img_preview/5.png)

docs/img_preview/1.png

384 KB
Loading

docs/img_preview/2.png

387 KB
Loading

docs/img_preview/3.png

418 KB
Loading

docs/img_preview/4.png

394 KB
Loading

0 commit comments

Comments
 (0)