ray

Search before asking

• I had searched in the issues and found no similar feature requirement.

Description

Currently users sees

(pid=3979) 2021-10-06 10:37:25,982	WARNING backend_state.py:996 -- Backend 'AAA' has 1 replicas that have taken more than 30s to start up. This may be caused by waiting for the cluster to auto-scale or beca

Describe the bug

Failed to execute Series.drop_duplicates.

In [75]: a = md.DataFrame(np.random.rand(10, 2), columns=['a', 'b'], chunk_size=2)                  

In [76]: a['a'].drop_duplicates().execute()               

Overview

As a CFP user, I would like to split a dataset (e.g., np array, pandas dataframe) into smaller objects that can then be fed into other nodes/pipeline. This is especially useful when we have compute intensive tasks and would like to parallelize it eas

Search before asking

• I had searched in the issues and found no similar feature requirement.

Description

We may not always remember to do this work which results in inconsistent formatting issue.
Let's create the standard to help us maintain the code here.

• gofmt
• goimports
• golangci-lint

curl -sSfL https: