[iotdb] 02/02: [IOTDB-6021] Pipe: NPE when sync TEXT timeseries with null fields between IoTDB instances using file mode with pattern filter

[ro...@apache.org]

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

rong pushed a commit to branch fix-pipe-tablet-with-nullable-binary-columns
in repository https://gitbox.apache.org/repos/asf/iotdb.git

commit 6d2ad66adc83a1089339de97655a3f00047a2484
Author: Steve Yurong Su <ro...@apache.org>
AuthorDate: Thu Jun 22 04:04:52 2023 +0800

    [IOTDB-6021] Pipe: NPE when sync TEXT timeseries with null fields between IoTDB instances using file mode with pattern filter
---
 .../org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java  | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java b/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java
index 47dd1ba7e03..4dc322b90ed 100644
--- a/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java
+++ b/server/src/main/java/org/apache/iotdb/db/pipe/task/subtask/PipeConnectorSubtask.java
@@ -160,6 +160,11 @@ public class PipeConnectorSubtask extends PipeSubtask {
         // stop current pipe task if failed to reconnect to the target system after MAX_RETRY_TIMES
         return;
       }
+    } else {
+      LOGGER.warn(
+          "A non-PipeConnectionException occurred, exception message: {}",
+          throwable.getMessage(),
+          throwable);
     }
 
     // handle other exceptions as usual