diff --git a/client/src/main/java/io/streamnative/oxia/client/notify/ShardNotificationReceiver.java b/client/src/main/java/io/streamnative/oxia/client/notify/ShardNotificationReceiver.java index 845ff5af..364ecc64 100644 --- a/client/src/main/java/io/streamnative/oxia/client/notify/ShardNotificationReceiver.java +++ b/client/src/main/java/io/streamnative/oxia/client/notify/ShardNotificationReceiver.java @@ -55,7 +55,6 @@ public class ShardNotificationReceiver extends GrpcResponseStream { private final @NonNull NotificationMetrics metrics; private @NonNull Optional startingOffset = Optional.empty(); - private Scheduler scheduler; private long offset;