diff --git a/weed/shell/command_ec_decode.go b/weed/shell/command_ec_decode.go
index 4ec1a7e8f..b49ab2c58 100644
--- a/weed/shell/command_ec_decode.go
+++ b/weed/shell/command_ec_decode.go
@@ -149,8 +149,9 @@ func collectEcShards(ctx context.Context, commandEnv *CommandEnv, nodeToEcIndexB
 	maxShardCount := 0
 	var exisitngEcIndexBits erasure_coding.ShardBits
 	for loc, ecIndexBits := range nodeToEcIndexBits {
-		if ecIndexBits.ShardIdCount() > maxShardCount {
-			maxShardCount = ecIndexBits.ShardIdCount()
+		toBeCopiedShardCount := ecIndexBits.MinusParityShards().ShardIdCount()
+		if toBeCopiedShardCount > maxShardCount {
+			maxShardCount = toBeCopiedShardCount
 			targetNodeLocation = loc
 			exisitngEcIndexBits = ecIndexBits
 		}