From e423b38db24a34aaa958ef1b930c666bedbe5810 Mon Sep 17 00:00:00 2001
From: renliangyu857 <2918490262@qq.com>
Date: Thu, 29 Dec 2022 11:34:13 +0800
Subject: [PATCH] optimize: log message level (#5212)

---
 changes/en-us/develop.md                               |  3 +--
 changes/zh-cn/develop.md                               |  2 +-
 .../java/io/seata/console/utils/JwtTokenUtils.java     | 10 +++++-----
 .../seata/core/exception/AbstractExceptionHandler.java |  4 ++--
 .../java/io/seata/rm/datasource/DataSourceManager.java |  2 +-
 .../io/seata/rm/datasource/xa/ResourceManagerXA.java   |  6 +++---
 .../seata/server/coordinator/DefaultCoordinator.java   |  4 ++--
 .../java/io/seata/server/coordinator/DefaultCore.java  |  5 +++--
 .../java/io/seata/server/session/SessionHolder.java    |  2 +-
 9 files changed, 19 insertions(+), 19 deletions(-)

diff --git a/changes/en-us/develop.md b/changes/en-us/develop.md
index ad1bc17fd16..d19fb1b8e54 100644
--- a/changes/en-us/develop.md
+++ b/changes/en-us/develop.md
@@ -6,12 +6,11 @@ Add changes here for all PR submitted to the develop branch.
 - [[#xxx](https://github.com/seata/seata/pull/xxx)] support xxx
 
 ### bugfix:
-- [[#xxx](https://github.com/seata/seata/pull/xxx)] fix xxx
 - [[#5194](https://github.com/seata/seata/pull/5194)] fix wrong keyword order for oracle when creating a table
 - [[#5021](https://github.com/seata/seata/pull/5201)] Fix JDK Reflection for Spring origin proxy failed in JDK17
 
 ### optimize:
-- [[#xxx](https://github.com/seata/seata/pull/xxx)] optimize xxx
+- [[#5212](https://github.com/seata/seata/pull/5212)] optimize log message level
 
 ### test:
 - [[#xxx](https://github.com/seata/seata/pull/xxx)] add test for xxx
diff --git a/changes/zh-cn/develop.md b/changes/zh-cn/develop.md
index 85bc34e0da1..63921213087 100644
--- a/changes/zh-cn/develop.md
+++ b/changes/zh-cn/develop.md
@@ -11,7 +11,7 @@
 - [[#5021](https://github.com/seata/seata/pull/5201)] 修复 JDK17 下获取 Spring 原始代理对象失败的问题
 
 ### optimize:
-- [[#xxx](https://github.com/seata/seata/pull/xxx)] 优化 xxx
+- [[#5212](https://github.com/seata/seata/pull/5212)] 优化不合理的日志信息级别
 
 ### test:
 - [[#xxx](https://github.com/seata/seata/pull/xxx)] 增加 xxx 测试
diff --git a/console/src/main/java/io/seata/console/utils/JwtTokenUtils.java b/console/src/main/java/io/seata/console/utils/JwtTokenUtils.java
index 1c5d46f2939..9166955882b 100644
--- a/console/src/main/java/io/seata/console/utils/JwtTokenUtils.java
+++ b/console/src/main/java/io/seata/console/utils/JwtTokenUtils.java
@@ -119,19 +119,19 @@ public boolean validateToken(String token) {
             Jwts.parser().setSigningKey(secretKey).parseClaimsJws(token);
             return true;
         } catch (SignatureException e) {
-            LOGGER.info("Invalid JWT signature.");
+            LOGGER.warn("Invalid JWT signature.");
             LOGGER.trace("Invalid JWT signature trace: {}", e);
         } catch (MalformedJwtException e) {
-            LOGGER.info("Invalid JWT token.");
+            LOGGER.warn("Invalid JWT token.");
             LOGGER.trace("Invalid JWT token trace: {}", e);
         } catch (ExpiredJwtException e) {
-            LOGGER.info("Expired JWT token.");
+            LOGGER.warn("Expired JWT token.");
             LOGGER.trace("Expired JWT token trace: {}", e);
         } catch (UnsupportedJwtException e) {
-            LOGGER.info("Unsupported JWT token.");
+            LOGGER.warn("Unsupported JWT token.");
             LOGGER.trace("Unsupported JWT token trace: {}", e);
         } catch (IllegalArgumentException e) {
-            LOGGER.info("JWT token compact of handler are invalid.");
+            LOGGER.warn("JWT token compact of handler are invalid.");
             LOGGER.trace("JWT token compact of handler are invalid trace: {}", e);
         }
         return false;
diff --git a/core/src/main/java/io/seata/core/exception/AbstractExceptionHandler.java b/core/src/main/java/io/seata/core/exception/AbstractExceptionHandler.java
index 013fd901557..b859e984a69 100644
--- a/core/src/main/java/io/seata/core/exception/AbstractExceptionHandler.java
+++ b/core/src/main/java/io/seata/core/exception/AbstractExceptionHandler.java
@@ -132,10 +132,10 @@ public <T extends AbstractTransactionRequest, S extends AbstractTransactionRespo
             callback.onSuccess(request, response);
         } catch (TransactionException tex) {
             if (Objects.equals(LockKeyConflict, tex.getCode())) {
-                LOGGER.info("this request cannot acquire global lock, you can let Seata retry by setting config [{}] = false or manually retry by yourself. request: {}",
+                LOGGER.error("this request cannot acquire global lock, you can let Seata retry by setting config [{}] = false or manually retry by yourself. request: {}",
                         ConfigurationKeys.CLIENT_LOCK_RETRY_POLICY_BRANCH_ROLLBACK_ON_CONFLICT, request);
             } else if (Objects.equals(LockKeyConflictFailFast, tex.getCode())) {
-                LOGGER.info("this request cannot acquire global lock, decide fail-fast because LockStatus is {}. request: {}",
+                LOGGER.error("this request cannot acquire global lock, decide fail-fast because LockStatus is {}. request: {}",
                         LockStatus.Rollbacking, request);
             } else {
                 LOGGER.error("Catch TransactionException while do RPC, request: {}", request, tex);
diff --git a/rm-datasource/src/main/java/io/seata/rm/datasource/DataSourceManager.java b/rm-datasource/src/main/java/io/seata/rm/datasource/DataSourceManager.java
index 8b2b9e59b34..6e24db3f765 100644
--- a/rm-datasource/src/main/java/io/seata/rm/datasource/DataSourceManager.java
+++ b/rm-datasource/src/main/java/io/seata/rm/datasource/DataSourceManager.java
@@ -121,7 +121,7 @@ public BranchStatus branchRollback(BranchType branchType, String xid, long branc
         try {
             UndoLogManagerFactory.getUndoLogManager(dataSourceProxy.getDbType()).undo(dataSourceProxy, xid, branchId);
         } catch (TransactionException te) {
-            StackTraceLogger.info(LOGGER, te,
+            StackTraceLogger.error(LOGGER, te,
                 "branchRollback failed. branchType:[{}], xid:[{}], branchId:[{}], resourceId:[{}], applicationData:[{}]. reason:[{}]",
                 new Object[]{branchType, xid, branchId, resourceId, applicationData, te.getMessage()});
             if (te.getCode() == TransactionExceptionCode.BranchRollbackFailed_Unretriable) {
diff --git a/rm-datasource/src/main/java/io/seata/rm/datasource/xa/ResourceManagerXA.java b/rm-datasource/src/main/java/io/seata/rm/datasource/xa/ResourceManagerXA.java
index b8b333fb537..e7d59e863dc 100644
--- a/rm-datasource/src/main/java/io/seata/rm/datasource/xa/ResourceManagerXA.java
+++ b/rm-datasource/src/main/java/io/seata/rm/datasource/xa/ResourceManagerXA.java
@@ -87,7 +87,7 @@ public void initXaTwoPhaseTimeoutChecker() {
                                                     try {
                                                         connection.closeForce();
                                                     } catch (SQLException e) {
-                                                        LOGGER.info("Force close the xa physical connection fail", e);
+                                                        LOGGER.warn("Force close the xa physical connection fail", e);
                                                     }
                                                 }
                                             }
@@ -151,11 +151,11 @@ private BranchStatus finishBranch(boolean committed, BranchType branchType, Stri
                     }
                 }
                 if (committed) {
-                    LOGGER.info(xaBranchXid + " commit failed since " + sqle.getMessage(), sqle);
+                    LOGGER.error(xaBranchXid + " commit failed since " + sqle.getMessage(), sqle);
                     // FIXME: case of PhaseTwo_CommitFailed_Unretryable
                     return BranchStatus.PhaseTwo_CommitFailed_Retryable;
                 } else {
-                    LOGGER.info(xaBranchXid + " rollback failed since " + sqle.getMessage(), sqle);
+                    LOGGER.error(xaBranchXid + " rollback failed since " + sqle.getMessage(), sqle);
                     // FIXME: case of PhaseTwo_RollbackFailed_Unretryable
                     return BranchStatus.PhaseTwo_RollbackFailed_Retryable;
                 }
diff --git a/server/src/main/java/io/seata/server/coordinator/DefaultCoordinator.java b/server/src/main/java/io/seata/server/coordinator/DefaultCoordinator.java
index 4c50f19ce50..e109ee4aa04 100644
--- a/server/src/main/java/io/seata/server/coordinator/DefaultCoordinator.java
+++ b/server/src/main/java/io/seata/server/coordinator/DefaultCoordinator.java
@@ -387,7 +387,7 @@ protected void handleRetryRollbacking() {
                 rollbackingSession.addSessionLifecycleListener(SessionHolder.getRootSessionManager());
                 core.doGlobalRollback(rollbackingSession, true);
             } catch (TransactionException ex) {
-                LOGGER.info("Failed to retry rollbacking [{}] {} {}", rollbackingSession.getXid(), ex.getCode(), ex.getMessage());
+                LOGGER.error("Failed to retry rollbacking [{}] {} {}", rollbackingSession.getXid(), ex.getCode(), ex.getMessage());
             }
         });
     }
@@ -426,7 +426,7 @@ protected void handleRetryCommitting() {
                 committingSession.addSessionLifecycleListener(SessionHolder.getRootSessionManager());
                 core.doGlobalCommit(committingSession, true);
             } catch (TransactionException ex) {
-                LOGGER.info("Failed to retry committing [{}] {} {}", committingSession.getXid(), ex.getCode(), ex.getMessage());
+                LOGGER.error("Failed to retry committing [{}] {} {}", committingSession.getXid(), ex.getCode(), ex.getMessage());
             }
         });
     }
diff --git a/server/src/main/java/io/seata/server/coordinator/DefaultCore.java b/server/src/main/java/io/seata/server/coordinator/DefaultCore.java
index 80d086dcaa5..730a8c72413 100644
--- a/server/src/main/java/io/seata/server/coordinator/DefaultCore.java
+++ b/server/src/main/java/io/seata/server/coordinator/DefaultCore.java
@@ -217,6 +217,7 @@ public boolean doGlobalCommit(GlobalSession globalSession, boolean retrying) thr
                     switch (branchStatus) {
                         case PhaseTwo_Committed:
                             SessionHelper.removeBranch(globalSession, branchSession, !retrying);
+                            LOGGER.info("Commit branch transaction successfully, xid = {} branchId = {}", globalSession.getXid(), branchSession.getBranchId());
                             return CONTINUE;
                         case PhaseTwo_CommitFailed_Unretryable:
                             //not at branch
@@ -325,10 +326,10 @@ public boolean doGlobalRollback(GlobalSession globalSession, boolean retrying) t
                             return CONTINUE;
                         case PhaseTwo_RollbackFailed_Unretryable:
                             SessionHelper.endRollbackFailed(globalSession, retrying);
-                            LOGGER.info("Rollback branch transaction fail and stop retry, xid = {} branchId = {}", globalSession.getXid(), branchSession.getBranchId());
+                            LOGGER.error("Rollback branch transaction fail and stop retry, xid = {} branchId = {}", globalSession.getXid(), branchSession.getBranchId());
                             return false;
                         default:
-                            LOGGER.info("Rollback branch transaction fail and will retry, xid = {} branchId = {}", globalSession.getXid(), branchSession.getBranchId());
+                            LOGGER.error("Rollback branch transaction fail and will retry, xid = {} branchId = {}", globalSession.getXid(), branchSession.getBranchId());
                             if (!retrying) {
                                 globalSession.queueToRetryRollback();
                             }
diff --git a/server/src/main/java/io/seata/server/session/SessionHolder.java b/server/src/main/java/io/seata/server/session/SessionHolder.java
index eeea2551487..b8f530042a4 100644
--- a/server/src/main/java/io/seata/server/session/SessionHolder.java
+++ b/server/src/main/java/io/seata/server/session/SessionHolder.java
@@ -399,7 +399,7 @@ public static boolean distributedLockAndExecute(String key, NoArgsFunc func) {
                 func.call();
             }
         } catch (Exception e) {
-            LOGGER.info("Exception running function with key = {}", key, e);
+            LOGGER.error("Exception running function with key = {}", key, e);
         } finally {
             if (lock) {
                 try {