Hi, @luoyuxia I can help to resolve this bug, can you assign it to me?

Hi, @luoyuxia I can help to resolve this bug, can you assign it to me?

Thanks..
Let's wait for a while to see if there any other commnuity newers are willing to contribute to it since it should be a quick fix and I also post solution in the issue description..

If no any others are willing to take it before v0.6, I'll assign to you to fix it..

Hi, @luoyuxia I can help to resolve this bug, can you assign it to me?

Thanks.. Let's wait for a while to see if there any other commnuity newers are willing to contribute to it since it should be a quick fix and I also post solution in the issue description..

If no any others are willing to take it before v0.6, I'll assign to you to fix it..

Ok, that's great.

I think it can fix by following the code :

        // Iterate over partitioned tables
        partitionAssignments.forEach(
            (tablePartition, assignments) ->
                assignments.forEach(
                    (bucket, replicas) -> {
                        if (replicas.contains(server)) {
                            replicasInServer.add(
                                new TableBucketReplica(
                                    new TableBucket(
                                        tablePartition.getTableId(),
                                        tablePartition.getPartitionId(),
                                        bucket),
                                    server));
                        }
                    }
                )
        );

If you think this is right, please assign this issue to me at any time:)

@psxjoy Thanks.. Assigned to you.. Enjoy coding~