This is an automated email from the ASF dual-hosted git repository. jackietien pushed a commit to branch force_ci/object_type in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit ba7a7a6fc1bc38535249c63b55225a3270f62fc5 Author: Caideyipi <[email protected]> AuthorDate: Mon Nov 10 09:43:01 2025 +0800 Follow fix for encoding & compressor (#16712) * fix * fix (cherry picked from commit 3ec8979e42aaa3bae6505e7bbf0d24dc406b4904) --- .../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; }
