You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ju...@apache.org on 2025/12/17 07:32:24 UTC
(iotdb) 04/07: [TIMECHODB] Handle audit
This is an automated email from the ASF dual-hosted git repository.
justinchen pushed a commit to branch cp-206
in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 96545209e781eea67cfd505a0517bda5eca8cf9c
Author: Caideyipi <87...@users.noreply.github.com>
AuthorDate: Fri Nov 7 15:32:11 2025 +0800
[TIMECHODB] Handle audit
---
.../PipeConfigPhysicalPlanTreePatternParseVisitor.java | 2 +-
.../impl/schema/AlterEncodingCompressorProcedure.java | 14 ++++++++------
.../metadata/AlterEncodingCompressorStatement.java | 2 ++
3 files changed, 11 insertions(+), 7 deletions(-)
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigPhysicalPlanTreePatternParseVisitor.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigPhysicalPlanTreePatternParseVisitor.java
index 8aa0ae42dab..c0e394d5a93 100644
--- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigPhysicalPlanTreePatternParseVisitor.java
+++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/pipe/source/PipeConfigPhysicalPlanTreePatternParseVisitor.java
@@ -254,7 +254,7 @@ public class PipeConfigPhysicalPlanTreePatternParseVisitor
@Override
public Optional<ConfigPhysicalPlan> visitPipeAlterEncodingCompressor(
final PipeAlterEncodingCompressorPlan pipeAlterEncodingCompressorPlan,
- final UnionIoTDBTreePattern pattern) {
+ final IoTDBTreePattern pattern) {
try {
final PathPatternTree intersectedTree =
pattern.getIntersection(
diff --git a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterEncodingCompressorProcedure.java b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterEncodingCompressorProcedure.java
index a76e3494d05..bdae18e4692 100644
--- a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterEncodingCompressorProcedure.java
+++ b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/schema/AlterEncodingCompressorProcedure.java
@@ -69,7 +69,9 @@ public class AlterEncodingCompressorProcedure
private boolean ifExists;
private byte encoding;
private byte compressor;
- private boolean mayAlterAudit;
+
+ // Reserved for potential upgrading
+ private boolean mayAlterAudit = false;
private transient ByteBuffer patternTreeBytes;
private transient String requestMessage;
@@ -147,7 +149,7 @@ public class AlterEncodingCompressorProcedure
private void alterEncodingCompressorInSchemaRegion(final ConfigNodeProcedureEnv env) {
final Map<TConsensusGroupId, TRegionReplicaSet> relatedSchemaRegionGroup =
- env.getConfigManager().getRelatedSchemaRegionGroup(patternTree, mayAlterAudit);
+ env.getConfigManager().getRelatedSchemaRegionGroup(patternTree);
if (relatedSchemaRegionGroup.isEmpty()) {
if (!ifExists) {
@@ -165,7 +167,7 @@ public class AlterEncodingCompressorProcedure
final DataNodeTSStatusTaskExecutor<TAlterEncodingCompressorReq> alterEncodingCompressorTask =
new DataNodeTSStatusTaskExecutor<TAlterEncodingCompressorReq>(
env,
- env.getConfigManager().getRelatedSchemaRegionGroup(patternTree, mayAlterAudit),
+ env.getConfigManager().getRelatedSchemaRegionGroup(patternTree),
false,
CnToDnAsyncRequestType.ALTER_ENCODING_COMPRESSOR,
((dataNodeLocation, consensusGroupIdList) ->
@@ -234,9 +236,9 @@ public class AlterEncodingCompressorProcedure
isGeneratedByPipe
? new PipeEnrichedPlan(
new PipeAlterEncodingCompressorPlan(
- patternTreeBytes, encoding, compressor, mayAlterAudit))
+ patternTreeBytes, encoding, compressor, false))
: new PipeAlterEncodingCompressorPlan(
- patternTreeBytes, encoding, compressor, mayAlterAudit));
+ patternTreeBytes, encoding, compressor, false));
} catch (final ConsensusException e) {
LOGGER.warn(ClusterManager.CONSENSUS_WRITE_ERROR, e);
result = new TSStatus(TSStatusCode.EXECUTE_STATEMENT_ERROR.getStatusCode());
@@ -282,7 +284,7 @@ public class AlterEncodingCompressorProcedure
ReadWriteIOUtils.write(ifExists, stream);
ReadWriteIOUtils.write(encoding, stream);
ReadWriteIOUtils.write(compressor, stream);
- ReadWriteIOUtils.write(mayAlterAudit, stream);
+ ReadWriteIOUtils.write(false, stream);
}
@Override
diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java
index 7a1bc61e30e..39fcdfba376 100644
--- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java
+++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/statement/metadata/AlterEncodingCompressorStatement.java
@@ -49,6 +49,8 @@ public class AlterEncodingCompressorStatement extends Statement implements IConf
private final CompressionType compressor;
private final boolean ifExists;
private final boolean ifPermitted;
+
+ // Reserved for upgrading
private boolean withAudit = false;
public AlterEncodingCompressorStatement(