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");
}
}
},