diff --git a/powerjob-official-processors/pom.xml b/powerjob-official-processors/pom.xml index 1998c2bd..1a78d58c 100644 --- a/powerjob-official-processors/pom.xml +++ b/powerjob-official-processors/pom.xml @@ -22,7 +22,7 @@ 1.4.4 4.2.0 5.2.9.RELEASE - 1.4.200 + 2.1.214 8.0.28 diff --git a/powerjob-server/pom.xml b/powerjob-server/pom.xml index cbfbc2c0..148a639b 100644 --- a/powerjob-server/pom.xml +++ b/powerjob-server/pom.xml @@ -35,7 +35,7 @@ 7.4.1.jre8 11.5.0.0 42.2.14 - 1.4.200 + 2.1.214 2.11.2 5.7.0.202003110725-r diff --git a/powerjob-worker/pom.xml b/powerjob-worker/pom.xml index 6815618a..6afbda68 100644 --- a/powerjob-worker/pom.xml +++ b/powerjob-worker/pom.xml @@ -16,7 +16,7 @@ 5.3.23 4.2.0 - 1.4.200 + 2.1.214 4.0.3 5.9.1 diff --git a/powerjob-worker/src/main/java/tech/powerjob/worker/persistence/TaskDAOImpl.java b/powerjob-worker/src/main/java/tech/powerjob/worker/persistence/TaskDAOImpl.java index f1793a2b..e3d2759b 100644 --- a/powerjob-worker/src/main/java/tech/powerjob/worker/persistence/TaskDAOImpl.java +++ b/powerjob-worker/src/main/java/tech/powerjob/worker/persistence/TaskDAOImpl.java @@ -28,7 +28,7 @@ public class TaskDAOImpl implements TaskDAO { String delTableSQL = "drop table if exists task_info"; // 感谢 Gitee 用户 @Linfly 反馈的 BUG // bigint(20) 与 Java Long 取值范围完全一致 - String createTableSQL = "create table task_info (task_id varchar(255), instance_id bigint(20), sub_instance_id bigint(20), task_name varchar(255), task_content blob, address varchar(255), status int(5), result text, failed_cnt int(11), created_time bigint(20), last_modified_time bigint(20), last_report_time bigint(20), unique KEY pkey (instance_id, task_id))"; + String createTableSQL = "create table task_info (task_id varchar(255), instance_id bigint, sub_instance_id bigint, task_name varchar(255), task_content blob, address varchar, status int, result text, failed_cnt int, created_time bigint, last_modified_time bigint, last_report_time bigint, constraint pkey unique (instance_id, task_id))"; try (Connection conn = connectionFactory.getConnection(); Statement stat = conn.createStatement()) { stat.execute(delTableSQL);