This is an automated email from the ASF dual-hosted git repository.
justinchen 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 b86ea430b69 Create Multi Time Series: Modify logger level & Pipe:
Adjusted the show pipe privilege (#16439)
b86ea430b69 is described below
commit b86ea430b69cc1453bdd834583e391223b09ee8b
Author: Caideyipi <[email protected]>
AuthorDate: Tue Sep 30 18:13:31 2025 +0800
Create Multi Time Series: Modify logger level & Pipe: Adjusted the show
pipe privilege (#16439)
* info
* Update PipeTableResp.java
* fix
* remove-unsure
---
.../consensus/response/pipe/task/PipeTableResp.java | 3 ++-
.../execution/executor/RegionWriteExecutor.java | 14 +++++++-------
2 files changed, 9 insertions(+), 8 deletions(-)
diff --git
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/task/PipeTableResp.java
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/task/PipeTableResp.java
index af5f803364c..5b5393eaa68 100644
---
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/task/PipeTableResp.java
+++
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/response/pipe/task/PipeTableResp.java
@@ -21,6 +21,7 @@ package
org.apache.iotdb.confignode.consensus.response.pipe.task;
import org.apache.iotdb.common.rpc.thrift.TSStatus;
import org.apache.iotdb.commons.auth.authorizer.BasicAuthorizer;
+import org.apache.iotdb.commons.auth.entity.PrivilegeType;
import org.apache.iotdb.commons.exception.IllegalPathException;
import org.apache.iotdb.commons.exception.pipe.PipeRuntimeException;
import org.apache.iotdb.commons.pipe.agent.plugin.builtin.BuiltinPipePlugin;
@@ -118,7 +119,7 @@ public class PipeTableResp implements DataSet {
public boolean isVisible4User(final String userName, final PipeStaticMeta
meta) {
try {
return Objects.isNull(userName)
- || BasicAuthorizer.getInstance().isAdmin(userName)
+ ||
BasicAuthorizer.getInstance().getUser(userName).checkSysPrivilege(PrivilegeType.SYSTEM)
|| isVisible4SourceUser(userName, meta.getSourceParameters())
|| isVisible4SinkUser(userName, meta.getSinkParameters());
} catch (final Exception e) {
diff --git
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java
index 60dda197578..f4aca5e157e 100644
---
a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java
+++
b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/execution/executor/RegionWriteExecutor.java
@@ -100,7 +100,7 @@ public class RegionWriteExecutor {
private static final PerformanceOverviewMetrics PERFORMANCE_OVERVIEW_METRICS
=
PerformanceOverviewMetrics.getInstance();
- private static final String METADATA_ERROR_MSG = "Metadata error: ";
+ private static final String METADATA_ERROR_MSG = "Metadata error: {}";
private static final IoTDBConfig CONFIG =
IoTDBDescriptor.getInstance().getConfig();
@@ -422,7 +422,7 @@ public class RegionWriteExecutor {
return super.visitCreateTimeSeries(node, context);
} else {
final MetadataException metadataException =
failingMeasurementMap.get(0);
- LOGGER.warn(METADATA_ERROR_MSG, metadataException);
+ LOGGER.info(METADATA_ERROR_MSG, metadataException.getMessage());
return RegionExecutionResult.create(
false,
metadataException.getMessage(),
@@ -477,7 +477,7 @@ public class RegionWriteExecutor {
} else {
final MetadataException metadataException =
failingMeasurementMap.values().iterator().next();
- LOGGER.warn(METADATA_ERROR_MSG, metadataException);
+ LOGGER.info(METADATA_ERROR_MSG, metadataException.getMessage());
return RegionExecutionResult.create(
false,
metadataException.getMessage(),
@@ -584,7 +584,7 @@ public class RegionWriteExecutor {
for (final Map.Entry<Integer, MetadataException> failingMeasurement :
failingMeasurementMap.entrySet()) {
- LOGGER.warn(METADATA_ERROR_MSG, failingMeasurement.getValue());
+ LOGGER.info(METADATA_ERROR_MSG,
failingMeasurement.getValue().getMessage());
failingStatus.add(
RpcUtils.getStatus(
failingMeasurement.getValue().getErrorCode(),
@@ -669,7 +669,7 @@ public class RegionWriteExecutor {
final int errorCode = metadataException.getErrorCode();
if (errorCode != TSStatusCode.PATH_ALREADY_EXIST.getStatusCode()
|| errorCode !=
TSStatusCode.ALIAS_ALREADY_EXIST.getStatusCode()) {
- LOGGER.warn(METADATA_ERROR_MSG, metadataException);
+ LOGGER.info(METADATA_ERROR_MSG,
metadataException.getMessage());
}
failingStatus.add(
RpcUtils.getStatus(
@@ -764,7 +764,7 @@ public class RegionWriteExecutor {
((MeasurementAlreadyExistException)
metadataException)
.getMeasurementPath())));
} else {
- LOGGER.warn(METADATA_ERROR_MSG, metadataException);
+ LOGGER.info(METADATA_ERROR_MSG,
metadataException.getMessage());
failingStatus.add(
RpcUtils.getStatus(
metadataException.getErrorCode(),
metadataException.getMessage()));
@@ -1063,7 +1063,7 @@ public class RegionWriteExecutor {
// if there are some exceptions, handle each exception and return
first of them.
if (!failingMetadataException.isEmpty()) {
final MetadataException metadataException =
failingMetadataException.get(0);
- LOGGER.warn(METADATA_ERROR_MSG, metadataException);
+ LOGGER.info(METADATA_ERROR_MSG, metadataException.getMessage());
return RegionExecutionResult.create(
false,
metadataException.getMessage(),
