This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch log-npe-13
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to refs/heads/log-npe-13 by this push:
new 3805935432f may-c (#16859)
3805935432f is described below
commit 3805935432fac055e8a77dbfa6911f3fc9786be3
Author: Caideyipi <[email protected]>
AuthorDate: Thu Dec 4 10:56:29 2025 +0800
may-c (#16859)
---
.../db/queryengine/plan/statement/crud/InsertTabletStatement.java | 7 ++++++-
.../iotdb/commons/pipe/receiver/PipeReceiverStatusHandler.java | 6 ++++--
2 files changed, 10 insertions(+), 3 deletions(-)
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/InsertTabletStatement.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/InsertTabletStatement.java
index f73443fd17b..2e393678c5d 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/InsertTabletStatement.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/crud/InsertTabletStatement.java
@@ -20,6 +20,7 @@
package org.apache.iotdb.db.queryengine.plan.statement.crud;
import org.apache.iotdb.common.rpc.thrift.TTimePartitionSlot;
+import org.apache.iotdb.commons.conf.CommonDescriptor;
import org.apache.iotdb.commons.exception.MetadataException;
import org.apache.iotdb.commons.path.PartialPath;
import org.apache.iotdb.commons.schema.view.LogicalViewSchema;
@@ -492,11 +493,15 @@ public class InsertTabletStatement extends
InsertBaseStatement implements ISchem
@Override
public String toString() {
+ final int size =
CommonDescriptor.getInstance().getConfig().getPathLogMaxSize();
return "InsertTabletStatement{"
+ "devicePath="
+ devicePath
+ ", measurements="
- + Arrays.toString(measurements)
+ + Arrays.toString(
+ Objects.nonNull(measurements) && measurements.length > size
+ ? Arrays.copyOf(measurements, size)
+ : measurements)
+ ", rowCount="
+ rowCount
+ ", timeRange=["
diff --git
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/PipeReceiverStatusHandler.java
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/PipeReceiverStatusHandler.java
index ed92abd3ef2..21597702ae5 100644
---
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/PipeReceiverStatusHandler.java
+++
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/receiver/PipeReceiverStatusHandler.java
@@ -33,6 +33,8 @@ import org.apache.iotdb.rpc.TSStatusCode;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+import javax.annotation.Nullable;
+
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
@@ -104,7 +106,7 @@ public class PipeReceiverStatusHandler {
*/
public void handle(
final TSStatus status,
- final String exceptionMessage,
+ final @Nullable String exceptionMessage,
final String recordMessage,
final boolean log4NoPrivileges) {
switch (status.getCode()) {
@@ -192,7 +194,7 @@ public class PipeReceiverStatusHandler {
break;
default:
// Some auth error may be wrapped in other codes
- if (exceptionMessage.contains(NO_PERMISSION_STR)) {
+ if (Objects.nonNull(exceptionMessage) &&
exceptionMessage.contains(NO_PERMISSION_STR)) {
if (skipIfNoPrivileges) {
if (log4NoPrivileges && LOGGER.isWarnEnabled()) {
LOGGER.warn(
