Skip to content
Celeborn SBT CI

[CELEBORN-2315] Add iterator fully-consumed validation after shuffle write #10124

Sign in to view logs

[CELEBORN-2315] Add iterator fully-consumed validation after shuffle write

[CELEBORN-2315] Add iterator fully-consumed validation after shuffle write #10124

Run time

Learn about OS pricing on GitHub Actions
Job Run time
flink2 (17, 2.2)
7m 8s
flink2 (11, 2.1)
7m 5s
service (8, 2.13.5)
24m 23s
flink2 (17, 2.1)
6m 53s
spark2 (8, 2.4, 2.12.10)
2m 16s
service (11, 2.13.5)
24m 52s
flink2 (11, 2.0)
6m 56s
spark4 (4.1, 17, 2.13, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
2m 35s
mr (11)
8m 42s
mr (8)
8m 15s
service (11, 2.12.15)
24m 29s
flink2 (17, 2.0)
6m 58s
openapi-codegen-check (11)
55s
flink2 (11, 2.2)
7m 40s
service (8, 2.12.15)
24m 42s
spark2 (8, 2.4, 2.11.12)
2m 20s
flink1 (11, 1.17)
6m 23s
flink1 (8, 1.16)
6m 21s
flink1 (11, 1.19)
6m 49s
flink1 (8, 1.19)
6m 36s
flink1 (8, 1.18)
6m 26s
flink1 (8, 1.20)
7m 12s
spark4 (4.0, 17, 2.13, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
2m 22s
flink1 (11, 1.20)
7m 24s
flink1 (11, 1.16)
6m 17s
flink1 (8, 1.17)
6m 15s
service (17, 2.12.15)
24m 58s
service (17, 2.13.5)
24m 26s
flink1 (11, 1.18)
6m 45s
spark3 (3.5, 8, 2.13, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
2m 7s
spark3 (3.4, 17, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 34s
spark3 (3.4, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 5s
spark3 (3.1, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 6s
spark3 (3.5, 8, 2.12, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
1m 43s
spark3 (3.0, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 21s
spark3 (3.4, 17, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 28s
spark3 (3.5, 11, 2.12, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
2m 16s
spark3 (3.2, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 31s
spark3 (3.5, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 14s
spark3 (3.5, 8, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 3s
spark3 (3.5, 11, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 19s
spark3 (3.5, 17, 2.12, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
2m 20s
spark3 (3.3, 17, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 25s
spark3 (3.5, 11, 2.13, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
2m 14s
spark3 (3.1, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 23s
spark3 (3.3, 11, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 35s
spark3 (3.5, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 21s
spark3 (3.2, 8, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
1m 57s
spark3 (3.2, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 15s
spark3 (3.2, 11, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 9s
spark3 (3.4, 11, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 9s
spark3 (3.3, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 18s
spark3 (3.4, 8, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
1m 59s
spark3 (3.5, 17, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
1m 59s
spark3 (3.4, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 12s
spark3 (3.3, 17, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 20s
spark3 (3.3, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 20s
spark3 (3.3, 8, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 15s
spark3 (3.0, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 18s
spark3 (3.5, 17, 2.13, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
2m 24s
spark3 (3.5, 17, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
2m 15s
5h 56m 18s