(seatunnel) branch dev updated: [Improve][Zeta] Remove unused fields (#10261)

[shenghang]

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

shenghang pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 6d6a5d261c [Improve][Zeta] Remove unused fields (#10261)
6d6a5d261c is described below

commit 6d6a5d261ca2d077eb41357bb97f749b06a8ac26
Author: dy102 <132787602+dyb...@users.noreply.github.com>
AuthorDate: Sat Jan 3 20:59:27 2026 +0900

    [Improve][Zeta] Remove unused fields (#10261)
---
 .../engine/server/checkpoint/IMapCheckpointIDCounter.java      | 10 ++--------
 1 file changed, 2 insertions(+), 8 deletions(-)

diff --git 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/IMapCheckpointIDCounter.java
 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/IMapCheckpointIDCounter.java
index ad00f9834a..438a675d90 100644
--- 
a/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/IMapCheckpointIDCounter.java
+++ 
b/seatunnel-engine/seatunnel-engine-server/src/main/java/org/apache/seatunnel/engine/server/checkpoint/IMapCheckpointIDCounter.java
@@ -35,14 +35,10 @@ import static 
org.apache.seatunnel.shade.com.google.common.base.Preconditions.ch
 
 public class IMapCheckpointIDCounter implements CheckpointIDCounter {
 
-    private final Long jobID;
-    private final Integer pipelineId;
     private final String key;
     private final IMap<String, Long> checkpointIdMap;
 
     public IMapCheckpointIDCounter(Long jobID, Integer pipelineId, NodeEngine 
nodeEngine) {
-        this.jobID = jobID;
-        this.pipelineId = pipelineId;
         this.key = convertLongIntToBase64(jobID, pipelineId);
         this.checkpointIdMap = 
nodeEngine.getHazelcastInstance().getMap(IMAP_CHECKPOINT_ID);
     }
@@ -50,13 +46,11 @@ public class IMapCheckpointIDCounter implements 
CheckpointIDCounter {
     @Override
     public void start() throws Exception {
         RetryUtils.retryWithException(
-                () -> {
-                    return checkpointIdMap.putIfAbsent(key, 
INITIAL_CHECKPOINT_ID);
-                },
+                () -> checkpointIdMap.putIfAbsent(key, INITIAL_CHECKPOINT_ID),
                 new RetryUtils.RetryMaterial(
                         Constant.OPERATION_RETRY_TIME,
                         true,
-                        exception -> 
ExceptionUtil.isOperationNeedRetryException(exception),
+                        ExceptionUtil::isOperationNeedRetryException,
                         Constant.OPERATION_RETRY_SLEEP));
     }