This is an automated email from the ASF dual-hosted git repository.

haonan pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new fc5d228abb3 fix(session): remove ignored logs (#11749)
fc5d228abb3 is described below

commit fc5d228abb31ebb3dd9cfbbb9421a74a98143c8c
Author: CritasWang <[email protected]>
AuthorDate: Tue Dec 19 18:06:13 2023 +0800

    fix(session): remove ignored logs (#11749)
---
 .../src/main/java/org/apache/iotdb/session/Session.java   | 15 ---------------
 1 file changed, 15 deletions(-)

diff --git 
a/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java 
b/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java
index 63290421dd9..699d3b024bc 100644
--- a/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java
+++ b/iotdb-client/session/src/main/java/org/apache/iotdb/session/Session.java
@@ -1086,7 +1086,6 @@ public class Session implements ISession {
         try {
           defaultSessionConnection.insertRecord(request);
         } catch (RedirectException ignored) {
-          logger.warn("session insertRecord fail:{}", ignored.getMessage());
         }
       } else {
         throw e;
@@ -1111,7 +1110,6 @@ public class Session implements ISession {
         try {
           defaultSessionConnection.insertRecord(request);
         } catch (RedirectException ignored) {
-          logger.warn("session insertRecord fail:{}", ignored.getMessage());
         }
       } else {
         throw e;
@@ -1417,7 +1415,6 @@ public class Session implements ISession {
       try {
         defaultSessionConnection.insertRecords(request);
       } catch (RedirectException ignored) {
-        logger.warn("session insertRecords fail:{}", ignored.getMessage());
       }
     }
   }
@@ -1664,7 +1661,6 @@ public class Session implements ISession {
       try {
         defaultSessionConnection.insertRecords(request);
       } catch (RedirectException ignored) {
-        logger.warn("session insertRecords fail:{}", ignored.getMessage());
       }
     }
   }
@@ -1837,7 +1833,6 @@ public class Session implements ISession {
       try {
         defaultSessionConnection.insertRecords(request);
       } catch (RedirectException ignored) {
-        logger.warn("session insertRecords fail:{}", ignored.getMessage());
       }
     }
   }
@@ -1880,7 +1875,6 @@ public class Session implements ISession {
       try {
         defaultSessionConnection.insertRecords(request);
       } catch (RedirectException ignored) {
-        logger.warn("session insertRecords fail:{}", ignored.getMessage());
       }
     }
   }
@@ -1952,7 +1946,6 @@ public class Session implements ISession {
         try {
           defaultSessionConnection.insertRecordsOfOneDevice(request);
         } catch (RedirectException ignored) {
-          logger.warn("session insertRecordsOfOneDevice fail:{}", 
ignored.getMessage());
         }
       } else {
         throw e;
@@ -2006,7 +1999,6 @@ public class Session implements ISession {
         try {
           defaultSessionConnection.insertStringRecordsOfOneDevice(req);
         } catch (RedirectException ignored) {
-          logger.warn("session insertStringRecordsOfOneDevice fail:{}", 
ignored.getMessage());
         }
       } else {
         throw e;
@@ -2101,7 +2093,6 @@ public class Session implements ISession {
         try {
           defaultSessionConnection.insertRecordsOfOneDevice(request);
         } catch (RedirectException ignored) {
-          logger.warn("session insertRecordsOfOneDevice fail:{}", 
ignored.getMessage());
         }
       } else {
         throw e;
@@ -2155,7 +2146,6 @@ public class Session implements ISession {
         try {
           defaultSessionConnection.insertStringRecordsOfOneDevice(req);
         } catch (RedirectException ignored) {
-          logger.warn("session insertStringRecordsOfOneDevice fail:{}", 
ignored.getMessage());
         }
       } else {
         throw e;
@@ -2470,7 +2460,6 @@ public class Session implements ISession {
         try {
           defaultSessionConnection.insertTablet(request);
         } catch (RedirectException ignored) {
-          logger.warn("session insertTablet fail:{}", ignored.getMessage());
         }
       } else {
         throw e;
@@ -2519,7 +2508,6 @@ public class Session implements ISession {
         try {
           defaultSessionConnection.insertTablet(request);
         } catch (RedirectException ignored) {
-          logger.warn("session insertTablet fail:{}", ignored.getMessage());
         }
       } else {
         throw e;
@@ -2579,7 +2567,6 @@ public class Session implements ISession {
       try {
         defaultSessionConnection.insertTablets(request);
       } catch (RedirectException ignored) {
-        logger.warn("session insertTablets fail:{}", ignored.getMessage());
       }
     }
   }
@@ -2616,7 +2603,6 @@ public class Session implements ISession {
       try {
         defaultSessionConnection.insertTablets(request);
       } catch (RedirectException ignored) {
-        logger.warn("session insertTablets fail:{}", ignored.getMessage());
       }
     }
   }
@@ -3412,7 +3398,6 @@ public class Session implements ISession {
                           } catch (IoTDBConnectionException | 
StatementExecutionException ex) {
                             throw new CompletionException(ex);
                           } catch (RedirectException ignored) {
-                            logger.info("insert by group has been redirect");
                           }
                         }
                       },

Reply via email to