Liu Bao

## What do these changes do? - [x] Share RayTaskState across tasks. - [x] Remove `create_task_state_actor_as_needed` option. We always lazy create RayTaskState and share the actor across tasks. ## Related...

## What do these changes do? To make the auto merge chunk feature works, Ray context should get meta from meta service if the key does not exist in current...

**Describe the bug** A clear and concise description of what the bug is. ```python Traceback (most recent call last): File "/home/vsts/miniconda/envs/test/lib/python3.9/site-packages/numexpr/necompiler.py", line 820, in evaluate compiled_ex = _numexpr_cache[numexpr_key] KeyError: ('(~((abs((sin((cosh(V_0))))))))',...

**Describe the bug** A clear and concise description of what the bug is. ```python File "/home/admin/mars/mars/core/operand/core.py", line 491, in execute result = executor(results, op) File "/home/admin/mars/mars/dataframe/sort/psrs.py", line 713, in execute...

**Describe the bug** A clear and concise description of what the bug is. ```python mars/deploy/oscar/tests/test_ray_dag.py:189 (test_merge_groupby[before-None]) ray_start_regular_shared2 = RayContext(dashboard_url='', python_version='3.8.13', ray_version='1.13.0', ray_commit='e4ce38d001dbbe09cd21c497fedd03...127.0.0.1:64894', 'address': '127.0.0.1:64894', 'node_id': '987c20539d0bb8031ea7d8ddfc5783c01d5b79d143191bdb072ba21b'}) create_cluster = (, {})...

[BUG] Ray shuffle reduce call iter_mapper_data_with_index returns incorrect values

1

**Describe the bug** A clear and concise description of what the bug is. ```python mars/dataframe/indexing/tests/test_indexing_execution.py:727 (test_reset_index_execution) setup = def test_reset_index_execution(setup): data = pd.DataFrame( [("bird", 389.0), ("bird", 24.0), ("mammal", 80.5), ("mammal",...

**Describe the bug** A clear and concise description of what the bug is.  The Mars job executed hundreds of tasks, some task has a large graph:  Set environ...

**Describe the bug** ```python import numpy as np import mars import mars.tensor as mt from mars.utils import new_random_id mars.new_session() s = np.array([new_random_id(20) for _ in range(10)]) target = s[5] print(target...

[BUG] test_sort_execution.test_sort_values_execution assert fail

1

**Describe the bug** A clear and concise description of what the bug is. pytest `mars.dataframe.sort.tests.test_sort_execution.test_sort_values_execution` ```python FAILED [ 50%] mars/dataframe/sort/tests/test_sort_execution.py:25 (test_sort_values_execution[0]) setup = distinct_opt = '0' @pytest.mark.parametrize( "distinct_opt", ["0"] if...

# The Execution API ## Background Mars provides some interfaces for third party backends, but it is difficult to implement them and can not take the advantages of third party...