diff --git a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/security/SecurityConfig.java b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/security/SecurityConfig.java index f2cf72cdbbb0aee08863a705d81416aa5d105fcd..823c9bdfba0cb75b51db5e63ca7ce7db81f9c407 100644 --- a/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/security/SecurityConfig.java +++ b/dolphinscheduler-api/src/main/java/org/apache/dolphinscheduler/api/security/SecurityConfig.java @@ -16,7 +16,7 @@ */ package org.apache.dolphinscheduler.api.security; -import org.apache.commons.lang3.StringUtils; +import org.apache.commons.lang.StringUtils; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.beans.factory.annotation.Autowired; diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java index c4cec686833b5613967e220f5a15d4bbee28646e..e5b9daf6f0806549e45b4f4de6fcc88b351b1a39 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/MasterServer.java @@ -141,7 +141,7 @@ public class MasterServer implements IStoppable { } catch (SchedulerException e1) { logger.error("QuartzExecutors shutdown failed : " + e1.getMessage(), e1); } - logger.error("start Quartz failed : " + e.getMessage(), e); + logger.error("start Quartz failed", e); } @@ -183,7 +183,7 @@ public class MasterServer implements IStoppable { //thread sleep 3 seconds for thread quitely stop Thread.sleep(3000L); }catch (Exception e){ - logger.warn("thread sleep exception:" + e.getMessage(), e); + logger.warn("thread sleep exception ", e); } try { heartbeatMasterService.shutdownNow(); @@ -228,7 +228,7 @@ public class MasterServer implements IStoppable { } catch (Exception e) { - logger.error("master server stop exception : " + e.getMessage(), e); + logger.error("master server stop exception ", e); System.exit(-1); } } diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java index 5c9675707202e15bd9d2ac82aebc24350bed725b..c1552c46210a8ba523f8502f0e392273ff053f51 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterBaseTaskExecThread.java @@ -140,7 +140,7 @@ public class MasterBaseTaskExecThread implements Callable { } Thread.sleep(commitRetryInterval); } catch (Exception e) { - logger.error("task commit to mysql and queue failed : " + e.getMessage(),e); + logger.error("task commit to mysql and queue failed",e); } retryTimes += 1; } diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java index ade47388844456cbefd0e43578bcb663f0d3e656..a91f8c17e661ec2e15008092683d79db841e819c 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterExecThread.java @@ -170,7 +170,7 @@ public class MasterExecThread implements Runnable { executeProcess(); } }catch (Exception e){ - logger.error("master exec thread exception: " + e.getMessage(), e); + logger.error("master exec thread exception", e); logger.error("process execute failed, process id:{}", processInstance.getId()); processInstance.setState(ExecutionStatus.FAILURE); processInstance.setEndTime(new Date()); @@ -355,7 +355,7 @@ public class MasterExecThread implements Runnable { try { FileUtils.deleteDirectory(new File(execLocalPath)); } catch (IOException e) { - logger.error("delete exec dir failed : " + e.getMessage(), e); + logger.error("delete exec dir failed ", e); } } } @@ -733,7 +733,7 @@ public class MasterExecThread implements Runnable { Date endTime = DateUtils.getScheduleDate(cmdParam.get(CMDPARAM_COMPLEMENT_DATA_END_DATE)); return processInstance.getScheduleTime().equals(endTime); } catch (Exception e) { - logger.error("complement end failed : " + e.getMessage(),e); + logger.error("complement end failed ",e); return false; } } @@ -1005,7 +1005,7 @@ public class MasterExecThread implements Runnable { return task; } }catch (Exception e){ - logger.error("get recovery task instance failed : " + e.getMessage(),e); + logger.error("get recovery task instance failed ",e); } return null; } diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java index 5f594b3fa03404438b527263eda0dd7c5bce32fb..1d34bbd14755d62ca32ad03e9867e04bfa379559 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterSchedulerThread.java @@ -134,7 +134,7 @@ public class MasterSchedulerThread implements Runnable { } } }catch (Exception e){ - logger.error("master scheduler thread exception : " + e.getMessage(),e); + logger.error("master scheduler thread exception",e); }finally{ AbstractZKClient.releaseMutex(mutex); } diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThread.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThread.java index 7d10591e0d8f50acb8f1e2add06f60a970164041..1861e8a908a1da09ec400688b8d010b10d1161a5 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThread.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/master/runner/MasterTaskExecThread.java @@ -137,7 +137,7 @@ public class MasterTaskExecThread extends MasterBaseTaskExecThread { processInstance = processDao.findProcessInstanceById(processInstance.getId()); Thread.sleep(Constants.SLEEP_TIME_MILLIS); } catch (Exception e) { - logger.error("exception: "+ e.getMessage(),e); + logger.error("exception",e); if (processInstance != null) { logger.error("wait task quit failed, instance id:{}, task id:{}", processInstance.getId(), taskInstance.getId()); diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/quartz/DruidConnectionProvider.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/quartz/DruidConnectionProvider.java index 32932127f0012bfc2b04b8185c7cc071d500e9c4..05100ac37492b510cc4b63b41ae70a7405b26338 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/quartz/DruidConnectionProvider.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/quartz/DruidConnectionProvider.java @@ -18,9 +18,9 @@ package org.apache.dolphinscheduler.server.quartz; import com.alibaba.druid.pool.DruidDataSource; import org.quartz.SchedulerException; +import org.quartz.utils.ConnectionProvider; import java.sql.Connection; import java.sql.SQLException; -import org.quartz.utils.ConnectionProvider; /** * druid connection provider @@ -137,7 +137,7 @@ public class DruidConnectionProvider implements ConnectionProvider { datasource.setDriverClassName(this.driver); } catch (Exception e) { try { - throw new SchedulerException("Problem setting driver class name on datasource: " + e.getMessage(), e); + throw new SchedulerException("Problem setting driver class name on datasource", e); } catch (SchedulerException e1) { } } diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/quartz/QuartzExecutors.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/quartz/QuartzExecutors.java index bb0f79897d48ac5fe41464c6f7aebf80951c0523..d4ad08faec1e869a3e9d286292414316048b275f 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/quartz/QuartzExecutors.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/quartz/QuartzExecutors.java @@ -27,7 +27,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import java.util.*; -import java.util.Calendar; import java.util.concurrent.locks.ReadWriteLock; import java.util.concurrent.locks.ReentrantReadWriteLock; @@ -198,7 +197,7 @@ public class QuartzExecutors { } catch (Exception e) { logger.error("add job failed", e); - throw new RuntimeException("add job failed:"+e.getMessage()); + throw new RuntimeException("add job failed", e); } finally { lock.writeLock().unlock(); } diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/rpc/LogClient.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/rpc/LogClient.java index 3f12ae75dda00c1a993f6bdef220dd33d81bd70d..1c6c97b88f2b4fc30990bd4b8cad59fe118d5609 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/rpc/LogClient.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/rpc/LogClient.java @@ -102,7 +102,7 @@ public class LogClient { retStrInfo = blockingStub.rollViewLog(pathParameter); return retStrInfo.getMsg(); } catch (StatusRuntimeException e) { - logger.error("roll view log failed : " + e.getMessage(), e); + logger.error("roll view log failed", e); return null; } } @@ -122,7 +122,7 @@ public class LogClient { retStrInfo = blockingStub.viewLog(pathParameter); return retStrInfo.getMsg(); } catch (StatusRuntimeException e) { - logger.error("view log failed : " + e.getMessage(), e); + logger.error("view log failed", e); return null; } } @@ -142,7 +142,7 @@ public class LogClient { retByteInfo = blockingStub.getLogBytes(pathParameter); return retByteInfo.getData().toByteArray(); } catch (StatusRuntimeException e) { - logger.error("get log bytes failed : " + e.getMessage(), e); + logger.error("get log bytes failed ", e); return null; } } diff --git a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils/ProcessUtils.java b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils/ProcessUtils.java index 7cba139cecd6366f4d125dcf47ef009bfe5a7a3a..0b621a9bb0c5ffb0c3adaca068fc18335d14bc53 100644 --- a/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils/ProcessUtils.java +++ b/dolphinscheduler-server/src/main/java/org/apache/dolphinscheduler/server/utils/ProcessUtils.java @@ -308,7 +308,7 @@ public class ProcessUtils { Runtime.getRuntime().exec(runCmd); } catch (Exception e) { - logger.error("kill application failed : " + e.getMessage(), e); + logger.error("kill application failed", e); } } } @@ -337,7 +337,7 @@ public class ProcessUtils { killYarnJob(taskInstance); } catch (Exception e) { - logger.error("kill failed : " + e.getMessage(), e); + logger.error("kill task failed", e); } }