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 63290421dd98a..699d3b024bc46 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 @@ private void insertRecord(String prefixPath, TSInsertRecordReq request) try { defaultSessionConnection.insertRecord(request); } catch (RedirectException ignored) { - logger.warn("session insertRecord fail:{}", ignored.getMessage()); } } else { throw e; @@ -1111,7 +1110,6 @@ private void insertRecord(String deviceId, TSInsertStringRecordReq request) try { defaultSessionConnection.insertRecord(request); } catch (RedirectException ignored) { - logger.warn("session insertRecord fail:{}", ignored.getMessage()); } } else { throw e; @@ -1417,7 +1415,6 @@ public void insertRecords( try { defaultSessionConnection.insertRecords(request); } catch (RedirectException ignored) { - logger.warn("session insertRecords fail:{}", ignored.getMessage()); } } } @@ -1664,7 +1661,6 @@ public void insertAlignedRecords( try { defaultSessionConnection.insertRecords(request); } catch (RedirectException ignored) { - logger.warn("session insertRecords fail:{}", ignored.getMessage()); } } } @@ -1837,7 +1833,6 @@ public void insertRecords( try { defaultSessionConnection.insertRecords(request); } catch (RedirectException ignored) { - logger.warn("session insertRecords fail:{}", ignored.getMessage()); } } } @@ -1880,7 +1875,6 @@ public void insertAlignedRecords( try { defaultSessionConnection.insertRecords(request); } catch (RedirectException ignored) { - logger.warn("session insertRecords fail:{}", ignored.getMessage()); } } } @@ -1952,7 +1946,6 @@ public void insertRecordsOfOneDevice( try { defaultSessionConnection.insertRecordsOfOneDevice(request); } catch (RedirectException ignored) { - logger.warn("session insertRecordsOfOneDevice fail:{}", ignored.getMessage()); } } else { throw e; @@ -2006,7 +1999,6 @@ public void insertStringRecordsOfOneDevice( try { defaultSessionConnection.insertStringRecordsOfOneDevice(req); } catch (RedirectException ignored) { - logger.warn("session insertStringRecordsOfOneDevice fail:{}", ignored.getMessage()); } } else { throw e; @@ -2101,7 +2093,6 @@ public void insertAlignedRecordsOfOneDevice( try { defaultSessionConnection.insertRecordsOfOneDevice(request); } catch (RedirectException ignored) { - logger.warn("session insertRecordsOfOneDevice fail:{}", ignored.getMessage()); } } else { throw e; @@ -2155,7 +2146,6 @@ public void insertAlignedStringRecordsOfOneDevice( try { defaultSessionConnection.insertStringRecordsOfOneDevice(req); } catch (RedirectException ignored) { - logger.warn("session insertStringRecordsOfOneDevice fail:{}", ignored.getMessage()); } } else { throw e; @@ -2470,7 +2460,6 @@ public void insertTablet(Tablet tablet, boolean sorted) try { defaultSessionConnection.insertTablet(request); } catch (RedirectException ignored) { - logger.warn("session insertTablet fail:{}", ignored.getMessage()); } } else { throw e; @@ -2519,7 +2508,6 @@ public void insertAlignedTablet(Tablet tablet, boolean sorted) try { defaultSessionConnection.insertTablet(request); } catch (RedirectException ignored) { - logger.warn("session insertTablet fail:{}", ignored.getMessage()); } } else { throw e; @@ -2579,7 +2567,6 @@ public void insertTablets(Map tablets, boolean sorted) try { defaultSessionConnection.insertTablets(request); } catch (RedirectException ignored) { - logger.warn("session insertTablets fail:{}", ignored.getMessage()); } } } @@ -2616,7 +2603,6 @@ public void insertAlignedTablets(Map tablets, boolean sorted) try { defaultSessionConnection.insertTablets(request); } catch (RedirectException ignored) { - logger.warn("session insertTablets fail:{}", ignored.getMessage()); } } } @@ -3412,7 +3398,6 @@ private void insertByGroup( } catch (IoTDBConnectionException | StatementExecutionException ex) { throw new CompletionException(ex); } catch (RedirectException ignored) { - logger.info("insert by group has been redirect"); } } },