This is an automated email from the ASF dual-hosted git repository.
rong 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 46daebab423 Pipe: Fix potential NPE when lastEvent == null in
PipeConnectorSubtask (#12680)
46daebab423 is described below
commit 46daebab4234ae2f2013f77d467cc8427b214880
Author: Caideyipi <[email protected]>
AuthorDate: Thu Jun 6 18:16:30 2024 +0800
Pipe: Fix potential NPE when lastEvent == null in PipeConnectorSubtask
(#12680)
---
.../iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtask.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtask.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtask.java
index 22e87c7e5c8..40ac29eaa81 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtask.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/task/subtask/connector/PipeConnectorSubtask.java
@@ -144,7 +144,7 @@ public class PipeConnectorSubtask extends
PipeAbstractConnectorSubtask {
taskID,
lastEvent instanceof EnrichedEvent
? ((EnrichedEvent) lastEvent).coreReportMessage()
- : lastEvent.toString(),
+ : lastEvent,
ErrorHandlingUtils.getRootCause(e).getMessage()),
e);
} else {
