diff --git a/node/src/main/java/com/tron/client/OracleClient.java b/node/src/main/java/com/tron/client/OracleClient.java index bbdb598..af2c883 100644 --- a/node/src/main/java/com/tron/client/OracleClient.java +++ b/node/src/main/java/com/tron/client/OracleClient.java @@ -37,6 +37,8 @@ import java.util.List; import java.util.Map; import java.util.Set; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit; @@ -68,7 +70,7 @@ public class OracleClient { private static Cache requestIdsCache = CacheBuilder.newBuilder().maximumSize(10000) .expireAfterWrite(12, TimeUnit.HOURS).recordStats().build(); - private static HashMap> listeningAddrs = Maps.newHashMap(); + private static ConcurrentHashMap> listeningAddrs = new ConcurrentHashMap<>(); private HashMap consumeIndexMap = Maps.newHashMap(); private ScheduledExecutorService listenExecutor = Executors.newSingleThreadScheduledExecutor(); diff --git a/node/src/main/resources/mapper/demo/JobRunsMapper.xml b/node/src/main/resources/mapper/demo/JobRunsMapper.xml index db7a468..086ca91 100644 --- a/node/src/main/resources/mapper/demo/JobRunsMapper.xml +++ b/node/src/main/resources/mapper/demo/JobRunsMapper.xml @@ -74,7 +74,7 @@ UPDATE job_runs SET `status` = #{status}, - updated_at = DATE_FORMAT(NOW(),'%Y-%m-%d %H:%m:%s') + updated_at = DATE_FORMAT(NOW(),'%Y-%m-%d %H:%i:%s') ,`error` = #{error} diff --git a/node/src/main/resources/mapper/demo/TaskRunsMapper.xml b/node/src/main/resources/mapper/demo/TaskRunsMapper.xml index db5fab2..020f55a 100644 --- a/node/src/main/resources/mapper/demo/TaskRunsMapper.xml +++ b/node/src/main/resources/mapper/demo/TaskRunsMapper.xml @@ -51,7 +51,7 @@ UPDATE task_runs SET `status` = #{status}, - updated_at = DATE_FORMAT(NOW(),'%Y-%m-%d %H:%m:%s') + updated_at = DATE_FORMAT(NOW(),'%Y-%m-%d %H:%i:%s') ,`error` = #{error}