This is an automated email from the ASF dual-hosted git repository.

zihaoxiang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/dolphinscheduler.git


The following commit(s) were added to refs/heads/dev by this push:
     new f81709c77b [Fix-17356][Dependent] error creating Dependent (#17357)
f81709c77b is described below

commit f81709c77b72ffe26deaa9b4b8fdfcab64d87c62
Author: xiangzihao <[email protected]>
AuthorDate: Mon Jul 28 10:35:57 2025 +0800

    [Fix-17356][Dependent] error creating Dependent (#17357)
---
 .../src/main/resources/sql/dolphinscheduler_postgresql.sql |  2 +-
 .../3.3.1_schema/postgresql/dolphinscheduler_ddl.sql       | 14 ++++++++++++++
 2 files changed, 15 insertions(+), 1 deletion(-)

diff --git 
a/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_postgresql.sql 
b/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_postgresql.sql
index 6fc1b173bc..487f5da3a5 100644
--- 
a/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_postgresql.sql
+++ 
b/dolphinscheduler-dao/src/main/resources/sql/dolphinscheduler_postgresql.sql
@@ -1311,7 +1311,7 @@ CREATE INDEX idx_sub_workflow_instance_id ON 
t_ds_relation_sub_workflow (sub_wor
 -- ----------------------------
 DROP TABLE IF EXISTS t_ds_workflow_task_lineage;
 CREATE TABLE t_ds_workflow_task_lineage (
-    id int NOT NULL,
+    id SERIAL NOT NULL,
     workflow_definition_code bigint NOT NULL DEFAULT 0,
     workflow_definition_version int NOT NULL DEFAULT 0,
     task_definition_code bigint NOT NULL DEFAULT 0,
diff --git 
a/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.3.1_schema/postgresql/dolphinscheduler_ddl.sql
 
b/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.3.1_schema/postgresql/dolphinscheduler_ddl.sql
index f5dc9b2cc9..b966ae7d60 100644
--- 
a/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.3.1_schema/postgresql/dolphinscheduler_ddl.sql
+++ 
b/dolphinscheduler-dao/src/main/resources/sql/upgrade/3.3.1_schema/postgresql/dolphinscheduler_ddl.sql
@@ -21,3 +21,17 @@ ALTER TABLE t_ds_command DROP COLUMN test_flag;
 ALTER TABLE t_ds_error_command DROP COLUMN test_flag;
 ALTER TABLE t_ds_workflow_instance DROP COLUMN test_flag;
 ALTER TABLE t_ds_task_instance DROP COLUMN test_flag;
+
+ALTER TABLE t_ds_workflow_task_lineage
+DROP CONSTRAINT t_ds_workflow_task_lineage_pkey;
+CREATE SEQUENCE t_ds_workflow_task_lineage_id_seq;
+ALTER TABLE t_ds_workflow_task_lineage
+ALTER COLUMN id TYPE integer;
+ALTER TABLE t_ds_workflow_task_lineage
+ALTER COLUMN id SET DEFAULT nextval('t_ds_workflow_task_lineage_id_seq');
+ALTER SEQUENCE t_ds_workflow_task_lineage_id_seq
+OWNED BY t_ds_workflow_task_lineage.id;
+ALTER TABLE t_ds_workflow_task_lineage
+ALTER COLUMN id SET NOT NULL;
+ALTER TABLE t_ds_workflow_task_lineage
+ADD PRIMARY KEY (id);

Reply via email to