diff --git a/java/runtime/src/main/java/io/ray/runtime/object/LocalModeObjectStore.java b/java/runtime/src/main/java/io/ray/runtime/object/LocalModeObjectStore.java index 4614100ae..fed5459b4 100644 --- a/java/runtime/src/main/java/io/ray/runtime/object/LocalModeObjectStore.java +++ b/java/runtime/src/main/java/io/ray/runtime/object/LocalModeObjectStore.java @@ -21,7 +21,7 @@ public class LocalModeObjectStore extends ObjectStore { private static final Logger LOGGER = LoggerFactory.getLogger(LocalModeObjectStore.class); - private static final int GET_CHECK_INTERVAL_MS = 100; + private static final int GET_CHECK_INTERVAL_MS = 1; private final Map pool = new ConcurrentHashMap<>(); private final List> objectPutCallbacks = new ArrayList<>();