소스 검색

Update makedata_ad_33_bucketData_20250110: fix append

StrayWarrior 5 달 전
부모
커밋
f31875b2dd
1개의 변경된 파일1개의 추가작업 그리고 1개의 파일을 삭제
  1. 1 1
      src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_33_bucketData_20250110.scala

+ 1 - 1
src/main/scala/com/aliyun/odps/spark/examples/makedata_ad/v20240718/makedata_ad_33_bucketData_20250110.scala

@@ -30,7 +30,7 @@ object makedata_ad_33_bucketData_20250110 {
         val start = i * groupSize
         val end = math.min(start + groupSize, parentPartitions)
         groups(i) = new PartitionGroup()
-        groups(i).partitions += shufflePartitionsArray.slice(start, end)
+        groups(i).partitions.appendAll(shufflePartitionsArray.slice(start, end))
       }
       groups
     }