feat(sj_1.1.0-beta2): 修复DM执行失败问题
This commit is contained in:
parent
d9cd271be2
commit
234f7d8100
@ -357,7 +357,7 @@ COMMENT ON TABLE sj_server_node IS '服务器节点';
|
||||
-- sj_distributed_lock
|
||||
CREATE TABLE sj_distributed_lock
|
||||
(
|
||||
name varchar(64) NOT NULL PRIMARY KEY IDENTITY,
|
||||
name varchar(64) NOT NULL PRIMARY KEY,
|
||||
lock_until timestamp(3) DEFAULT CURRENT_TIMESTAMP(3) NOT NULL,
|
||||
locked_at timestamp(3) DEFAULT CURRENT_TIMESTAMP(3) NOT NULL,
|
||||
locked_by varchar(255) NULL,
|
||||
|
@ -72,7 +72,7 @@ public class JdbcLockProvider implements LockStorage, Lifecycle {
|
||||
} catch (DuplicateKeyException | ConcurrencyFailureException | TransactionSystemException e) {
|
||||
return false;
|
||||
} catch (DataIntegrityViolationException | BadSqlGrammarException | UncategorizedSQLException e) {
|
||||
SnailJobLog.LOCAL.error("Unexpected exception. lockName:[{}]", lockConfig.getLockName(), e);
|
||||
SnailJobLog.LOCAL.debug("Unexpected exception. lockName:[{}]", lockConfig.getLockName(), e);
|
||||
return false;
|
||||
}
|
||||
}));
|
||||
|
Loading…
Reference in New Issue
Block a user