大数据 数据仓库 dolphinscheduler （海豚）调度器部署安装

1、创建数据库

mysql> CREATE DATABASE dolphinscheduler DEFAULT CHARACTER SET utf8 DEFAULT COLLATE utf8_general_ci;

Query OK, 1 row affected (0.00 sec)

2、创建用户

mysql> CREATE USER 'dolphinscheduler'@'%' IDENTIFIED BY 'dolphinscheduler';

ERROR 1819 (HY000): Your password does not satisfy the current policy requirements

-- 这个是密码过于简单的原因，进行如下操作即可

mysql> set global validate_password_length=4;

Query OK, 0 rows affected (0.00 sec)

mysql> set global validate_password_policy=0;

Query OK, 0 rows affected (0.00 sec)

-- 再一次进行操作即可了

mysql> CREATE USER 'dolphinscheduler'@'%' IDENTIFIED BY 'dolphinscheduler';

Query OK, 0 rows affected (0.00 sec)

3、赋予用户相应权限

mysql> GRANT ALL PRIVILEGES ON dolphinscheduler.* TO 'dolphinscheduler'@'%';

Query OK, 0 rows affected (0.00 sec)

-- 刷新当前配置

mysql> flush privileges;

Query OK, 0 rows affected (0.00 sec)

4、修改数据源配置文件

[lqs@nwh120 conf]$ pwd

/home/lqs/module/dolphinscheduler-1.3.9-install/conf

[lqs@nwh120 conf]$ vim datasource.properties

修改如下内容：

spring.datasource.driver-class-name=com.mysql.jdbc.Driver

spring.datasource.url=jdbc:mysql://nwh120:3306/dolphinscheduler?useUnicode=true&characterEncoding=UTF-8

spring.datasource.username=dolphinscheduler

spring.datasource.password=dolphinscheduler

5、拷贝MySQL驱动到DolphinScheduler的解压目录下的lib中

[lqs@nwh120 dolphinscheduler-1.3.9-install]$ cp /home/lqs/software/mysql-connector-java-5.1.27-bin.jar lib/

6、执行数据库初始化脚本 数据库初始化脚本位于DolphinScheduler解压安装目录下的script目录中，即/home/lqs/module/dolphinscheduler-1.3.9-install

[lqs@nwh120 dolphinscheduler-1.3.9-install]$ script/create-dolphinscheduler.sh

输入如下：

19:53:40.086 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: sun.cpu.isalist

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: sun.io.unicode.encoding

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: sun.cpu.endian

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.vendor.url.bug

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: file.separator

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.vendor

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: sun.boot.class.path

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.ext.dirs

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.version

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.vm.info

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: awt.toolkit

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: user.language

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.specification.vendor

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: sun.java.command

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.home

19:53:40.088 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: sun.arch.data.model

19:53:40.089 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.vm.specification.version

19:53:40.089 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.class.path

19:53:40.089 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: user.name

19:53:40.089 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: file.encoding

19:53:40.089 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.specification.version

19:53:40.089 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.awt.printerjob

19:53:40.089 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: user.timezone

19:53:40.089 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: user.home

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: os.version

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: sun.management.compiler

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.specification.name

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.class.version

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.library.path

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: sun.jnu.encoding

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: os.name

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.vm.specification.vendor

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.io.tmpdir

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: line.separator

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.endorsed.dirs

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: os.arch

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.awt.graphicsenv

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.runtime.version

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.vm.specification.name

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: user.dir

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: user.country

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: sun.java.launcher

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: sun.os.patch.level

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.vm.name

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: file.encoding.pkg

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: path.separator

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.vm.vendor

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.vendor.url

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: sun.boot.library.path

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.vm.version

19:53:40.092 [main] INFO org.apache.dolphinscheduler.dao.utils.PropertyUtils - Overriding property from system property: java.runtime.name

_ _ |_ _ _|_. ___ _ | _

| | |\/|_)(_| | |_\ |_)||_|_\

/ |

3.2.0

19:53:40.899 [main] INFO ru.yandex.clickhouse.ClickHouseDriver - Driver registered

19:53:41.088 [main] INFO com.alibaba.druid.pool.DruidDataSource - {dataSource-1} inited

19:53:41.105 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - Start initializing the DolphinScheduler manager table structure

19:53:41.108 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ /* Navicat MySQL Data Transfer Source Server : xx.xx Source Server Version : 50725 Source Host : 192.168.xx.xx:3306 Source Database : escheduler Target Server Type : MYSQL Target Server Version : 50725 File Encoding : 65001 Date: 2019-03-23 11:47:30 */ SET FOREIGN_KEY_CHECKS=0

19:53:41.110 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.110 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_alert

19:53:41.110 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.110 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_alert`

19:53:41.110 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_alert` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `title` varchar(64) DEFAULT NULL COMMENT 'title', `show_type` tinyint(4) DEFAULT NULL COMMENT 'send email type,0:TABLE,1:TEXT', `content` text COMMENT 'Message content (can be email, can be SMS. Mail is stored in JSON map, and SMS is string)', `alert_type` tinyint(4) DEFAULT NULL COMMENT '0:email,1:sms', `alert_status` tinyint(4) DEFAULT '0' COMMENT '0:wait running,1:success,2:failed', `log` text COMMENT 'log', `alertgroup_id` int(11) DEFAULT NULL COMMENT 'alert group id', `receivers` text COMMENT 'receivers', `receivers_cc` text COMMENT 'cc', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.115 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.115 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_alertgroup

19:53:41.115 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.115 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_alertgroup`

19:53:41.115 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_alertgroup` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `group_name` varchar(255) DEFAULT NULL COMMENT 'group name', `group_type` tinyint(4) DEFAULT NULL COMMENT 'Group type (message 0, SMS 1...)', `desc` varchar(255) DEFAULT NULL COMMENT 'description', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.119 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.119 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_command

19:53:41.119 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.119 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_command`

19:53:41.119 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_command` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `command_type` tinyint(4) DEFAULT NULL COMMENT 'Command type: 0 start workflow, 1 start execution from current node, 2 resume fault-tolerant workflow, 3 resume pause process, 4 start execution from failed node, 5 complement, 6 schedule, 7 rerun, 8 pause, 9 stop, 10 resume waiting thread', `process_definition_id` int(11) DEFAULT NULL COMMENT 'process definition id', `command_param` text COMMENT 'json command parameters', `task_depend_type` tinyint(4) DEFAULT NULL COMMENT 'Node dependency type: 0 current node, 1 forward, 2 backward', `failure_strategy` tinyint(4) DEFAULT '0' COMMENT 'Failed policy: 0 end, 1 continue', `warning_type` tinyint(4) DEFAULT '0' COMMENT 'Alarm type: 0 is not sent, 1 process is sent successfully, 2 process is sent failed, 3 process is sent successfully and all failures are sent', `warning_group_id` int(11) DEFAULT NULL COMMENT 'warning group', `schedule_time` datetime DEFAULT NULL COMMENT 'schedule time', `start_time` datetime DEFAULT NULL COMMENT 'start time', `executor_id` int(11) DEFAULT NULL COMMENT 'executor id', `dependence` varchar(255) DEFAULT NULL COMMENT 'dependence', `update_time` datetime DEFAULT NULL COMMENT 'update time', `process_instance_priority` int(11) DEFAULT NULL COMMENT 'process instance priority: 0 Highest,1 High,2 Medium,3 Low,4 Lowest', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.122 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.122 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_datasource

19:53:41.122 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.122 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_datasource`

19:53:41.122 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_datasource` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `name` varchar(64) NOT NULL COMMENT 'data source name', `note` varchar(256) DEFAULT NULL COMMENT 'description', `type` tinyint(4) NOT NULL COMMENT 'data source type: 0:mysql,1:postgresql,2:hive,3:spark', `user_id` int(11) NOT NULL COMMENT 'the creator id', `connection_params` text NOT NULL COMMENT 'json connection params', `create_time` datetime NOT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.125 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.125 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_master_server

19:53:41.125 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.125 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_master_server`

19:53:41.126 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_master_server` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `host` varchar(45) DEFAULT NULL COMMENT 'ip', `port` int(11) DEFAULT NULL COMMENT 'port', `zk_directory` varchar(64) DEFAULT NULL COMMENT 'the server path in zk directory', `res_info` varchar(256) DEFAULT NULL COMMENT 'json resource information:{"cpu":xxx,"memroy":xxx}', `create_time` datetime DEFAULT NULL COMMENT 'create time', `last_heartbeat_time` datetime DEFAULT NULL COMMENT 'last head beat time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.130 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.130 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_process_definition

19:53:41.130 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.130 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_process_definition`

19:53:41.130 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_process_definition` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `name` varchar(255) DEFAULT NULL COMMENT 'process definition name', `version` int(11) DEFAULT NULL COMMENT 'process definition version', `release_state` tinyint(4) DEFAULT NULL COMMENT 'process definition release state：0:offline,1:online', `project_id` int(11) DEFAULT NULL COMMENT 'project id', `user_id` int(11) DEFAULT NULL COMMENT 'process definition creator id', `process_definition_json` longtext COMMENT 'process definition json content', `desc` text COMMENT 'process definition description', `global_params` text COMMENT 'global parameters', `flag` tinyint(4) DEFAULT NULL COMMENT '0 not available, 1 available', `locations` text COMMENT 'Node location information', `connects` text COMMENT 'Node connection information', `receivers` text COMMENT 'receivers', `receivers_cc` text COMMENT 'cc', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`), KEY `process_definition_index` (`project_id`,`id`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.134 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.134 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_process_instance

19:53:41.134 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.134 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_process_instance`

19:53:41.135 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_process_instance` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `name` varchar(255) DEFAULT NULL COMMENT 'process instance name', `process_definition_id` int(11) DEFAULT NULL COMMENT 'process definition id', `state` tinyint(4) DEFAULT NULL COMMENT 'process instance Status: 0 commit succeeded, 1 running, 2 prepare to pause, 3 pause, 4 prepare to stop, 5 stop, 6 fail, 7 succeed, 8 need fault tolerance, 9 kill, 10 wait for thread, 11 wait for dependency to complete', `recovery` tinyint(4) DEFAULT NULL COMMENT 'process instance failover flag：0:normal,1:failover instance', `start_time` datetime DEFAULT NULL COMMENT 'process instance start time', `end_time` datetime DEFAULT NULL COMMENT 'process instance end time', `run_times` int(11) DEFAULT NULL COMMENT 'process instance run times', `host` varchar(45) DEFAULT NULL COMMENT 'process instance host', `command_type` tinyint(4) DEFAULT NULL COMMENT 'command type', `command_param` text COMMENT 'json command parameters', `task_depend_type` tinyint(4) DEFAULT NULL COMMENT 'task depend type. 0: only current node,1:before the node,2:later nodes', `max_try_times` tinyint(4) DEFAULT '0' COMMENT 'max try times', `failure_strategy` tinyint(4) DEFAULT '0' COMMENT 'failure strategy. 0:end the process when node failed,1:continue running the other nodes when node failed', `warning_type` tinyint(4) DEFAULT '0' COMMENT 'warning type. 0:no warning,1:warning if process success,2:warning if process failed,3:warning if success', `warning_group_id` int(11) DEFAULT NULL COMMENT 'warning group id', `schedule_time` datetime DEFAULT NULL COMMENT 'schedule time', `command_start_time` datetime DEFAULT NULL COMMENT 'command start time', `global_params` text COMMENT 'global parameters', `process_instance_json` longtext COMMENT 'process instance json(copy的process definition 的json)', `flag` tinyint(4) DEFAULT '1' COMMENT 'flag', `update_time` timestamp NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP, `is_sub_process` int(11) DEFAULT '0' COMMENT 'flag, whether the process is sub process', `executor_id` int(11) NOT NULL COMMENT 'executor id', `locations` text COMMENT 'Node location information', `connects` text COMMENT 'Node connection information', `history_cmd` text COMMENT 'history commands of process instance operation', `dependence_schedule_times` text COMMENT 'depend schedule fire time', `process_instance_priority` int(11) DEFAULT NULL COMMENT 'process instance priority. 0 Highest,1 High,2 Medium,3 Low,4 Lowest', PRIMARY KEY (`id`), KEY `process_instance_index` (`process_definition_id`,`id`) USING BTREE, KEY `start_time_index` (`start_time`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.139 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.139 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_project

19:53:41.139 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.139 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_project`

19:53:41.139 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_project` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `name` varchar(100) DEFAULT NULL COMMENT 'project name', `desc` varchar(200) DEFAULT NULL COMMENT 'project description', `user_id` int(11) DEFAULT NULL COMMENT 'creator id', `flag` tinyint(4) DEFAULT '1' COMMENT '0 not available, 1 available', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`), KEY `user_id_index` (`user_id`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.143 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.143 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_queue

19:53:41.143 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.143 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_queue`

19:53:41.144 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_queue` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `queue_name` varchar(64) DEFAULT NULL COMMENT 'queue name', `queue` varchar(64) DEFAULT NULL COMMENT 'yarn queue name', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.147 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.147 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_relation_datasource_user

19:53:41.147 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.147 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_relation_datasource_user`

19:53:41.147 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_relation_datasource_user` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `user_id` int(11) NOT NULL COMMENT 'user id', `datasource_id` int(11) DEFAULT NULL COMMENT 'data source id', `perm` int(11) DEFAULT '1' COMMENT 'limits of authority', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.150 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.150 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_relation_process_instance

19:53:41.150 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.150 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_relation_process_instance`

19:53:41.150 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_relation_process_instance` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `parent_process_instance_id` int(11) DEFAULT NULL COMMENT 'parent process instance id', `parent_task_instance_id` int(11) DEFAULT NULL COMMENT 'parent process instance id', `process_instance_id` int(11) DEFAULT NULL COMMENT 'child process instance id', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.153 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.153 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_relation_project_user

19:53:41.153 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.153 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_relation_project_user`

19:53:41.154 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_relation_project_user` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `user_id` int(11) NOT NULL COMMENT 'user id', `project_id` int(11) DEFAULT NULL COMMENT 'project id', `perm` int(11) DEFAULT '1' COMMENT 'limits of authority', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`), KEY `user_id_index` (`user_id`) USING BTREE ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.169 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.169 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_relation_resources_user

19:53:41.169 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.169 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_relation_resources_user`

19:53:41.170 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_relation_resources_user` ( `id` int(11) NOT NULL AUTO_INCREMENT, `user_id` int(11) NOT NULL COMMENT 'user id', `resources_id` int(11) DEFAULT NULL COMMENT 'resource id', `perm` int(11) DEFAULT '1' COMMENT 'limits of authority', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.173 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.173 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_relation_udfs_user

19:53:41.173 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.173 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_relation_udfs_user`

19:53:41.173 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_relation_udfs_user` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `user_id` int(11) NOT NULL COMMENT 'userid', `udf_id` int(11) DEFAULT NULL COMMENT 'udf id', `perm` int(11) DEFAULT '1' COMMENT 'limits of authority', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.176 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.176 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_relation_user_alertgroup

19:53:41.176 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.176 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_relation_user_alertgroup`

19:53:41.177 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_relation_user_alertgroup` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `alertgroup_id` int(11) DEFAULT NULL COMMENT 'alert group id', `user_id` int(11) DEFAULT NULL COMMENT 'user id', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=2 DEFAULT CHARSET=utf8

19:53:41.180 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.180 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_resources

19:53:41.180 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.180 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_resources`

19:53:41.181 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_resources` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `alias` varchar(64) DEFAULT NULL COMMENT 'alias', `file_name` varchar(64) DEFAULT NULL COMMENT 'file name', `desc` varchar(256) DEFAULT NULL COMMENT 'description', `user_id` int(11) DEFAULT NULL COMMENT 'user id', `type` tinyint(4) DEFAULT NULL COMMENT 'resource type,0:FILE，1:UDF', `size` bigint(20) DEFAULT NULL COMMENT 'resource size', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.184 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.184 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_schedules

19:53:41.184 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.184 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_schedules`

19:53:41.184 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_schedules` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `process_definition_id` int(11) NOT NULL COMMENT 'process definition id', `start_time` datetime NOT NULL COMMENT 'start time', `end_time` datetime NOT NULL COMMENT 'end time', `crontab` varchar(256) NOT NULL COMMENT 'crontab description', `failure_strategy` tinyint(4) NOT NULL COMMENT 'failure strategy. 0:end,1:continue', `user_id` int(11) NOT NULL COMMENT 'user id', `release_state` tinyint(4) NOT NULL COMMENT 'release state. 0:offline,1:online ', `warning_type` tinyint(4) NOT NULL COMMENT 'Alarm type: 0 is not sent, 1 process is sent successfully, 2 process is sent failed, 3 process is sent successfully and all failures are sent', `warning_group_id` int(11) DEFAULT NULL COMMENT 'alert group id', `process_instance_priority` int(11) DEFAULT NULL COMMENT 'process instance priority：0 Highest,1 High,2 Medium,3 Low,4 Lowest', `create_time` datetime NOT NULL COMMENT 'create time', `update_time` datetime NOT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.187 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.187 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_session

19:53:41.187 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.187 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_session`

19:53:41.187 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_session` ( `id` varchar(64) NOT NULL COMMENT 'key', `user_id` int(11) DEFAULT NULL COMMENT 'user id', `ip` varchar(45) DEFAULT NULL COMMENT 'ip', `last_login_time` datetime DEFAULT NULL COMMENT 'last login time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.190 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.190 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_task_instance

19:53:41.190 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.190 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_task_instance`

19:53:41.191 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_task_instance` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `name` varchar(255) DEFAULT NULL COMMENT 'task name', `task_type` varchar(64) DEFAULT NULL COMMENT 'task type', `process_definition_id` int(11) DEFAULT NULL COMMENT 'process definition id', `process_instance_id` int(11) DEFAULT NULL COMMENT 'process instance id', `task_json` longtext COMMENT 'task content json', `state` tinyint(4) DEFAULT NULL COMMENT 'Status: 0 commit succeeded, 1 running, 2 prepare to pause, 3 pause, 4 prepare to stop, 5 stop, 6 fail, 7 succeed, 8 need fault tolerance, 9 kill, 10 wait for thread, 11 wait for dependency to complete', `submit_time` datetime DEFAULT NULL COMMENT 'task submit time', `start_time` datetime DEFAULT NULL COMMENT 'task start time', `end_time` datetime DEFAULT NULL COMMENT 'task end time', `host` varchar(45) DEFAULT NULL COMMENT 'host of task running on', `execute_path` varchar(200) DEFAULT NULL COMMENT 'task execute path in the host', `log_path` varchar(200) DEFAULT NULL COMMENT 'task log path', `alert_flag` tinyint(4) DEFAULT NULL COMMENT 'whether alert', `retry_times` int(4) DEFAULT '0' COMMENT 'task retry times', `pid` int(4) DEFAULT NULL COMMENT 'pid of task', `app_link` varchar(255) DEFAULT NULL COMMENT 'yarn app id', `flag` tinyint(4) DEFAULT '1' COMMENT '0 not available, 1 available', `retry_interval` int(4) DEFAULT NULL COMMENT 'retry interval when task failed ', `max_retry_times` int(2) DEFAULT NULL COMMENT 'max retry times', `task_instance_priority` int(11) DEFAULT NULL COMMENT 'task instance priority:0 Highest,1 High,2 Medium,3 Low,4 Lowest', PRIMARY KEY (`id`), KEY `process_instance_id` (`process_instance_id`) USING BTREE, KEY `task_instance_index` (`process_definition_id`,`process_instance_id`) USING BTREE, CONSTRAINT `foreign_key_instance_id` FOREIGN KEY (`process_instance_id`) REFERENCES `t_escheduler_process_instance` (`id`) ON DELETE CASCADE ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.196 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.196 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_tenant

19:53:41.196 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.196 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_tenant`

19:53:41.196 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_tenant` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `tenant_code` varchar(64) DEFAULT NULL COMMENT 'tenant code', `tenant_name` varchar(64) DEFAULT NULL COMMENT 'tenant name', `desc` varchar(256) DEFAULT NULL COMMENT 'description', `queue_id` int(11) DEFAULT NULL COMMENT 'queue id', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.199 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.199 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_udfs

19:53:41.199 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.199 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_udfs`

19:53:41.199 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_udfs` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `user_id` int(11) NOT NULL COMMENT 'user id', `func_name` varchar(100) NOT NULL COMMENT 'UDF function name', `class_name` varchar(255) NOT NULL COMMENT 'class of udf', `type` tinyint(4) NOT NULL COMMENT 'Udf function type', `arg_types` varchar(255) DEFAULT NULL COMMENT 'arguments types', `database` varchar(255) DEFAULT NULL COMMENT 'data base', `desc` varchar(255) DEFAULT NULL COMMENT 'description', `resource_id` int(11) NOT NULL COMMENT 'resource id', `resource_name` varchar(255) NOT NULL COMMENT 'resource name', `create_time` datetime NOT NULL COMMENT 'create time', `update_time` datetime NOT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.202 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.202 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_user

19:53:41.202 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.202 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_user`

19:53:41.203 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_user` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'user id', `user_name` varchar(64) DEFAULT NULL COMMENT 'user name', `user_password` varchar(64) DEFAULT NULL COMMENT 'user password', `user_type` tinyint(4) DEFAULT NULL COMMENT 'user type, 0:administrator，1:ordinary user', `email` varchar(64) DEFAULT NULL COMMENT 'email', `phone` varchar(11) DEFAULT NULL COMMENT 'phone', `tenant_id` int(11) DEFAULT NULL COMMENT 'tenant id', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`), UNIQUE KEY `user_name_unique` (`user_name`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.207 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.207 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Table structure for t_escheduler_worker_server

19:53:41.207 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ----------------------------

19:53:41.207 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS `t_escheduler_worker_server`

19:53:41.207 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE `t_escheduler_worker_server` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `host` varchar(45) DEFAULT NULL COMMENT 'ip', `port` int(11) DEFAULT NULL COMMENT 'process id', `zk_directory` varchar(64) CHARACTER SET utf8 COLLATE utf8_bin DEFAULT NULL COMMENT 'zk path', `res_info` varchar(255) DEFAULT NULL COMMENT 'json resource info,{"cpu":xxx,"memroy":xxx}', `create_time` datetime DEFAULT NULL COMMENT 'create time', `last_heartbeat_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB DEFAULT CHARSET=utf8

19:53:41.211 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /*drop table first */ DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS

19:53:41.211 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS

19:53:41.211 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS QRTZ_SCHEDULER_STATE

19:53:41.212 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS QRTZ_LOCKS

19:53:41.212 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS QRTZ_SIMPLE_TRIGGERS

19:53:41.212 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS QRTZ_SIMPROP_TRIGGERS

19:53:41.213 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS QRTZ_CRON_TRIGGERS

19:53:41.213 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS QRTZ_BLOB_TRIGGERS

19:53:41.213 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS QRTZ_TRIGGERS

19:53:41.214 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS QRTZ_JOB_DETAILS

19:53:41.214 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP TABLE IF EXISTS QRTZ_CALENDARS

19:53:41.214 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE QRTZ_JOB_DETAILS( SCHED_NAME VARCHAR(120) NOT NULL, JOB_NAME VARCHAR(200) NOT NULL, JOB_GROUP VARCHAR(200) NOT NULL, DESCRIPTION VARCHAR(250) NULL, JOB_CLASS_NAME VARCHAR(250) NOT NULL, IS_DURABLE VARCHAR(1) NOT NULL, IS_NONCONCURRENT VARCHAR(1) NOT NULL, IS_UPDATE_DATA VARCHAR(1) NOT NULL, REQUESTS_RECOVERY VARCHAR(1) NOT NULL, JOB_DATA BLOB NULL, PRIMARY KEY (SCHED_NAME,JOB_NAME,JOB_GROUP)) ENGINE=InnoDB

19:53:41.217 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE QRTZ_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, JOB_NAME VARCHAR(200) NOT NULL, JOB_GROUP VARCHAR(200) NOT NULL, DESCRIPTION VARCHAR(250) NULL, NEXT_FIRE_TIME BIGINT(13) NULL, PREV_FIRE_TIME BIGINT(13) NULL, PRIORITY INTEGER NULL, TRIGGER_STATE VARCHAR(16) NOT NULL, TRIGGER_TYPE VARCHAR(8) NOT NULL, START_TIME BIGINT(13) NOT NULL, END_TIME BIGINT(13) NULL, CALENDAR_NAME VARCHAR(200) NULL, MISFIRE_INSTR SMALLINT(2) NULL, JOB_DATA BLOB NULL, PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), FOREIGN KEY (SCHED_NAME,JOB_NAME,JOB_GROUP) REFERENCES QRTZ_JOB_DETAILS(SCHED_NAME,JOB_NAME,JOB_GROUP)) ENGINE=InnoDB

19:53:41.220 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE QRTZ_SIMPLE_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, REPEAT_COUNT BIGINT(7) NOT NULL, REPEAT_INTERVAL BIGINT(12) NOT NULL, TIMES_TRIGGERED BIGINT(10) NOT NULL, PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)) ENGINE=InnoDB

19:53:41.223 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE QRTZ_CRON_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, CRON_EXPRESSION VARCHAR(120) NOT NULL, TIME_ZONE_ID VARCHAR(80), PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)) ENGINE=InnoDB

19:53:41.226 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE QRTZ_SIMPROP_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, STR_PROP_1 VARCHAR(512) NULL, STR_PROP_2 VARCHAR(512) NULL, STR_PROP_3 VARCHAR(512) NULL, INT_PROP_1 INT NULL, INT_PROP_2 INT NULL, LONG_PROP_1 BIGINT NULL, LONG_PROP_2 BIGINT NULL, DEC_PROP_1 NUMERIC(13,4) NULL, DEC_PROP_2 NUMERIC(13,4) NULL, BOOL_PROP_1 VARCHAR(1) NULL, BOOL_PROP_2 VARCHAR(1) NULL, PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)) ENGINE=InnoDB

19:53:41.229 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE QRTZ_BLOB_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, BLOB_DATA BLOB NULL, PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), INDEX (SCHED_NAME,TRIGGER_NAME, TRIGGER_GROUP), FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)) ENGINE=InnoDB

19:53:41.232 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE QRTZ_CALENDARS ( SCHED_NAME VARCHAR(120) NOT NULL, CALENDAR_NAME VARCHAR(200) NOT NULL, CALENDAR BLOB NOT NULL, PRIMARY KEY (SCHED_NAME,CALENDAR_NAME)) ENGINE=InnoDB

19:53:41.235 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, PRIMARY KEY (SCHED_NAME,TRIGGER_GROUP)) ENGINE=InnoDB

19:53:41.238 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE QRTZ_FIRED_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, ENTRY_ID VARCHAR(95) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, INSTANCE_NAME VARCHAR(200) NOT NULL, FIRED_TIME BIGINT(13) NOT NULL, SCHED_TIME BIGINT(13) NOT NULL, PRIORITY INTEGER NOT NULL, STATE VARCHAR(16) NOT NULL, JOB_NAME VARCHAR(200) NULL, JOB_GROUP VARCHAR(200) NULL, IS_NONCONCURRENT VARCHAR(1) NULL, REQUESTS_RECOVERY VARCHAR(1) NULL, PRIMARY KEY (SCHED_NAME,ENTRY_ID)) ENGINE=InnoDB

19:53:41.240 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE QRTZ_SCHEDULER_STATE ( SCHED_NAME VARCHAR(120) NOT NULL, INSTANCE_NAME VARCHAR(200) NOT NULL, LAST_CHECKIN_TIME BIGINT(13) NOT NULL, CHECKIN_INTERVAL BIGINT(13) NOT NULL, PRIMARY KEY (SCHED_NAME,INSTANCE_NAME)) ENGINE=InnoDB

19:53:41.243 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE TABLE QRTZ_LOCKS ( SCHED_NAME VARCHAR(120) NOT NULL, LOCK_NAME VARCHAR(40) NOT NULL, PRIMARY KEY (SCHED_NAME,LOCK_NAME)) ENGINE=InnoDB

19:53:41.246 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_J_REQ_RECOVERY ON QRTZ_JOB_DETAILS(SCHED_NAME,REQUESTS_RECOVERY)

19:53:41.249 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_J_GRP ON QRTZ_JOB_DETAILS(SCHED_NAME,JOB_GROUP)

19:53:41.252 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_J ON QRTZ_TRIGGERS(SCHED_NAME,JOB_NAME,JOB_GROUP)

19:53:41.255 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_JG ON QRTZ_TRIGGERS(SCHED_NAME,JOB_GROUP)

19:53:41.257 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_C ON QRTZ_TRIGGERS(SCHED_NAME,CALENDAR_NAME)

19:53:41.260 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_G ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_GROUP)

19:53:41.263 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_STATE)

19:53:41.265 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_N_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP,TRIGGER_STATE)

19:53:41.267 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_N_G_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_GROUP,TRIGGER_STATE)

19:53:41.270 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_NEXT_FIRE_TIME ON QRTZ_TRIGGERS(SCHED_NAME,NEXT_FIRE_TIME)

19:53:41.273 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_NFT_ST ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_STATE,NEXT_FIRE_TIME)

19:53:41.276 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_NFT_MISFIRE ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME)

19:53:41.278 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_NFT_ST_MISFIRE ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME,TRIGGER_STATE)

19:53:41.280 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_T_NFT_ST_MISFIRE_GRP ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME,TRIGGER_GROUP,TRIGGER_STATE)

19:53:41.283 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_FT_TRIG_INST_NAME ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,INSTANCE_NAME)

19:53:41.285 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_FT_INST_JOB_REQ_RCVRY ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,INSTANCE_NAME,REQUESTS_RECOVERY)

19:53:41.288 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_FT_J_G ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,JOB_NAME,JOB_GROUP)

19:53:41.290 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_FT_JG ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,JOB_GROUP)

19:53:41.292 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_FT_T_G ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)

19:53:41.295 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE INDEX IDX_QRTZ_FT_TG ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,TRIGGER_GROUP)

19:53:41.297 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: commit

19:53:41.298 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Records of t_escheduler_user,user : admin , password : dolphinscheduler123

19:53:41.298 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ INSERT INTO `t_escheduler_user` VALUES ('1', 'admin', '7ad2410b2f4c074479a8937a28a22b8f', '0', 'xxx@qq.com', '', '0', '2018-03-27 15:48:50', '2018-10-24 17:40:22')

19:53:41.299 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: INSERT INTO `t_escheduler_alertgroup` VALUES (1, 'default admin warning group', '0', 'default admin warning group','2018-11-29 10:20:39', '2018-11-29 10:20:39')

19:53:41.300 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: INSERT INTO `t_escheduler_relation_user_alertgroup` VALUES ('1', '1', '1', '2018-11-29 10:22:33', '2018-11-29 10:22:33')

19:53:41.300 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- Records of t_escheduler_queue,default queue name : default

19:53:41.300 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: INSERT INTO `t_escheduler_queue` VALUES ('1', 'default', 'default')

19:53:41.302 [main] INFO org.apache.dolphinscheduler.dao.upgrade.shell.CreateDolphinScheduler - init DolphinScheduler finished

19:53:41.313 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - upgrade DolphinScheduler metadata version from 1.0.0 to 1.0.1

19:53:41.313 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - Begin upgrading DolphinScheduler's table structure

19:53:41.313 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - dolphinscheduler

19:53:41.313 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.313 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_queue_C_create_time

19:53:41.313 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_queue_C_create_time

19:53:41.314 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_queue_C_create_time() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_escheduler_queue' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='create_time') THEN ALTER TABLE t_escheduler_queue ADD COLUMN create_time datetime DEFAULT NULL COMMENT 'create time' AFTER queue; END IF; END;

19:53:41.314 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_queue_C_create_time

19:53:41.344 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_queue_C_create_time

19:53:41.345 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_queue_C_update_time

19:53:41.345 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_queue_C_update_time

19:53:41.345 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_queue_C_update_time() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_escheduler_queue' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='update_time') THEN ALTER TABLE t_escheduler_queue ADD COLUMN update_time datetime DEFAULT NULL COMMENT 'update time' AFTER create_time; END IF; END;

19:53:41.346 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_queue_C_update_time

19:53:41.376 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_queue_C_update_time

19:53:41.377 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - sqlSQLFilePath/home/lqs/module/dolphinscheduler-1.3.9-install/sql/upgrade/1.0.1_schema/mysql/dolphinscheduler_dml.sql

19:53:41.378 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - upgrade DolphinScheduler metadata version from 1.0.1 to 1.0.2

19:53:41.378 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - Begin upgrading DolphinScheduler's table structure

19:53:41.379 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - dolphinscheduler

19:53:41.379 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.379 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_version

19:53:41.379 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_version

19:53:41.379 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_version() BEGIN drop table if exists t_escheduler_version; CREATE TABLE IF NOT EXISTS `t_escheduler_version` ( `id` int(11) NOT NULL AUTO_INCREMENT, `version` varchar(200) NOT NULL, PRIMARY KEY (`id`), UNIQUE KEY `version_UNIQUE` (`version`) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8 COMMENT='version'; END;

19:53:41.380 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_version

19:53:41.383 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_version

19:53:41.384 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_user_C_queue

19:53:41.384 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_user_C_queue

19:53:41.384 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_user_C_queue() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_escheduler_user' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='queue') THEN ALTER TABLE t_escheduler_user ADD COLUMN queue varchar(64) COMMENT 'queue' AFTER update_time; END IF; END;

19:53:41.385 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_user_C_queue

19:53:41.416 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_user_C_queue

19:53:41.417 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_access_token

19:53:41.417 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_access_token

19:53:41.417 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_access_token() BEGIN drop table if exists t_escheduler_access_token; CREATE TABLE IF NOT EXISTS `t_escheduler_access_token` ( `id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'key', `user_id` int(11) DEFAULT NULL COMMENT 'user id', `token` varchar(64) DEFAULT NULL COMMENT 'token', `expire_time` datetime DEFAULT NULL COMMENT 'end time of token ', `create_time` datetime DEFAULT NULL COMMENT 'create time', `update_time` datetime DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) ) ENGINE=InnoDB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8; END;

19:53:41.418 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_access_token

19:53:41.421 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_access_token

19:53:41.421 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_error_command

19:53:41.421 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_error_command

19:53:41.422 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_error_command() BEGIN drop table if exists t_escheduler_error_command; CREATE TABLE IF NOT EXISTS `t_escheduler_error_command` ( `id` int(11) NOT NULL COMMENT 'key', `command_type` tinyint(4) NULL DEFAULT NULL COMMENT 'command type', `executor_id` int(11) NULL DEFAULT NULL COMMENT 'executor id', `process_definition_id` int(11) NULL DEFAULT NULL COMMENT 'process definition id', `command_param` text CHARACTER SET utf8 COLLATE utf8_general_ci NULL COMMENT 'json command parameters', `task_depend_type` tinyint(4) NULL DEFAULT NULL COMMENT 'task depend type', `failure_strategy` tinyint(4) NULL DEFAULT 0 COMMENT 'failure strategy', `warning_type` tinyint(4) NULL DEFAULT 0 COMMENT 'warning type', `warning_group_id` int(11) NULL DEFAULT NULL COMMENT 'warning group id', `schedule_time` datetime NULL DEFAULT NULL COMMENT 'scheduler time', `start_time` datetime NULL DEFAULT NULL COMMENT 'start time', `update_time` datetime NULL DEFAULT NULL COMMENT 'update time', `dependence` text CHARACTER SET utf8 COLLATE utf8_general_ci NULL COMMENT 'dependence', `process_instance_priority` int(11) NULL DEFAULT NULL COMMENT 'process instance priority, 0 Highest,1 High,2 Medium,3 Low,4 Lowest', `worker_group_id` int(11) NULL DEFAULT -1 COMMENT 'worker group id', `message` text CHARACTER SET utf8 COLLATE utf8_general_ci NULL COMMENT 'message', PRIMARY KEY (`id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT=1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic; END;

19:53:41.422 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_error_command

19:53:41.426 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_error_command

19:53:41.426 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_worker_group

19:53:41.426 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_worker_group

19:53:41.427 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_worker_group() BEGIN drop table if exists t_escheduler_worker_group; CREATE TABLE IF NOT EXISTS `t_escheduler_worker_group` ( `id` bigint(11) NOT NULL AUTO_INCREMENT COMMENT 'id', `name` varchar(256) NULL DEFAULT NULL COMMENT 'worker group name', `ip_list` varchar(256) NULL DEFAULT NULL COMMENT 'worker ip list. split by [,] ', `create_time` datetime NULL DEFAULT NULL COMMENT 'create time', `update_time` datetime NULL DEFAULT NULL COMMENT 'update time', PRIMARY KEY (`id`) USING BTREE ) ENGINE = InnoDB AUTO_INCREMENT=1 CHARACTER SET = utf8 COLLATE = utf8_general_ci ROW_FORMAT = Dynamic; END;

19:53:41.427 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_worker_group

19:53:41.432 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_worker_group

19:53:41.432 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_task_instance_C_worker_group_id

19:53:41.432 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_task_instance_C_worker_group_id

19:53:41.433 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_task_instance_C_worker_group_id() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_escheduler_task_instance' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='worker_group_id') THEN ALTER TABLE t_escheduler_task_instance ADD COLUMN `worker_group_id` int(11) NULL DEFAULT -1 COMMENT 'worker group id' AFTER `task_instance_priority`; END IF; END;

19:53:41.433 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_task_instance_C_worker_group_id

19:53:41.440 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_task_instance_C_worker_group_id

19:53:41.441 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_command_C_worker_group_id

19:53:41.441 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_command_C_worker_group_id

19:53:41.441 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_command_C_worker_group_id() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_escheduler_command' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='worker_group_id') THEN ALTER TABLE t_escheduler_command ADD COLUMN `worker_group_id` int(11) NULL DEFAULT -1 COMMENT 'worker group id' AFTER `process_instance_priority`; END IF; END;

19:53:41.442 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_command_C_worker_group_id

19:53:41.447 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_command_C_worker_group_id

19:53:41.447 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_schedules_C_worker_group_id

19:53:41.447 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_schedules_C_worker_group_id

19:53:41.448 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_schedules_C_worker_group_id() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_escheduler_schedules' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='worker_group_id') THEN ALTER TABLE t_escheduler_schedules ADD COLUMN `worker_group_id` int(11) NULL DEFAULT -1 COMMENT 'worker group id' AFTER `process_instance_priority`; END IF; END;

19:53:41.448 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_schedules_C_worker_group_id

19:53:41.453 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_schedules_C_worker_group_id

19:53:41.453 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_process_instance_C_worker_group_id

19:53:41.453 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_process_instance_C_worker_group_id

19:53:41.454 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_process_instance_C_worker_group_id() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_escheduler_process_instance' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='worker_group_id') THEN ALTER TABLE t_escheduler_process_instance ADD COLUMN `worker_group_id` int(11) NULL DEFAULT -1 COMMENT 'worker group id' AFTER `process_instance_priority`; END IF; END;

19:53:41.454 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_process_instance_C_worker_group_id

19:53:41.460 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_process_instance_C_worker_group_id

19:53:41.461 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_process_instance_C_timeout

19:53:41.461 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_process_instance_C_timeout

19:53:41.461 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_process_instance_C_timeout() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_escheduler_process_instance' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='timeout') THEN ALTER TABLE `t_escheduler_process_instance` ADD COLUMN `timeout` int(11) NULL DEFAULT 0 COMMENT 'time out' AFTER `worker_group_id`; END IF; END;

19:53:41.462 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_process_instance_C_timeout

19:53:41.468 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_process_instance_C_timeout

19:53:41.469 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_process_definition_C_timeout

19:53:41.469 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_process_definition_C_timeout

19:53:41.469 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_process_definition_C_timeout() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_escheduler_process_definition' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='timeout') THEN ALTER TABLE `t_escheduler_process_definition` ADD COLUMN `timeout` int(11) NULL DEFAULT 0 COMMENT 'time out' AFTER `create_time`; END IF; END;

19:53:41.470 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_process_definition_C_timeout

19:53:41.475 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_process_definition_C_timeout

19:53:41.476 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - sqlSQLFilePath/home/lqs/module/dolphinscheduler-1.3.9-install/sql/upgrade/1.0.2_schema/mysql/dolphinscheduler_dml.sql

19:53:41.476 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ INSERT INTO `t_escheduler_version` (`version`) VALUES ('1.0.2')

19:53:41.486 [main] DEBUG com.alibaba.druid.pool.PreparedStatementPool - stmt enter cache

19:53:41.487 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - upgrade DolphinScheduler metadata version from 1.0.2 to 1.1.0

19:53:41.487 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - Begin upgrading DolphinScheduler's table structure

19:53:41.487 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - dolphinscheduler

19:53:41.487 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.487 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_process_definition_C_tenant_id

19:53:41.487 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_process_definition_C_tenant_id

19:53:41.488 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_process_definition_C_tenant_id() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_escheduler_process_definition' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='tenant_id') THEN ALTER TABLE `t_escheduler_process_definition` ADD COLUMN `tenant_id` int(11) NOT NULL DEFAULT -1 COMMENT 'tenant id' AFTER `timeout`; END IF; END;

19:53:41.488 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_process_definition_C_tenant_id

19:53:41.493 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_process_definition_C_tenant_id

19:53:41.494 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_escheduler_T_t_escheduler_process_instance_C_tenant_id

19:53:41.494 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_process_instance_C_tenant_id

19:53:41.494 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_escheduler_T_t_escheduler_process_instance_C_tenant_id() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_escheduler_process_instance' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='tenant_id') THEN ALTER TABLE `t_escheduler_process_instance` ADD COLUMN `tenant_id` int(11) NOT NULL DEFAULT -1 COMMENT 'tenant id' AFTER `timeout`; END IF; END;

19:53:41.495 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_escheduler_T_t_escheduler_process_instance_C_tenant_id

19:53:41.500 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_escheduler_T_t_escheduler_process_instance_C_tenant_id

19:53:41.501 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - sqlSQLFilePath/home/lqs/module/dolphinscheduler-1.3.9-install/sql/upgrade/1.1.0_schema/mysql/dolphinscheduler_dml.sql

19:53:41.503 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - upgrade DolphinScheduler metadata version from 1.1.0 to 1.2.0

19:53:41.503 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - Begin upgrading DolphinScheduler's table structure

19:53:41.504 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - dolphinscheduler

19:53:41.504 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.504 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_access_token

19:53:41.504 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_access_token

19:53:41.505 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_access_token() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_access_token' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_access_token RENAME t_ds_access_token; END IF; END;

19:53:41.505 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_access_token

19:53:41.507 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_access_token

19:53:41.508 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_alert

19:53:41.508 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_alert

19:53:41.508 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_alert() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_alert' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_alert RENAME t_ds_alert; END IF; END;

19:53:41.509 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_alert

19:53:41.510 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_alert

19:53:41.510 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_alertgroup

19:53:41.510 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_alertgroup

19:53:41.511 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_alertgroup() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_alertgroup' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_alertgroup RENAME t_ds_alertgroup; END IF; END;

19:53:41.511 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_alertgroup

19:53:41.513 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_alertgroup

19:53:41.513 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_command

19:53:41.513 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_command

19:53:41.513 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_command() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_command' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_command RENAME t_ds_command; END IF; END;

19:53:41.514 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_command

19:53:41.515 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_command

19:53:41.516 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_datasource

19:53:41.516 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_datasource

19:53:41.516 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_datasource() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_datasource' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_datasource RENAME t_ds_datasource; END IF; END;

19:53:41.516 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_datasource

19:53:41.518 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_datasource

19:53:41.519 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_error_command

19:53:41.519 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_error_command

19:53:41.519 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_error_command() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_error_command' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_error_command RENAME t_ds_error_command; END IF; END;

19:53:41.519 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_error_command

19:53:41.521 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_error_command

19:53:41.521 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_master_server

19:53:41.521 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_master_server

19:53:41.522 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_master_server() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_master_server' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_master_server RENAME t_ds_master_server; END IF; END;

19:53:41.522 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_master_server

19:53:41.524 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_master_server

19:53:41.524 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_process_definition

19:53:41.524 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_process_definition

19:53:41.524 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_process_definition() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_process_definition' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_process_definition RENAME t_ds_process_definition; END IF; END;

19:53:41.525 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_process_definition

19:53:41.526 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_process_definition

19:53:41.527 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_process_instance

19:53:41.527 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_process_instance

19:53:41.527 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_process_instance() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_process_instance' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_process_instance RENAME t_ds_process_instance; END IF; END;

19:53:41.528 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_process_instance

19:53:41.529 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_process_instance

19:53:41.530 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_project

19:53:41.530 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_project

19:53:41.530 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_project() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_project' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_project RENAME t_ds_project; END IF; END;

19:53:41.530 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_project

19:53:41.532 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_project

19:53:41.532 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_queue

19:53:41.532 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_queue

19:53:41.533 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_queue() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_queue' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_queue RENAME t_ds_queue; END IF; END;

19:53:41.533 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_queue

19:53:41.534 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_queue

19:53:41.535 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_relation_datasource_user

19:53:41.535 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_relation_datasource_user

19:53:41.535 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_relation_datasource_user() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_relation_datasource_user' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_relation_datasource_user RENAME t_ds_relation_datasource_user; END IF; END;

19:53:41.535 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_relation_datasource_user

19:53:41.537 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_relation_datasource_user

19:53:41.537 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_relation_process_instance

19:53:41.537 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_relation_process_instance

19:53:41.537 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_relation_process_instance() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_relation_process_instance' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_relation_process_instance RENAME t_ds_relation_process_instance; END IF; END;

19:53:41.538 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_relation_process_instance

19:53:41.539 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_relation_process_instance

19:53:41.540 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_relation_project_user

19:53:41.540 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_relation_project_user

19:53:41.540 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_relation_project_user() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_relation_project_user' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_relation_project_user RENAME t_ds_relation_project_user; END IF; END;

19:53:41.540 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_relation_project_user

19:53:41.542 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_relation_project_user

19:53:41.542 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_relation_resources_user

19:53:41.543 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_relation_resources_user

19:53:41.543 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_relation_resources_user() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_relation_resources_user' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_relation_resources_user RENAME t_ds_relation_resources_user; END IF; END;

19:53:41.543 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_relation_resources_user

19:53:41.545 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_relation_resources_user

19:53:41.546 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_relation_udfs_user

19:53:41.546 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_relation_udfs_user

19:53:41.546 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_relation_udfs_user() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_relation_udfs_user' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_relation_udfs_user RENAME t_ds_relation_udfs_user; END IF; END;

19:53:41.547 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_relation_udfs_user

19:53:41.549 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_relation_udfs_user

19:53:41.550 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_relation_user_alertgroup

19:53:41.550 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_relation_user_alertgroup

19:53:41.550 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_relation_user_alertgroup() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_relation_user_alertgroup' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_relation_user_alertgroup RENAME t_ds_relation_user_alertgroup; END IF; END;

19:53:41.551 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_relation_user_alertgroup

19:53:41.553 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_relation_user_alertgroup

19:53:41.553 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_resources

19:53:41.553 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_resources

19:53:41.554 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_resources() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_resources' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_resources RENAME t_ds_resources; END IF; END;

19:53:41.554 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_resources

19:53:41.556 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_resources

19:53:41.557 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_schedules

19:53:41.557 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_schedules

19:53:41.557 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_schedules() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_schedules' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_schedules RENAME t_ds_schedules; END IF; END;

19:53:41.558 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_schedules

19:53:41.559 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_schedules

19:53:41.560 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_session

19:53:41.560 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_session

19:53:41.560 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_session() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_session' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_session RENAME t_ds_session; END IF; END;

19:53:41.561 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_session

19:53:41.562 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_session

19:53:41.562 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_task_instance

19:53:41.562 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_task_instance

19:53:41.563 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_task_instance() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_task_instance' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_task_instance RENAME t_ds_task_instance; END IF; END;

19:53:41.563 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_task_instance

19:53:41.565 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_task_instance

19:53:41.565 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_tenant

19:53:41.565 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_tenant

19:53:41.566 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_tenant() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_tenant' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_tenant RENAME t_ds_tenant; END IF; END;

19:53:41.566 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_tenant

19:53:41.568 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_tenant

19:53:41.568 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_udfs

19:53:41.568 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_udfs

19:53:41.569 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_udfs() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_udfs' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_udfs RENAME t_ds_udfs; END IF; END;

19:53:41.569 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_udfs

19:53:41.571 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_udfs

19:53:41.571 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_user

19:53:41.572 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_user

19:53:41.572 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_user() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_user' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_user RENAME t_ds_user; END IF; END;

19:53:41.573 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_user

19:53:41.575 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_user

19:53:41.576 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_version

19:53:41.576 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_version

19:53:41.576 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_version() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_version' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_version RENAME t_ds_version; END IF; END;

19:53:41.577 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_version

19:53:41.579 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_version

19:53:41.580 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_worker_group

19:53:41.580 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_worker_group

19:53:41.580 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_worker_group() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_worker_group' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_worker_group RENAME t_ds_worker_group; END IF; END;

19:53:41.581 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_worker_group

19:53:41.583 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_worker_group

19:53:41.584 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ut_dolphin_T_t_ds_worker_server

19:53:41.584 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ut_dolphin_T_t_ds_worker_server

19:53:41.584 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ut_dolphin_T_t_ds_worker_server() BEGIN IF EXISTS (SELECT 1 FROM information_schema.TABLES WHERE TABLE_NAME='t_escheduler_worker_server' AND TABLE_SCHEMA=(SELECT DATABASE())) THEN ALTER TABLE t_escheduler_worker_server RENAME t_ds_worker_server; END IF; END;

19:53:41.585 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ut_dolphin_T_t_ds_worker_server

19:53:41.587 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ut_dolphin_T_t_ds_worker_server

19:53:41.588 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_alertgroup_C_desc

19:53:41.588 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_alertgroup_C_desc

19:53:41.588 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_alertgroup_C_desc() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_alertgroup' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='desc') THEN ALTER TABLE t_ds_alertgroup CHANGE COLUMN `desc` description varchar(255); END IF; END;

19:53:41.588 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_alertgroup_C_desc

19:53:41.591 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_alertgroup_C_desc

19:53:41.591 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_process_definition_C_desc

19:53:41.591 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_process_definition_C_desc

19:53:41.592 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_process_definition_C_desc() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_process_definition' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='desc') THEN ALTER TABLE t_ds_process_definition CHANGE COLUMN `desc` description text; END IF; END;

19:53:41.592 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_process_definition_C_desc

19:53:41.595 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_process_definition_C_desc

19:53:41.595 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_project_C_desc

19:53:41.595 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_project_C_desc

19:53:41.596 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_project_C_desc() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_project' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='desc') THEN ALTER TABLE t_ds_project CHANGE COLUMN `desc` description varchar(200); END IF; END;

19:53:41.597 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_project_C_desc

19:53:41.599 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_project_C_desc

19:53:41.599 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_resources_C_desc

19:53:41.599 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_resources_C_desc

19:53:41.599 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_resources_C_desc() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_resources' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='desc') THEN ALTER TABLE t_ds_resources CHANGE COLUMN `desc` description varchar(256); END IF; END;

19:53:41.600 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_resources_C_desc

19:53:41.602 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_resources_C_desc

19:53:41.603 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_tenant_C_desc

19:53:41.603 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_tenant_C_desc

19:53:41.603 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_tenant_C_desc() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_tenant' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='desc') THEN ALTER TABLE t_ds_tenant CHANGE COLUMN `desc` description varchar(256); END IF; END;

19:53:41.603 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_tenant_C_desc

19:53:41.617 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_tenant_C_desc

19:53:41.618 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_udfs_C_desc

19:53:41.618 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_udfs_C_desc

19:53:41.618 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_udfs_C_desc() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_udfs' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME='desc') THEN ALTER TABLE t_ds_udfs CHANGE COLUMN `desc` description varchar(255); END IF; END;

19:53:41.619 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_udfs_C_desc

19:53:41.621 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_udfs_C_desc

19:53:41.621 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - sqlSQLFilePath/home/lqs/module/dolphinscheduler-1.3.9-install/sql/upgrade/1.2.0_schema/mysql/dolphinscheduler_dml.sql

19:53:41.621 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.622 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: SET FOREIGN_KEY_CHECKS=0

19:53:41.622 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE QRTZ_CRON_TRIGGERS SET SCHED_NAME='DolphinScheduler' WHERE SCHED_NAME='EasyScheduler'

19:53:41.622 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE QRTZ_TRIGGERS SET SCHED_NAME='DolphinScheduler' WHERE SCHED_NAME='EasyScheduler'

19:53:41.623 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE QRTZ_FIRED_TRIGGERS SET SCHED_NAME='DolphinScheduler' WHERE SCHED_NAME='EasyScheduler'

19:53:41.623 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE QRTZ_JOB_DETAILS SET SCHED_NAME='DolphinScheduler' WHERE SCHED_NAME='EasyScheduler'

19:53:41.623 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE QRTZ_JOB_DETAILS SET JOB_CLASS_NAME='org.apache.dolphinscheduler.dao.quartz.ProcessScheduleJob' WHERE JOB_CLASS_NAME='cn.escheduler.server.quartz.ProcessScheduleJob'

19:53:41.623 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE QRTZ_LOCKS SET SCHED_NAME='DolphinScheduler' WHERE SCHED_NAME='EasyScheduler'

19:53:41.624 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE QRTZ_SCHEDULER_STATE SET SCHED_NAME='DolphinScheduler' WHERE SCHED_NAME='EasyScheduler'

19:53:41.624 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE t_ds_user SET phone = '' WHERE phone = 'xx'

19:53:41.627 [main] DEBUG com.alibaba.druid.pool.PreparedStatementPool - stmt enter cache

19:53:41.627 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - upgrade DolphinScheduler metadata version from 1.2.0 to 1.3.0

19:53:41.627 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - Begin upgrading DolphinScheduler's table structure

19:53:41.627 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - dolphinscheduler

19:53:41.627 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.628 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_process_definition_A_modify_by

19:53:41.628 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_process_definition_A_modify_by

19:53:41.628 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_process_definition_A_modify_by() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_process_definition' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='modify_by') THEN ALTER TABLE t_ds_process_definition ADD `modify_by` varchar(36) DEFAULT '' COMMENT 'modify user'; END IF; END;

19:53:41.629 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_process_definition_A_modify_by

19:53:41.634 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_process_definition_A_modify_by

19:53:41.634 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_task_instance_A_executor_id

19:53:41.635 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_task_instance_A_executor_id

19:53:41.635 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_task_instance_A_executor_id() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_task_instance' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='executor_id') THEN ALTER TABLE t_ds_task_instance ADD `executor_id` int(11) DEFAULT NULL COMMENT 'executor id'; END IF; END;

19:53:41.635 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_task_instance_A_executor_id

19:53:41.640 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_task_instance_A_executor_id

19:53:41.641 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_task_instance_C_app_link

19:53:41.641 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_task_instance_C_app_link

19:53:41.641 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_task_instance_C_app_link() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_task_instance' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='app_link') THEN ALTER TABLE t_ds_task_instance CHANGE `app_link` `app_link` text COMMENT 'yarn app id'; END IF; END;

19:53:41.642 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_task_instance_C_app_link

19:53:41.650 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_task_instance_C_app_link

19:53:41.650 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_dolphin_T_t_ds_resources_A_pid

19:53:41.650 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_resources_A_pid

19:53:41.651 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_dolphin_T_t_ds_resources_A_pid() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_resources' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='pid') THEN ALTER TABLE t_ds_resources ADD `pid` int(11) DEFAULT -1 COMMENT 'parent id'; END IF; END;

19:53:41.651 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_dolphin_T_t_ds_resources_A_pid

19:53:41.655 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_dolphin_T_t_ds_resources_A_pid

19:53:41.656 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_dolphin_T_t_ds_resources_A_full_name

19:53:41.656 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_resources_A_full_name

19:53:41.656 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_dolphin_T_t_ds_resources_A_full_name() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_resources' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='full_name') THEN ALTER TABLE t_ds_resources ADD `full_name` varchar(255) DEFAULT NULL COMMENT 'full name'; END IF; END;

19:53:41.657 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_dolphin_T_t_ds_resources_A_full_name

19:53:41.661 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_dolphin_T_t_ds_resources_A_full_name

19:53:41.662 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_dolphin_T_t_ds_resources_A_pid

19:53:41.662 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_resources_is_directory

19:53:41.662 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_dolphin_T_t_ds_resources_is_directory() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_resources' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='is_directory') THEN ALTER TABLE t_ds_resources ADD `is_directory` tinyint(1) DEFAULT 0 COMMENT 'is directory'; END IF; END;

19:53:41.662 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_dolphin_T_t_ds_resources_is_directory

19:53:41.667 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_dolphin_T_t_ds_resources_is_directory

19:53:41.667 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- ac_dolphin_T_t_ds_process_definition_A_resource_ids

19:53:41.667 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS ac_dolphin_T_t_ds_process_definition_A_resource_ids

19:53:41.667 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE ac_dolphin_T_t_ds_process_definition_A_resource_ids() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_process_definition' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='resource_ids') THEN ALTER TABLE t_ds_process_definition ADD `resource_ids` varchar(255) DEFAULT NULL COMMENT 'resource ids'; END IF; END;

19:53:41.668 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL ac_dolphin_T_t_ds_process_definition_A_resource_ids

19:53:41.672 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE ac_dolphin_T_t_ds_process_definition_A_resource_ids

19:53:41.673 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_process_instance_R_worker_group_id

19:53:41.673 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_process_instance_R_worker_group_id

19:53:41.673 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_process_instance_R_worker_group_id() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_process_instance' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='worker_group_id') THEN ALTER TABLE t_ds_process_instance change `worker_group_id` `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group'; END IF; END;

19:53:41.673 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_process_instance_R_worker_group_id

19:53:41.680 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_process_instance_R_worker_group_id

19:53:41.680 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_task_instance_R_worker_group_id

19:53:41.680 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_task_instance_R_worker_group_id

19:53:41.681 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_task_instance_R_worker_group_id() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_task_instance' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='worker_group_id') THEN ALTER TABLE t_ds_task_instance change `worker_group_id` `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group'; END IF; END;

19:53:41.681 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_task_instance_R_worker_group_id

19:53:41.687 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_task_instance_R_worker_group_id

19:53:41.687 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_schedules_R_worker_group_id

19:53:41.687 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_schedules_R_worker_group_id

19:53:41.688 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_schedules_R_worker_group_id() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_schedules' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='worker_group_id') THEN ALTER TABLE t_ds_schedules change `worker_group_id` `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group'; END IF; END;

19:53:41.688 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_schedules_R_worker_group_id

19:53:41.694 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_schedules_R_worker_group_id

19:53:41.695 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_command_R_worker_group_id

19:53:41.695 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_command_R_worker_group_id

19:53:41.695 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_command_R_worker_group_id() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_command' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='worker_group_id') THEN ALTER TABLE t_ds_command change `worker_group_id` `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group'; END IF; END;

19:53:41.696 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_command_R_worker_group_id

19:53:41.702 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_command_R_worker_group_id

19:53:41.702 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_error_command_R_worker_group_id

19:53:41.702 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_error_command_R_worker_group_id

19:53:41.703 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_error_command_R_worker_group_id() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_error_command' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='worker_group_id') THEN ALTER TABLE t_ds_error_command change `worker_group_id` `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group'; END IF; END;

19:53:41.703 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_error_command_R_worker_group_id

19:53:41.709 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_error_command_R_worker_group_id

19:53:41.709 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_process_definition_A_process_definition_unique

19:53:41.709 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_process_definition_A_process_definition_unique

19:53:41.710 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_process_definition_A_process_definition_unique() BEGIN IF NOT EXISTS (SELECT 1 FROM information_schema.STATISTICS WHERE TABLE_NAME='t_ds_process_definition' AND TABLE_SCHEMA=(SELECT DATABASE()) AND INDEX_NAME ='process_definition_unique') THEN ALTER TABLE t_ds_process_definition ADD UNIQUE KEY `process_definition_unique` (`name`,`project_id`); END IF; END;

19:53:41.710 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_process_definition_A_process_definition_unique

19:53:41.714 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_process_definition_A_process_definition_unique

19:53:41.716 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - sqlSQLFilePath/home/lqs/module/dolphinscheduler-1.3.9-install/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_dml.sql

19:53:41.716 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.716 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: SET FOREIGN_KEY_CHECKS=0

19:53:41.716 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE t_ds_resources SET pid=-1,is_directory=false WHERE pid IS NULL

19:53:41.717 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE t_ds_resources SET full_name = concat('/',alias) WHERE pid=-1 and full_name IS NULL

19:53:41.718 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE QRTZ_JOB_DETAILS SET JOB_CLASS_NAME='org.apache.dolphinscheduler.service.quartz.ProcessScheduleJob' WHERE JOB_CLASS_NAME='org.apache.dolphinscheduler.server.quartz.ProcessScheduleJob'

19:53:41.718 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE t_ds_process_instance instance SET `worker_group`=IFNULL((SELECT name from t_ds_worker_group WHERE instance.worker_group=CONCAT(id,'')),'default')

19:53:41.719 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE t_ds_task_instance instance SET `worker_group`=IFNULL((SELECT name from t_ds_worker_group WHERE instance.worker_group=CONCAT(id,'')),'default')

19:53:41.720 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE t_ds_schedules schedule SET `worker_group`=IFNULL((SELECT name from t_ds_worker_group WHERE schedule.worker_group=CONCAT(id,'')),'default')

19:53:41.720 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE t_ds_command command SET `worker_group`=IFNULL((SELECT name from t_ds_worker_group WHERE command.worker_group=CONCAT(id,'')),'default')

19:53:41.721 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE t_ds_error_command command SET `worker_group`=IFNULL((SELECT name from t_ds_worker_group WHERE command.worker_group=CONCAT(id,'')),'default')

19:53:41.721 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE t_ds_user SET phone = '' WHERE phone = 'xx'

19:53:41.728 [main] DEBUG com.alibaba.druid.pool.PreparedStatementPool - stmt enter cache

19:53:41.729 [main] DEBUG com.alibaba.druid.pool.PreparedStatementPool - stmt enter cache

19:53:41.729 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - upgrade DolphinScheduler metadata version from 1.3.0 to 1.3.2

19:53:41.729 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - Begin upgrading DolphinScheduler's table structure

19:53:41.729 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - dolphinscheduler

19:53:41.730 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - sqlSQLFilePath/home/lqs/module/dolphinscheduler-1.3.9-install/sql/upgrade/1.3.2_schema/mysql/dolphinscheduler_dml.sql

19:53:41.730 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.730 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: SET FOREIGN_KEY_CHECKS=0

19:53:41.730 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: UPDATE t_ds_user SET phone = '' WHERE phone = 'xx'

19:53:41.734 [main] DEBUG com.alibaba.druid.pool.PreparedStatementPool - stmt enter cache

19:53:41.735 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - upgrade DolphinScheduler metadata version from 1.3.2 to 1.3.3

19:53:41.735 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - Begin upgrading DolphinScheduler's table structure

19:53:41.735 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - dolphinscheduler

19:53:41.739 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.740 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- add t_ds_resources_un

19:53:41.740 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE IF EXISTS uc_dolphin_T_t_ds_resources_un

19:53:41.740 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_resources_un() BEGIN IF NOT EXISTS ( SELECT * FROM information_schema.KEY_COLUMN_USAGE WHERE TABLE_NAME = 't_ds_resources' AND CONSTRAINT_NAME = 't_ds_resources_un' ) THEN ALTER TABLE t_ds_resources ADD CONSTRAINT t_ds_resources_un UNIQUE KEY (full_name,`type`); END IF; END;

19:53:41.741 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_resources_un()

19:53:41.745 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE IF EXISTS uc_dolphin_T_t_ds_resources_un

19:53:41.746 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - sqlSQLFilePath/home/lqs/module/dolphinscheduler-1.3.9-install/sql/upgrade/1.3.3_schema/mysql/dolphinscheduler_dml.sql

19:53:41.750 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - upgrade DolphinScheduler metadata version from 1.3.3 to 1.3.5

19:53:41.751 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - Begin upgrading DolphinScheduler's table structure

19:53:41.751 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - dolphinscheduler

19:53:41.751 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.751 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_process_instance_R_host

19:53:41.751 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_process_instance_R_host

19:53:41.752 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_process_instance_R_host() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_process_instance' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='host') THEN ALTER TABLE t_ds_process_instance MODIFY COLUMN `host` varchar(135); END IF; END;

19:53:41.752 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_process_instance_R_host

19:53:41.763 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_process_instance_R_host

19:53:41.764 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_task_instance_R_host

19:53:41.764 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_task_instance_R_host

19:53:41.764 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_task_instance_R_host() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_task_instance' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='host') THEN ALTER TABLE t_ds_task_instance MODIFY COLUMN `host` varchar(135); END IF; END;

19:53:41.765 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_task_instance_R_host

19:53:41.773 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_task_instance_R_host

19:53:41.773 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - sqlSQLFilePath/home/lqs/module/dolphinscheduler-1.3.9-install/sql/upgrade/1.3.5_schema/mysql/dolphinscheduler_dml.sql

19:53:41.777 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - upgrade DolphinScheduler metadata version from 1.3.5 to 1.3.6

19:53:41.777 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - Begin upgrading DolphinScheduler's table structure

19:53:41.777 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - dolphinscheduler

19:53:41.777 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.778 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_worker_group_R_ip_list

19:53:41.778 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_worker_group_R_ip_list

19:53:41.778 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_worker_group_R_ip_list() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_worker_group' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='ip_list') THEN ALTER TABLE t_ds_worker_group CHANGE COLUMN `ip_list` `addr_list` text; ALTER TABLE t_ds_worker_group MODIFY COLUMN `name` varchar(255) NOT NULL; ALTER TABLE t_ds_worker_group ADD UNIQUE KEY `name_unique` (`name`); END IF; END;

19:53:41.779 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_worker_group_R_ip_list

19:53:41.795 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_worker_group_R_ip_list

19:53:41.796 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_qrtz_fired_triggers_R_entry_id

19:53:41.796 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_qrtz_fired_triggers_R_entry_id

19:53:41.796 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_qrtz_fired_triggers_R_entry_id() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='QRTZ_FIRED_TRIGGERS' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='entry_id') THEN ALTER TABLE QRTZ_FIRED_TRIGGERS MODIFY COLUMN `entry_id` varchar(200); END IF; END;

19:53:41.797 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_qrtz_fired_triggers_R_entry_id

19:53:41.807 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_qrtz_fired_triggers_R_entry_id

19:53:41.808 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - sqlSQLFilePath/home/lqs/module/dolphinscheduler-1.3.9-install/sql/upgrade/1.3.6_schema/mysql/dolphinscheduler_dml.sql

19:53:41.811 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - upgrade DolphinScheduler metadata version from 1.3.6 to 1.3.7

19:53:41.811 [main] INFO org.apache.dolphinscheduler.dao.upgrade.DolphinSchedulerManager - Begin upgrading DolphinScheduler's table structure

19:53:41.811 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - dolphinscheduler

19:53:41.811 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: /* * Licensed to the Apache Software Foundation (ASF) under one or more * contributor license agreements. See the NOTICE file distributed with * this work for additional information regarding copyright ownership. * The ASF licenses this file to You under the Apache License, Version 2.0 * (the "License"); you may not use this file except in compliance with * the License. You may obtain a copy of the License at * * http://www.apache.org/licenses/LICENSE-2.0 * * Unless required by applicable law or agreed to in writing, software * distributed under the License is distributed on an "AS IS" BASIS, * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. * See the License for the specific language governing permissions and * limitations under the License. */ SET sql_mode=(SELECT REPLACE(@@sql_mode,'ONLY_FULL_GROUP_BY',''))

19:53:41.811 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_datasource_R_note

19:53:41.811 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_datasource_R_note

19:53:41.811 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_datasource_R_note() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_datasource' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='note') THEN ALTER TABLE t_ds_datasource MODIFY COLUMN `note` varchar(255) DEFAULT NULL COMMENT 'description'; END IF; END;

19:53:41.812 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_datasource_R_note

19:53:41.818 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_datasource_R_note

19:53:41.819 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_resources_R_description

19:53:41.819 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_resources_R_description

19:53:41.819 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_resources_R_description() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_resources' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='description') THEN ALTER TABLE t_ds_resources MODIFY COLUMN `description` varchar(255) DEFAULT NULL; END IF; END;

19:53:41.819 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_resources_R_description

19:53:41.825 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_resources_R_description

19:53:41.825 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_schedules_R_crontab

19:53:41.825 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_schedules_R_crontab

19:53:41.826 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_schedules_R_crontab() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_schedules' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='crontab') THEN ALTER TABLE t_ds_schedules MODIFY COLUMN `crontab` varchar(255) NOT NULL COMMENT 'crontab description'; ALTER TABLE t_ds_schedules MODIFY COLUMN `worker_group` varchar(64) DEFAULT '' COMMENT 'worker group id'; END IF; END;

19:53:41.826 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_schedules_R_crontab

19:53:41.832 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_schedules_R_crontab

19:53:41.832 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_tenant_R_description

19:53:41.832 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_tenant_R_description

19:53:41.833 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_tenant_R_description() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_tenant' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='description') THEN ALTER TABLE t_ds_tenant MODIFY COLUMN `description` varchar(255) DEFAULT NULL; END IF; END;

19:53:41.833 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_tenant_R_description

19:53:41.838 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_tenant_R_description

19:53:41.838 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - -- uc_dolphin_T_t_ds_worker_group_R_name

19:53:41.838 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_worker_group_R_name

19:53:41.839 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CREATE PROCEDURE uc_dolphin_T_t_ds_worker_group_R_name() BEGIN IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_worker_group' AND TABLE_SCHEMA=(SELECT DATABASE()) AND COLUMN_NAME ='name') THEN ALTER TABLE t_ds_worker_group MODIFY COLUMN `name` varchar(255) NOT NULL COMMENT 'worker group name'; END IF; END;

19:53:41.839 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: CALL uc_dolphin_T_t_ds_worker_group_R_name

19:53:41.840 [main] INFO org.apache.dolphinscheduler.common.utils.ScriptRunner - sql: DROP PROCEDURE uc_dolphin_T_t_ds_worker_group_R_name

19:53:41.841 [main] INFO org.apache.dolphinscheduler.dao.upgrade.UpgradeDao - sqlSQLFilePath/home/lqs/module/dolphinscheduler-1.3.9-install/sql/upgrade/1.3.7_schema/mysql/dolphinscheduler_dml.sql

19:53:41.844 [main] INFO org.apache.dolphinscheduler.dao.upgrade.shell.CreateDolphinScheduler - upgrade DolphinScheduler finished

19:53:41.844 [main] INFO org.apache.dolphinscheduler.dao.upgrade.shell.CreateDolphinScheduler - create DolphinScheduler success

7、配置一键部署脚本 a、修改解压目录下的conf/config目录下的install_config.conf文件

#

# Licensed to the Apache Software Foundation (ASF) under one or more

# contributor license agreements. See the NOTICE file distributed with

# this work for additional information regarding copyright ownership.

# The ASF licenses this file to You under the Apache License, Version 2.0

# (the "License"); you may not use this file except in compliance with

# the License. You may obtain a copy of the License at

#

# http://www.apache.org/licenses/LICENSE-2.0

#

# Unless required by applicable law or agreed to in writing, software

# distributed under the License is distributed on an "AS IS" BASIS,

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

# See the License for the specific language governing permissions and

# limitations under the License.

#

# NOTICE : If the following config has special characters in the variable `.*[]^${}\+?|()@#&`, Please escape, for example, `[` escape to `\[`

# postgresql or mysql

dbtype="mysql"

# db config

# db address and port

dbhost="nwh120:3306"

# db username

username="dolphinscheduler"

# database name

dbname="dolphinscheduler"

# db passwprd

# NOTICE: if there are special characters, please use the \ to escape, for example, `[` escape to `\[`

password="dolphinscheduler"

# zk cluster

zkQuorum="nwh120:2181,nwh121:2181,nwh122:2181"

# Note: the target installation path for dolphinscheduler, please not config as the same as the current path (pwd)

installPath="/home/lqs/module/dolphinscheduler"

# deployment user

# Note: the deployment user needs to have sudo privileges and permissions to operate hdfs. If hdfs is enabled, the root directory needs to be created by itself

deployUser="lqs"

# alert config

# mail server host

mailServerHost="smtp.exmail.qq.com"

# mail server port

# note: Different protocols and encryption methods correspond to different ports, when SSL/TLS is enabled, make sure the port is correct.

mailServerPort="25"

# sender

mailSender="xxxxxxxxxx"

# user

mailUser="xxxxxxxxxx"

# sender password

# note: The mail.passwd is email service authorization code, not the email login password.

mailPassword="xxxxxxxxxx"

# TLS mail protocol support

starttlsEnable="true"

# SSL mail protocol support

# only one of TLS and SSL can be in the true state.

sslEnable="false"

#note: sslTrust is the same as mailServerHost

sslTrust="smtp.exmail.qq.com"

# user data local directory path, please make sure the directory exists and have read write permissions

dataBasedirPath="/tmp/dolphinscheduler"

# resource storage type: HDFS, S3, NONE

resourceStorageType="HDFS"

# resource store on HDFS/S3 path, resource file will store to this hadoop hdfs path, self configuration, please make sure the directory exists on hdfs and have read write permissions. "/dolphinscheduler" is recommended

resourceUploadPath="/dolphinscheduler"

# if resourceStorageType is HDFS，defaultFS write namenode address，HA you need to put core-site.xml and hdfs-site.xml in the conf directory.

# if S3，write S3 address，HA，for example ：s3a://dolphinscheduler，

# Note，s3 be sure to create the root directory /dolphinscheduler

defaultFS="hdfs://nwh120:8020"

# if resourceStorageType is S3, the following three configuration is required, otherwise please ignore

s3Endpoint="http://192.168.xx.xx:9010"

s3AccessKey="xxxxxxxxxx"

s3SecretKey="xxxxxxxxxx"

# resourcemanager port, the default value is 8088 if not specified

resourceManagerHttpAddressPort="8088"

# if resourcemanager HA is enabled, please set the HA IPs; if resourcemanager is single, keep this value empty

yarnHaIps=

# if resourcemanager HA is enabled or not use resourcemanager, please keep the default value; If resourcemanager is single, you only need to replace ds1 to actual resourcemanager hostname

singleYarnIp="nwh121"

# who have permissions to create directory under HDFS/S3 root path

# Note: if kerberos is enabled, please config hdfsRootUser=

hdfsRootUser="lqs"

# kerberos config

# whether kerberos starts, if kerberos starts, following four items need to config, otherwise please ignore

kerberosStartUp="false"

# kdc krb5 config file path

krb5ConfPath="$installPath/conf/krb5.conf"

# keytab username

keytabUserName="hdfs-mycluster@ESZ.COM"

# username keytab path

keytabPath="$installPath/conf/hdfs.headless.keytab"

# kerberos expire time, the unit is hour

kerberosExpireTime="2"

# api server port

apiServerPort="12345"

# install hosts

# Note: install the scheduled hostname list. If it is pseudo-distributed, just write a pseudo-distributed hostname

ips="nwh120,nwh121,nwh122"

# ssh port, default 22

# Note: if ssh port is not default, modify here

sshPort="22"

# run master machine

# Note: list of hosts hostname for deploying master

masters="nwh120"

# run worker machine

# note: need to write the worker group name of each worker, the default value is "default"

workers="nwh120:default,nwh121:default,nwh122:default"

# run alert machine

# note: list of machine hostnames for deploying alert server

alertServer="nwh120"

# run api machine

# note: list of machine hostnames for deploying api server

apiServers="nwh120"

8、一键部署DolphinScheduler a、启动Zookeeper集群 b、一键部署并启动DolphinScheduler

[lqs@nwh120 dolphinscheduler-1.3.9]$ pwd

/home/lqs/module/dolphinscheduler-1.3.9

[lqs@nwh120 dolphinscheduler-1.3.9]$ ./install.sh

出现一下进程时说明启动成功 网页访问：http://nwh120:12345/dolphinscheduler 默认登录账号：admin 密码：dolphinscheduler123

精彩内容

 您阅读本篇文章共花了：