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 <[email protected]> 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(
