(iotdb) branch master updated: Follow fix for encoding & compressor (#16712)

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jiangtian 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 3ec8979e42a Follow fix for encoding & compressor (#16712)
3ec8979e42a is described below

commit 3ec8979e42aaa3bae6505e7bbf0d24dc406b4904
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Mon Nov 10 09:43:01 2025 +0800

    Follow fix for encoding & compressor (#16712)
    
    * fix
    
    * fix
---
 .../pipe/payload/PipeAlterEncodingCompressorPlan.java | 19 ++++++++++++++++++-
 .../impl/schema/AlterEncodingCompressorProcedure.java |  7 +++++--
 2 files changed, 23 insertions(+), 3 deletions(-)

diff --git 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeAlterEncodingCompressorPlan.java
 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeAlterEncodingCompressorPlan.java
index bd31a7c57b2..08ec62be80c 100644
--- 
a/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeAlterEncodingCompressorPlan.java
+++ 
b/iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/consensus/request/write/pipe/payload/PipeAlterEncodingCompressorPlan.java
@@ -85,6 +85,7 @@ public class PipeAlterEncodingCompressorPlan extends 
ConfigPhysicalPlan {
     ReadWriteIOUtils.write(patternTreeBytes, stream);
     ReadWriteIOUtils.write(encoding, stream);
     ReadWriteIOUtils.write(compressor, stream);
+    ReadWriteIOUtils.write(mayAlterAudit, stream);
   }
 
   @Override
@@ -92,11 +93,27 @@ public class PipeAlterEncodingCompressorPlan extends 
ConfigPhysicalPlan {
     patternTreeBytes = 
ByteBuffer.wrap(ReadWriteIOUtils.readBinary(buffer).getValues());
     encoding = ReadWriteIOUtils.readByte(buffer);
     compressor = ReadWriteIOUtils.readByte(buffer);
+    mayAlterAudit = ReadWriteIOUtils.readBoolean(buffer);
+  }
+
+  @Override
+  public boolean equals(final Object o) {
+    if (this == o) {
+      return true;
+    }
+    if (o == null || getClass() != o.getClass()) {
+      return false;
+    }
+    final PipeAlterEncodingCompressorPlan that = 
(PipeAlterEncodingCompressorPlan) o;
+    return this.patternTreeBytes.equals(that.patternTreeBytes)
+        && this.encoding == that.encoding
+        && this.compressor == that.compressor
+        && this.mayAlterAudit == that.mayAlterAudit;
   }
 
   @Override
   public int hashCode() {
-    return Objects.hash(patternTreeBytes, encoding, compressor);
+    return Objects.hash(patternTreeBytes, encoding, compressor, mayAlterAudit);
   }
 
   @Override
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..627547ce722 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
@@ -63,7 +63,8 @@ import static 
org.apache.iotdb.confignode.procedure.impl.schema.DeleteTimeSeries
 
 public class AlterEncodingCompressorProcedure
     extends StateMachineProcedure<ConfigNodeProcedureEnv, 
AlterEncodingCompressorState> {
-  private static final Logger LOGGER = 
LoggerFactory.getLogger(AlterEncodingCompressorState.class);
+  private static final Logger LOGGER =
+      LoggerFactory.getLogger(AlterEncodingCompressorProcedure.class);
   private String queryId;
   private PathPatternTree patternTree;
   private boolean ifExists;
@@ -298,7 +299,9 @@ public class AlterEncodingCompressorProcedure
 
   @Override
   public boolean equals(final Object o) {
-    if (this == o) return true;
+    if (this == o) {
+      return true;
+    }
     if (o == null || getClass() != o.getClass()) {
       return false;
     }