Merge pull request #69 from zhp8341/web-ui

Web UI

Author: zhp8341

.gitignore

@@ -1,3 +1,8 @@
+.settings/
+.project
+.classpath
+target/
+node_modules/
 # Created by .ignore support plugin (hsz.mobi)
 ### Java template
 # Compiled class file
@@ -140,4 +145,4 @@ Icon
 Network Trash Folder
 Temporary Items
 .apdisk
-./logs
+./logs

README.md

@@ -18,8 +18,10 @@ https://xie.infoq.cn/article/1af0cb75be056fea788e6c86b
   **主要功能**:包含任务配置、启/停任务、告警、日志等功能，支持sql语法提示，格式化、sql语句校验。 
 
   **目的**:减少开发、降低成本 完全实现sql化 流计算任务。 😂
-  
-   由于前端UI是本人自己写的，不够专业，样式有点丑 请多多包含！！！
+
+
+   该项目获得 [Flink Forward Asia Hackathon (2021) 季军 ](https://mp.weixin.qq.com/s/J2OkX_D34ktfwSfhwdmXYQ)
+
 
 ### 1、主要功能
 
@@ -213,19 +215,12 @@ https://nightlies.apache.org/flink/flink-docs-release-1.13/zh/docs/connectors/ta
 ##  七、RoadMap
 
 
-1、 支持除官方以外的连接器  如：阿里云的sls
+1、支持多版本flink
 
-2、 任务告警自动拉起 (完成)
+2、 完善文档 （持续过程）
 
-3、 支持Application模式
+3、UI
 
-4、 完善文档 （持续过程）
-
-5、 支持sql预校验，编写sql的时候语法提示等友好的用户体验(完成)
-
-6、 checkpoint支持rocksDB (完成)
-
-7、 支持jar模式提交任务 (完成)
 
 
 
@@ -244,20 +239,18 @@ https://nightlies.apache.org/flink/flink-docs-release-1.13/zh/docs/connectors/ta
 http://img.ccblog.cn/flink/dd2.png 
 
 
-微信二维码 http://img.ccblog.cn/flink/wx2.png
-
-
- [微信二维码](http://img.ccblog.cn/flink/wx2.png)
-
- 
- 
 
  ##  十、使用情况 
 
 
 [2021-03-18 和 2021-03-19 两天 做的调研 ](/docs/img2.md)
 
-## 十一、 捐赠
+
+## 十一、 鸣谢
+感谢文香炯（湖南草花互动科技股份公司）贡献前端代码 ：https://gitee.com/wenxiangjiong/flink-streaming-platform-web.git
+
+
+## 十二、 捐赠
 
 [点击打开支付宝捐赠](http://img.ccblog.cn/jz/zfb.jpg)
 

deployer/pom.xml

@@ -10,7 +10,6 @@
     </parent>
     <modelVersion>4.0.0</modelVersion>
 
-    <groupId>com.streaming.platform.web</groupId>
     <artifactId>deployer</artifactId>
     <version>${flink_streaming_version}</version>
 

deployer/src/main/assembly/dev.xml

@@ -50,6 +50,7 @@
             <outputDirectory>lib</outputDirectory>
             <scope>runtime</scope>
             <excludes>
+                <exclude>io.*:*</exclude>
                 <exclude>org.*:*</exclude>
                 <exclude>net.*:*</exclude>
                 <exclude>ch.*:*</exclude>

deployer/src/main/bin/deploy.sh

@@ -1,12 +1,11 @@
-#!/usr/bin/env bash
-
+#! /bin/bash
 
 #具体执行哪个步骤
 ACTION=$1
 
 echo "开始执行脚本 启动参数 $1"
 
-source /etc/profile
+##source /etc/profile
 set -e
 
 # Find the java binary
@@ -21,7 +20,9 @@ else
   fi
 fi
 
-
+curr_path=`pwd`
+shell_path=$(cd $(dirname $0); pwd)
+cd ${shell_path}
 echo "JAVA_HOME= ${JAVA_HOME}"
 
 ##变量设置##
@@ -39,51 +40,38 @@ start(){
          echo $pid
      if [ -z $pid ]
      then
-
-         echo "开始启动进程执行命令  java $JAVA_OPTS   -jar $project --spring.profiles.active=$env --spring.config.additional-location=../conf/application.properties  "
-        
-          java $JAVA_OPTS   -jar $project --spring.profiles.active=$env --spring.config.additional-location=../conf/application.properties      >/dev/null 2>&1  &
-          sleep 20
+         echo "开始启动进程执行命令  java $JAVA_OPTS   -jar $project --spring.profiles.active=$env --spring.config.additional-location=../conf/application.properties "
+          java $JAVA_OPTS -jar $project --spring.profiles.active=$env --spring.config.additional-location=../conf/application.properties >/dev/null 2>&1 &
+          sleep 5
           pid=$(ps x | grep $project  | grep -v grep | awk '{print $1}')
-
            if [ -z $pid ]
            then
-              echo "启动应用进程失败 请手动执行一下  java  -jar $project --spring.profiles.active=$env --spring.config.additional-location=../conf/application.properties  "
+              echo "启动应用进程失败 请手动执行一下  java -jar $project --spring.profiles.active=$env --spring.config.additional-location=../conf/application.properties "
            else
               echo "启动成功 pid=" $pid
            fi
-
            echo "可通过命令  tail -fn 300  ../logs/info.log  查看web日志"
-
      else
       echo " $project 进程已经存 pid=" $pid
      fi
-
-
 }
 
 stop()
 {
-pid=$(ps x | grep $project  | grep -v grep | awk '{print $1}')
-echo "进程 $pid"
-
-echo "------>Check pid of $project"
-
-if [ -z "$pid" ]
-then
-    echo "------>APP_NAME process [$project] is already stopped"
-else
-    for pid in ${pid[*]}
-    do
-      echo "------>Kill process which pid=$pid"
-      /bin/kill $pid
-    done
-        sleep  30
-
-fi
-
-
-
+	pid=$(ps x | grep $project  | grep -v grep | awk '{print $1}')
+	echo "进程 $pid"
+	echo "------>Check pid of $project"
+	if [ -z "$pid" ]
+	then
+	    echo "------>APP_NAME process [$project] is already stopped"
+	else
+	    for pid in ${pid[*]}
+	    do
+	      echo "------>Kill process which pid=$pid"
+	      /bin/kill $pid
+	    done
+	    sleep 5
+	fi
 }
 
 restart()
@@ -93,16 +81,16 @@ restart()
 }
 
 case "$ACTION" in
-
     restart)
     cp $project  $project$time
        restart
     ;;
     start)
        start
     ;;
-
     stop)
         stop
     ;;
 esac
+cd ${curr_path}
+

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

@@ -6,7 +6,7 @@ ACTION=$1
 
 ##变量设置##
 env=docker
-project="/data/projects/flink-streaming-platform-web/lib/flink-streaming-web-1.3.0.RELEASE.jar"
+project="/data/projects/flink-streaming-platform-web/lib/flink-streaming-web-1.4.0.RELEASE.jar"
 
 
 ##JAVA_OPTS设置

deployer/src/main/conf/application.properties

@@ -1,3 +1,18 @@
+# 如果公司内部使用了nacos 可以将有些配置放到nacos 如果没有请不要填写相关配置
+#nacos.core.auth.enabled=true
+#nacos.config.bootstrap.enable=true
+#nacos.config.server-addr=172.16.167.37:8848
+#nacos.config.group=DEFAULT_GROUP
+#nacos.config.data-id=flink-web.properties
+#nacos.config.namespace=dev
+#nacos.config.username=nacos
+#nacos.config.password=nacos
+#nacos.config.type=properties
+#nacos.config.max-retry=10
+#nacos.config.auto-refresh=true
+#nacos.config.config-retry-time=2333
+#nacos.config.config-long-poll-timeout=46000
+
 ####jdbc信息
 server.port=9084
 spring.datasource.url=jdbc:mysql://localhost:3306/flink_web?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=false

docs/idea-run.md

@@ -18,7 +18,7 @@
 
 6、将 flink-streaming-core/target/flink-streaming-core.jar 移动到 刚创建的lib 中
 
-7、将 flink-streaming-core.jar 改名为 flink-streaming-core-1.3.0.RELEASE.jar
+7、将 flink-streaming-core.jar 改名为 flink-streaming-core-1.4.0.RELEASE.jar
 
 8、flink-streaming-web 模块是REST服务模块，运行启动类是：com.flink.streaming.web.StartApplication
 
@@ -38,9 +38,9 @@
 
 2、command 类似于，下面这个命令是 平台生成的 使用 yarn 提交 批任务
 
-/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 
+/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 
 
-3、大家可以去分析这个命令，其实就是要知道 Flink 的客户端在哪个目录 ，提交的jar 就是导入到lib下的 flink-streaming-core-1.3.0.RELEASE.jar 
+3、大家可以去分析这个命令，其实就是要知道 Flink 的客户端在哪个目录 ，提交的jar 就是导入到lib下的 flink-streaming-core-1.4.0.RELEASE.jar 
 
 4、yarn 的url 貌似只是 日志那里有使用
 

docs/img.md

@@ -24,24 +24,9 @@
 
 
 
- ![图片](http://img.ccblog.cn/flink/0.png)
- ![图片](http://img.ccblog.cn/flink/1-1.png)
- ![图片](http://img.ccblog.cn/flink/1.png)
- ![图片](http://img.ccblog.cn/flink/2.png)
- ![图片](http://img.ccblog.cn/flink/3-1.png)
- ![图片](http://img.ccblog.cn/flink/3.png)
- ![图片](http://img.ccblog.cn/flink/4.png)
- ![图片](http://img.ccblog.cn/flink/5.png)
- ![图片](http://img.ccblog.cn/flink/6.png)
- ![图片](http://img.ccblog.cn/flink/7.png)
- ![图片](http://img.ccblog.cn/flink/9.png)
- ![图片](http://img.ccblog.cn/flink/10.png)
- ![图片](http://img.ccblog.cn/flink/12.png)
- ![图片](http://img.ccblog.cn/flink/13.png)
- ![图片](http://img.ccblog.cn/flink/1-0.png)
- ![图片](http://img.ccblog.cn/flink/1-2.png)
- ![图片](http://img.ccblog.cn/flink/1-3.png)
- ![图片](http://img.ccblog.cn/flink/1-4.png)
- ![图片](http://img.ccblog.cn/flink/1-5.png)
- ![图片](http://img.ccblog.cn/flink/1-6.png)
- ![图片](http://img.ccblog.cn/flink/1-7.png)
+ ![图片](img_preview/1.png)
+ ![图片](img_preview/2.png)
+ ![图片](img_preview/6.png)
+ ![图片](img_preview/3.png)
+ ![图片](img_preview/4.png)
+ ![图片](img_preview/5.png)