diff --git a/redisson/src/main/java/org/redisson/command/CommandBatchService.java b/redisson/src/main/java/org/redisson/command/CommandBatchService.java
index 539b0f6b2..a7ceda3d9 100644
--- a/redisson/src/main/java/org/redisson/command/CommandBatchService.java
+++ b/redisson/src/main/java/org/redisson/command/CommandBatchService.java
@@ -133,7 +133,7 @@ public class CommandBatchService extends CommandAsyncService {
     private final AtomicBoolean executed = new AtomicBoolean();
 
     private final long retryInterval;
-    private final long retryAttempts;
+    private final int retryAttempts;
 
     public CommandBatchService(CommandAsyncExecutor executor) {
         this(executor, RedissonObjectBuilder.ReferenceType.DEFAULT);
@@ -406,8 +406,8 @@ public class CommandBatchService extends CommandAsyncService {
                             .executionMode(this.options.getExecutionMode())
                             .syncSlaves(this.options.getSyncSlaves(), this.options.getSyncTimeout(), TimeUnit.MILLISECONDS)
                             .responseTimeout(this.options.getResponseTimeout(), TimeUnit.MILLISECONDS)
-                            .retryAttempts(Math.max(0, this.options.getRetryAttempts() - attempt.get()))
-                            .retryInterval(this.options.getRetryInterval(), TimeUnit.MILLISECONDS);
+                            .retryAttempts(Math.max(0, retryAttempts - attempt.get()))
+                            .retryInterval(retryInterval, TimeUnit.MILLISECONDS);
 
                     if (this.options.isSkipResult()) {
                         options.skipResult();