在实际的工作中，我们对于内部做数据分析的业务场景里面，我们会使用到大量的flink sql，但是我们不需要写一条sql就编写一个flink sql job，因此我们会使用到可视化工具来完成这个任务，这篇文章我们介绍下常用的这个工具：flink-streaming-platform-web的安装教程。
一、准备一个flink的环境
这里我们演示的话，使用的flink单机版，这里大家根据实际情况来使用flink的环境即可。
二、准备一个mysql环境
使用flink-streaming-platform-web这个工具的话，我们需要一个mysql的环境来管理这上面的元数据信息，因此我们需要准备一个mysql环境，这里我们准备的mysql环境是5.7版本。
三、创建元数据信息库表
这里我们首先在mysql中创建一个元数据信息库，名称为：flink_web
然后我们下面的sql文件给执行到这个flink_web的库里面去。这里的sql文件地址在：sql文件地址。这里我们也把sql文件给粘贴到下面来：
SET NAMES utf8mb4; SET FOREIGN_KEY_CHECKS = 0; USE flink_web; -- ---------------------------- -- Table structure for alart_log -- ---------------------------- DROP TABLE IF EXISTS `alart_log`; CREATE TABLE `alart_log` ( `id` bigint(11) unsigned NOT NULL AUTO_INCREMENT, `job_config_id` bigint(11) NOT NULL COMMENT 'job_config的id 如果0代表的是测试,', `job_name` varchar(255) DEFAULT NULL, `message` varchar(512) DEFAULT NULL COMMENT '消息内容', `type` tinyint(1) NOT NULL COMMENT '1:钉钉', `status` tinyint(1) NOT NULL COMMENT '1:成功 0:失败', `fail_log` text COMMENT '失败原因', `is_deleted` tinyint(1) NOT NULL DEFAULT '0', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `edit_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', `creator` varchar(32) DEFAULT 'sys', `editor` varchar(32) DEFAULT 'sys', PRIMARY KEY (`id`), KEY `index_job_config_id` (`job_config_id`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='告警发送情况日志'; -- ---------------------------- -- Table structure for ip_status -- ---------------------------- DROP TABLE IF EXISTS `ip_status`; CREATE TABLE `ip_status` ( `id` bigint(11) unsigned NOT NULL AUTO_INCREMENT, `ip` varchar(64) NOT NULL COMMENT 'ip', `status` int(11) NOT NULL COMMENT '1:运行 -1:停止 ', `last_time` datetime DEFAULT NULL COMMENT '最后心跳时间', `is_deleted` tinyint(1) NOT NULL DEFAULT '0', `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `edit_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', `creator` varchar(32) NOT NULL DEFAULT 'sys', `editor` varchar(32) NOT NULL DEFAULT 'sys', PRIMARY KEY (`id`), UNIQUE KEY `index_uk_ip` (`ip`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='web服务运行ip'; -- ---------------------------- -- Table structure for job_config -- ---------------------------- DROP TABLE IF EXISTS `job_config`; CREATE TABLE `job_config` ( `id` bigint(11) unsigned NOT NULL AUTO_INCREMENT, `job_name` varchar(64) NOT NULL COMMENT '任务名称', `deploy_mode` varchar(64) NOT NULL COMMENT '提交模式: standalone 、yarn 、yarn-session ', `flink_run_config` varchar(512) NOT NULL COMMENT 'flink运行配置', `flink_sql` MEDIUMTEXT NOT NULL COMMENT 'sql语句', `flink_checkpoint_config` varchar(512) DEFAULT NULL COMMENT 'checkPoint配置', `job_id` varchar(64) DEFAULT NULL COMMENT '运行后的任务id', `is_open` tinyint(1) NOT NULL COMMENT '1:开启 0: 关闭', `status` tinyint(1) NOT NULL COMMENT '1:运行中 0: 停止中 -1:运行失败', `ext_jar_path` varchar(2048) DEFAULT NULL COMMENT 'udf地址已经连接器jar 如http://xxx.xxx.com/flink-streaming-udf.jar', `last_start_time` datetime DEFAULT NULL COMMENT '最后一次启动时间', `last_run_log_id` bigint(11) DEFAULT NULL COMMENT '最后一次日志', `version` int(11) NOT NULL DEFAULT '0' COMMENT '更新版本号 用于乐观锁', `is_deleted` tinyint(1) NOT NULL DEFAULT '0', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `edit_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', `creator` varchar(32) DEFAULT 'sys', `editor` varchar(32) DEFAULT 'sys', PRIMARY KEY (`id`), KEY `uk_index` (`job_name`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='flink任务配置表'; ALTER TABLE job_config add `job_type` tinyint(1) NOT NULL DEFAULT '0' COMMENT '任务类型 0:sql 1:自定义jar' AFTER version ; ALTER TABLE job_config add `custom_args` varchar(128) DEFAULT NULL COMMENT '启动jar可能需要使用的自定义参数' AFTER job_type; ALTER TABLE job_config add `custom_main_class` varchar(128) DEFAULT NULL COMMENT '程序入口类' AFTER custom_args; ALTER TABLE job_config add `custom_jar_url` varchar(128) DEFAULT NULL COMMENT'自定义jar的http地址 如:http://ccblog.cn/xx.jar' AFTER custom_main_class; ALTER TABLE job_config ADD COLUMN job_desc VARCHAR(255) NULL COMMENT '任务描述' AFTER job_name; ALTER TABLE job_config ADD COLUMN cron VARCHAR(128) NULL COMMENT '批任务定时调度 如 0/20 * * * * ? 表示每20秒 执行任务 ' AFTER status; -- ---------------------------- -- Table structure for job_config_history -- ---------------------------- CREATE TABLE `job_config_history` ( `id` bigint(11) unsigned NOT NULL AUTO_INCREMENT, `job_config_id` bigint(11) NOT NULL COMMENT 'job_config主表Id', `job_name` varchar(64) NOT NULL COMMENT '任务名称', `deploy_mode` varchar(64) NOT NULL COMMENT '提交模式: standalone 、yarn 、yarn-session ', `flink_run_config` varchar(512) NOT NULL COMMENT 'flink运行配置', `flink_sql` mediumtext NOT NULL COMMENT 'sql语句', `flink_checkpoint_config` varchar(512) DEFAULT NULL COMMENT 'checkPoint配置', `ext_jar_path` varchar(2048) DEFAULT NULL COMMENT 'udf地址及连接器jar 如http://xxx.xxx.com/flink-streaming-udf.jar', `version` int(11) NOT NULL DEFAULT '0' COMMENT '更新版本号', `is_deleted` tinyint(1) NOT NULL DEFAULT '0', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `edit_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', `creator` varchar(32) DEFAULT 'sys', `editor` varchar(32) DEFAULT 'sys', PRIMARY KEY (`id`), KEY `index_job_config_id` (`job_config_id`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='flink任务配置历史变更表'; ALTER TABLE job_config_history ADD COLUMN job_desc VARCHAR(255) NULL COMMENT '任务描述' AFTER job_name; ALTER TABLE job_config_history add `job_type` tinyint(1) NOT NULL DEFAULT '0' COMMENT '任务类型 0:sql 1:自定义jar' AFTER version ; ALTER TABLE job_config_history ADD COLUMN cron VARCHAR(128) NULL COMMENT '批任务定时调度 如 0/20 * * * * ? 表示每20秒 执行任务 ' AFTER version; -- ---------------------------- -- Table structure for job_run_log -- ---------------------------- DROP TABLE IF EXISTS `job_run_log`; CREATE TABLE `job_run_log` ( `id` bigint(11) unsigned NOT NULL AUTO_INCREMENT, `job_config_id` bigint(11) NOT NULL, `job_name` varchar(64) NOT NULL COMMENT '任务名称', `deploy_mode` varchar(64) NOT NULL COMMENT '提交模式: standalone 、yarn 、yarn-session ', `job_id` varchar(64) DEFAULT NULL COMMENT '运行后的任务id', `local_log` mediumtext COMMENT '启动时本地日志', `remote_log_url` varchar(128) DEFAULT NULL COMMENT '远程日志url的地址', `start_time` datetime DEFAULT NULL COMMENT '启动时间', `end_time` datetime DEFAULT NULL COMMENT '启动时间', `job_status` varchar(32) DEFAULT NULL COMMENT '任务状态', `is_deleted` tinyint(1) NOT NULL DEFAULT '0', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `edit_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', `creator` varchar(32) DEFAULT 'sys', `editor` varchar(32) DEFAULT 'sys', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='运行任务日志'; ALTER TABLE job_run_log add `run_ip` varchar(64) DEFAULT NULL COMMENT '任务运行所在的机器' AFTER local_log ; ALTER TABLE job_run_log ADD COLUMN job_desc VARCHAR(255) NULL COMMENT '任务描述' AFTER job_name; -- ---------------------------- -- Table structure for savepoint_backup -- ---------------------------- DROP TABLE IF EXISTS `savepoint_backup`; CREATE TABLE `savepoint_backup` ( `id` bigint(11) unsigned NOT NULL AUTO_INCREMENT, `job_config_id` bigint(11) NOT NULL, `savepoint_path` varchar(2048) NOT NULL COMMENT '地址', `backup_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '备份时间', `is_deleted` tinyint(1) NOT NULL DEFAULT '0', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `edit_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', `creator` varchar(32) DEFAULT 'sys', `editor` varchar(32) DEFAULT 'sys', PRIMARY KEY (`id`), KEY `index` (`job_config_id`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='savepoint备份地址'; -- ---------------------------- -- Table structure for system_config -- ---------------------------- DROP TABLE IF EXISTS `system_config`; CREATE TABLE `system_config` ( `id` bigint(11) unsigned NOT NULL AUTO_INCREMENT, `key` varchar(128) NOT NULL COMMENT 'key值', `val` varchar(512) NOT NULL COMMENT 'value', `type` varchar(12) NOT NULL COMMENT '类型 如:sys alarm', `is_deleted` tinyint(1) NOT NULL DEFAULT '0', `create_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `edit_time` datetime NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', `creator` varchar(32) NOT NULL DEFAULT 'sys', `editor` varchar(32) NOT NULL DEFAULT 'sys', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='系统配置'; -- ---------------------------- -- Table structure for user -- ---------------------------- DROP TABLE IF EXISTS `user`; CREATE TABLE `user` ( `id` int(11) NOT NULL AUTO_INCREMENT, `username` varchar(100) COLLATE utf8mb4_bin NOT NULL COMMENT '用户帐号', `password` varchar(255) COLLATE utf8mb4_bin DEFAULT NULL COMMENT '密码', `status` tinyint(1) NOT NULL COMMENT '1:启用 0: 停用', `is_deleted` tinyint(1) NOT NULL DEFAULT '0' COMMENT '1:删除 0: 未删除', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `edit_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', `creator` varchar(32) COLLATE utf8mb4_bin DEFAULT 'sys', `editor` varchar(32) COLLATE utf8mb4_bin DEFAULT 'sys', PRIMARY KEY (`id`), UNIQUE KEY `index_uk` (`username`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_bin; ALTER TABLE user ADD COLUMN `name` VARCHAR(100) NOT NULL COMMENT '用户姓名' AFTER `username`; CREATE TABLE `job_alarm_config` ( `id` bigint(11) unsigned NOT NULL AUTO_INCREMENT, `job_id` bigint(11) unsigned NOT NULL COMMENT 'job_config主表id', `type` tinyint(1) NOT NULL COMMENT '类型 1:钉钉告警 2:url回调 3:异常自动拉起任务', `version` int(11) NOT NULL DEFAULT '0' COMMENT '更新版本号 ', `is_deleted` tinyint(1) NOT NULL DEFAULT '0', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `edit_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', `creator` varchar(32) DEFAULT 'sys', `editor` varchar(32) DEFAULT 'sys', PRIMARY KEY (`id`), KEY `uk_index_job_id` (`job_id`) USING BTREE ) ENGINE = InnoDB DEFAULT CHARSET = utf8mb4 COMMENT ='告警辅助配置表'; -- ---------------------------- -- Records of user 默认密码是 123456 -- ---------------------------- BEGIN; INSERT INTO `user` VALUES (1, 'admin', '系统管理员', 'e10adc3949ba59abbe56e057f20f883e', 1, 0, '2020-07-10 22:15:04', '2020-07-24 22:21:35', 'sys', 'sys'); COMMIT; CREATE TABLE `upload_file` ( `id` bigint(11) unsigned NOT NULL AUTO_INCREMENT, `file_name` varchar(128) DEFAULT NULL COMMENT '文件名字', `file_path` varchar(512) DEFAULT NULL COMMENT '文件路径', `type` int(11) NOT NULL DEFAULT '1' COMMENT '1:jar', `is_deleted` tinyint(1) NOT NULL DEFAULT '0', `create_time` datetime DEFAULT CURRENT_TIMESTAMP COMMENT '创建时间', `edit_time` datetime DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP COMMENT '修改时间', `creator` varchar(32) DEFAULT 'sys', `editor` varchar(32) DEFAULT 'sys', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8mb4 COMMENT='上传文件管理';
创建完成之后，我们就能看到对应的表信息了。
四、为flink-streaming-platform-web添加配置
首先我们在flink-streaming-platform-web的conf下配置mysql文件，编辑application.properties文件
这里我们修改对应的mysql信息即可。
由于我们这里只是演示下，因此不需要配置nacos的信息。
五、启动flink-streaming-platform-web
这里我们进入到bin目录里面，执行下面的命令即可：
./deploy.sh start
可以看到启动成功了。
六、访问flink-streaming-platform-web的dashboard
我们启动flink-streaming-platform-web完成之后，就会把flink-streaming-platform-web的dashboard暴露出来，默认的访问地址是：http://${ip}:9084
默认的账户和密码是：
账户：admin 密码：123456
到此为止，我们的flink-streaming-platform-web就安装完了，在后面的文章我们介绍下如何使用。
备注：
1、这里使用的flink-streaming-platform-web版本需要和flink的版本保持一致，不然后续启动任务的时候会报错。目前flink-streaming-platform-web可以直接下载的版本适配的是flink1.4的版本，但是flink现在已经是1.7的版本了。所以这里一定要注意下版本保持一致。
还没有评论，来说两句吧...