diff --git a/sql/upgrade/1.0.1_schema/mysql/escheduler_ddl.sql b/sql/upgrade/1.0.1_schema/mysql/escheduler_ddl.sql
index 66c03b21ea..bf36e1ad4b 100644
--- a/sql/upgrade/1.0.1_schema/mysql/escheduler_ddl.sql
+++ b/sql/upgrade/1.0.1_schema/mysql/escheduler_ddl.sql
@@ -38,4 +38,4 @@ d//
 
 delimiter ;
 CALL ac_escheduler_T_t_escheduler_queue_C_update_time;
-DROP PROCEDURE ac_escheduler_T_t_escheduler_queue_C_update_time;
\ No newline at end of file
+DROP PROCEDURE ac_escheduler_T_t_escheduler_queue_C_update_time;
diff --git a/sql/upgrade/1.0.2_schema/mysql/escheduler_ddl.sql b/sql/upgrade/1.0.2_schema/mysql/escheduler_ddl.sql
index b75c362e0e..0a080347d3 100644
--- a/sql/upgrade/1.0.2_schema/mysql/escheduler_ddl.sql
+++ b/sql/upgrade/1.0.2_schema/mysql/escheduler_ddl.sql
@@ -182,27 +182,6 @@ delimiter ;
 CALL ac_escheduler_T_t_escheduler_schedules_C_worker_group_id;
 DROP PROCEDURE ac_escheduler_T_t_escheduler_schedules_C_worker_group_id;
 
--- ac_escheduler_T_t_escheduler_process_instance_C_worker_group_id
-drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_process_instance_C_worker_group_id;
-delimiter d//
-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分组' AFTER `process_instance_priority`;
-       END IF;
- END;
-
-d//
-
-delimiter ;
-CALL ac_escheduler_T_t_escheduler_process_instance_C_worker_group_id;
-DROP PROCEDURE ac_escheduler_T_t_escheduler_process_instance_C_worker_group_id;
-
-
 -- ac_escheduler_T_t_escheduler_process_instance_C_timeout
 drop PROCEDURE if EXISTS ac_escheduler_T_t_escheduler_process_instance_C_timeout;
 delimiter d//