未验证 提交 715b696d 编写于 作者: journey2018's avatar journey2018 提交者: GitHub

logger filter modify (#663)

* Filtering the log of one task to the log of another task

* Filtering the log of one task to the log of another task update

* rollback

* The log shows confusion

* update loggerserver

* update

* datasource connect error modify

* rollback code,logger server log filter ,process variables modify local variables

* Client ip changes, sessionId cannot be accessed modify

* mr and spark task tenant queue set error modify

* tenant queryById modify

* update

* update

* update

* update

* TaskSchedulerThread TaskProps setTenantCode

* logger filter modify
上级 91e1ba5b
......@@ -100,11 +100,11 @@ public class LoggerServer {
StringBuilder sb = new StringBuilder();
boolean errorLineFlag = false;
for (String line : list){
if (line.startsWith("[INFO]")){
if (line.contains("TaskLogger")){
errorLineFlag = filterLine(request.getPath(),line);
}
if (!errorLineFlag || !line.startsWith("[INFO]")){
if (!errorLineFlag || !line.contains("TaskLogger")){
sb.append(line + "\r\n");
}
}
......@@ -192,11 +192,11 @@ public class LoggerServer {
br = new BufferedReader(new InputStreamReader(new FileInputStream(path)));
boolean errorLineFlag = false;
while ((line = br.readLine()) != null){
if (line.startsWith("[INFO]")){
if (line.contains("TaskLogger")){
errorLineFlag = filterLine(path,line);
}
if (!errorLineFlag || !line.startsWith("[INFO]")){
if (!errorLineFlag || !line.startsWith("TaskLogger")){
sb.append(line + "\r\n");
}
}
......@@ -218,7 +218,7 @@ public class LoggerServer {
/**
*
*
* @param path
* @param line
* @return
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册