From 3cbe865776cf40fceb9f02e4d9b5840e9e739d5e Mon Sep 17 00:00:00 2001 From: Yelli Date: Mon, 1 Jun 2020 17:21:23 +0800 Subject: [PATCH] modify t_ds_task_instance app_link change sql (#2861) --- sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql | 4 ++-- sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_ddl.sql | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql b/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql index 2dd72ac0ed..a188bfe3e9 100644 --- a/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql +++ b/sql/upgrade/1.3.0_schema/mysql/dolphinscheduler_ddl.sql @@ -61,12 +61,12 @@ drop PROCEDURE if EXISTS uc_dolphin_T_t_ds_task_instance_C_app_link; delimiter d// CREATE PROCEDURE uc_dolphin_T_t_ds_task_instance_C_app_link() BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS + 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 COLUMN app_link app_link text COMMENT 'yarn app id'; + ALTER TABLE t_ds_task_instance CHANGE `app_link` `app_link` text COMMENT 'yarn app id'; END IF; END; diff --git a/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_ddl.sql b/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_ddl.sql index b9d55bd869..506ae35d6f 100644 --- a/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_ddl.sql +++ b/sql/upgrade/1.3.0_schema/postgresql/dolphinscheduler_ddl.sql @@ -54,7 +54,7 @@ DROP FUNCTION IF EXISTS uc_dolphin_T_t_ds_task_instance_A_executor_id(); delimiter d// CREATE OR REPLACE FUNCTION uc_dolphin_T_t_ds_task_instance_C_app_link() RETURNS void AS $$ BEGIN - IF NOT EXISTS (SELECT 1 FROM information_schema.COLUMNS + IF EXISTS (SELECT 1 FROM information_schema.COLUMNS WHERE TABLE_NAME='t_ds_task_instance' AND COLUMN_NAME ='app_link') THEN