distributed.protocol.core - CRITICAL - Failed to deserialize
Traceback (most recent call last):
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/protocol/core.py", line 130, in loads
    value = merge_and_deserialize(head, fs, deserializers=deserializers)
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/protocol/serialize.py", line 450, in merge_and_deserialize
    return deserialize(header, merged_frames, deserializers=deserializers)
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/protocol/serialize.py", line 384, in deserialize
    return loads(header, frames)
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/protocol/serialize.py", line 79, in pickle_loads
    buffers[i] = memoryview(bytes(mv)).cast(mv.format, mv.shape)
TypeError: memoryview: cannot cast view with zeros in shape or strides
distributed.core - ERROR - memoryview: cannot cast view with zeros in shape or strides
Traceback (most recent call last):
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/core.py", line 554, in handle_stream
    msgs = await comm.read()
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/comm/tcp.py", line 217, in read
    msg = await from_frames(
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/comm/utils.py", line 80, in from_frames
    res = _from_frames()
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/comm/utils.py", line 63, in _from_frames
    return protocol.loads(
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/protocol/core.py", line 130, in loads
    value = merge_and_deserialize(head, fs, deserializers=deserializers)
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/protocol/serialize.py", line 450, in merge_and_deserialize
    return deserialize(header, merged_frames, deserializers=deserializers)
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/protocol/serialize.py", line 384, in deserialize
    return loads(header, frames)
  File "/home/sandeshmore/PycharmProjects/dask_latest/dask_03/lib/python3.8/site-packages/distributed/protocol/serialize.py", line 79, in pickle_loads
    buffers[i] = memoryview(bytes(mv)).cast(mv.format, mv.shape)
TypeError: memoryview: cannot cast view with zeros in shape or strides
distributed.worker - ERROR - memoryview: cannot cast view with zeros in shape or strides

import dask.dataframe as dd
import pandas as pd

if __name__ == '__main__':
    from dask.distributed import LocalCluster, Client

    cluster = LocalCluster(n_workers=4)
    client = Client(cluster)

    newer_items_df = dd.from_pandas(pd.DataFrame([
        {'A': '1', 'B': '1', 'C': 1, 'D': 'A3'},
        {'A': '1',  'B': '1', 'C': 2, 'D': 'A4'},
        {'A': '123',  'B': '123', 'C': 3, 'D': 'A5'},
        {'A': '123', 'B': '123', 'C': 3, 'D': 'A6'},
        {'A': '123', 'B': '123', 'C': 4, 'D': 'A7'},
        {'A': '123', 'B': '123', 'C': 5, 'D': 'A8'},
           ]), npartitions=5)
    ##This works in release 2021.1.1 and not in 2021.3.0
    Interclusdistance1 = newer_items_df.groupby(['A', 'B'])[['C']].max().rename(
        columns={'C': 'InterClus_distance'}).reset_index()

    # ##This works in release 2021.3.0
    # Interclusdistance2 = newer_items_df.groupby(['A', 'B'])[['C']].max().reset_index().rename(
    #     columns={'C': 'InterClus_distance'})

    print(Interclusdistance1.compute())     ## This fails
    # print(Interclusdistance2.compute())  ##This works in newer release 2021.3.0