Skip to content

Commit f1eca39

Browse files
committed
Merge pull request #166 from qq254963746/develop
fix 添加任务时,mysql报错,异常被吞掉的问题
2 parents efe4f7e + 92c63a5 commit f1eca39

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

lts-queue/lts-queue-mysql/src/main/java/com/lts/queue/mysql/MysqlExecutableJobQueue.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -87,6 +87,8 @@ public boolean add(JobPo jobPo) {
8787
if (e.getMessage().contains("doesn't exist Query:")) {
8888
createQueue(jobPo.getTaskTrackerNodeGroup());
8989
add(jobPo);
90+
} else{
91+
throw e;
9092
}
9193
}
9294
return true;

0 commit comments

Comments
 (0)