This is an automated email from the ASF dual-hosted git repository. zhangliang pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push: new 8440a5a9505 Remove useless setter of CDCAckPosition.lastRecord (#35070) 8440a5a9505 is described below commit 8440a5a950588c63d5a67d0ea47fea1974448632 Author: Liang Zhang <zhangli...@apache.org> AuthorDate: Mon Mar 24 18:37:57 2025 +0800 Remove useless setter of CDCAckPosition.lastRecord (#35070) --- .../shardingsphere/data/pipeline/cdc/core/ack/CDCAckPosition.java | 8 +++----- 1 file changed, 3 insertions(+), 5 deletions(-) diff --git a/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/ack/CDCAckPosition.java b/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/ack/CDCAckPosition.java index 9179649d8b4..5bd124c8ba5 100644 --- a/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/ack/CDCAckPosition.java +++ b/kernel/data-pipeline/scenario/cdc/core/src/main/java/org/apache/shardingsphere/data/pipeline/cdc/core/ack/CDCAckPosition.java @@ -18,7 +18,6 @@ package org.apache.shardingsphere.data.pipeline.cdc.core.ack; import lombok.Getter; -import lombok.Setter; import org.apache.shardingsphere.data.pipeline.core.ingest.record.Record; import java.util.concurrent.atomic.AtomicInteger; @@ -28,11 +27,10 @@ import java.util.concurrent.atomic.AtomicInteger; */ public final class CDCAckPosition { - private final AtomicInteger dataRecordCount = new AtomicInteger(); - @Getter - @Setter - private Record lastRecord; + private final Record lastRecord; + + private final AtomicInteger dataRecordCount = new AtomicInteger(); public CDCAckPosition(final Record lastRecord, final int dataRecordCount) { this.lastRecord = lastRecord;