Enable distributed ref counting by default (#7628)

* enable

* Turn on eager eviction

* Shorten tests and drain ReferenceCounter

* Don't force kill actor handles that have gone out of scope, lint

* Fix locks

* Cleanup Plasma Async Callback (#7452)

* [rllib][tune] fix some nans (#7611)

* Change /tmp to platform-specific temporary directory (#7529)

* [Serve] UI Improvements (#7569)

* bugfix about test_dynres.py (#7615)

Co-authored-by: senlin.zsl <senlin.zsl@antfin.com>

* Java call Python actor method use actor.call (#7614)

* bug fix about useage of absl::flat_hash_map::erase and absl::flat_hash_set::erase (#7633)

Co-authored-by: senlin.zsl <senlin.zsl@antfin.com>

* [Java] Make both `RayActor` and `RayPyActor` inheriting from `BaseActor` (#7462)

* [Java] Fix the issue that the cached value in `RayObject` is serialized (#7613)

* Add failure tests to test_reference_counting (#7400)

* Fix typo in asyncio documentation (#7602)

* Fix segfault

* debug

* Force kill actor

* Fix test

python/ray/tests/conftest.py

@@ -22,6 +22,8 @@ def get_default_fixure_internal_config():
     internal_config = json.dumps({
         "initial_reconstruction_timeout_milliseconds": 200,
         "num_heartbeats_timeout": 10,
+        "object_store_full_max_retries": 3,
+        "object_store_full_initial_delay_ms": 100,
     })
     return internal_config
 

python/ray/tests/test_global_gc.py

@@ -112,6 +112,7 @@ def test_global_gc_when_full(shutdown_only):
 
         # Remote workers.
         actors = [GarbageHolder.remote() for _ in range(2)]
+        assert all(ray.get([a.has_garbage.remote() for a in actors]))
 
         # GC should be triggered for all workers, including the local driver,
         # when a remote task tries to put a return value that doesn't fit in

python/ray/tests/test_reference_counting.py

@@ -18,16 +18,7 @@ logger = logging.getLogger(__name__)
 
 @pytest.fixture
 def one_worker_100MiB(request):
-    config = json.dumps({
-        "distributed_ref_counting_enabled": 1,
-        "task_retry_delay_ms": 0,
-        "object_store_full_max_retries": 3,
-        "object_store_full_initial_delay_ms": 100,
-    })
-    yield ray.init(
-        num_cpus=1,
-        object_store_memory=100 * 1024 * 1024,
-        _internal_config=config)
+    yield ray.init(num_cpus=1, object_store_memory=100 * 1024 * 1024)
     ray.shutdown()