Skip to content

Commit 7123dae

Browse files
[Bug][DAO] Fix workflow_definition_code INT/BIGINT mismatch in t_ds_serial_command
1 parent ba2b482 commit 7123dae

3 files changed

Lines changed: 5 additions & 2 deletions

File tree

dolphinscheduler-dao/src/main/java/org/apache/dolphinscheduler/dao/entity/SerialCommand.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public class SerialCommand {
3838
@TableId(value = "id", type = IdType.AUTO)
3939
private Integer id;
4040

41-
private Integer workflowInstanceId;
41+
private Long workflowInstanceId;
4242

4343
private Long workflowDefinitionCode;
4444

dolphinscheduler-dao/src/main/resources/sql/upgrade/3.4.0_schema/mysql/dolphinscheduler_ddl.sql

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -25,7 +25,7 @@ ALTER TABLE `t_ds_task_group_queue` ADD KEY `idx_workflow_instance_id` (`workflo
2525
-- ----------------------------
2626
CREATE TABLE IF NOT EXISTS `t_ds_serial_command` (
2727
`id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'primary key',
28-
`workflow_definition_code` int(11) NOT NULL COMMENT 'workflow definition code',
28+
`workflow_definition_code` bigint(20) NOT NULL COMMENT 'workflow definition code',
2929
`workflow_definition_version` int(11) NOT NULL COMMENT 'workflow definition version',
3030
`workflow_instance_id` bigint(20) NOT NULL COMMENT 'workflow instance id',
3131
`state` tinyint(4) NOT NULL DEFAULT 0 COMMENT 'state of the serial queue: 0 waiting, 1 fired',

dolphinscheduler-dao/src/main/resources/sql/upgrade/3.4.1_schema/mysql/dolphinscheduler_ddl.sql

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -14,3 +14,6 @@
1414
* See the License for the specific language governing permissions and
1515
* limitations under the License.
1616
*/
17+
-- Fix workflow_definition_code type mismatch (INT -> BIGINT)
18+
ALTER TABLE `t_ds_serial_command`
19+
MODIFY COLUMN `workflow_definition_code` BIGINT(20) NOT NULL;

0 commit comments

Comments
 (0)