Skip to content
Celeborn CI

[CELEBORN-XXX] Optimize performance of handling MapperEnd RPC in LifecycleManager #12327

Sign in to view logs

[CELEBORN-XXX] Optimize performance of handling MapperEnd RPC in LifecycleManager

[CELEBORN-XXX] Optimize performance of handling MapperEnd RPC in LifecycleManager #12327

Run time

Learn about OS pricing on GitHub Actions
Job Run time
flink (8, 1.14)
9m 48s
flink (8, 1.14)
9m 48s
mr (8)
12m 4s
mr (8)
12m 4s
flink (8, 1.15)
10m 13s
flink (8, 1.15)
10m 13s
mr (11)
13m 12s
mr (11)
13m 12s
flink (8, 1.16)
9m 50s
flink (8, 1.16)
9m 50s
flink (8, 1.17)
9m 51s
flink (8, 1.17)
9m 51s
service (8)
12m 36s
service (8)
12m 36s
flink (8, 1.18)
10m 41s
flink (8, 1.18)
10m 41s
service (11)
12m 1s
service (11)
12m 1s
flink (8, 1.19)
11m 7s
flink (8, 1.19)
11m 7s
service (17)
11m 59s
service (17)
11m 59s
flink (8, 1.20)
10m 49s
flink (8, 1.20)
10m 49s
spark2 (8, 2.4)
33m 51s
spark2 (8, 2.4)
33m 51s
flink (11, 1.14)
10m 47s
flink (11, 1.14)
10m 47s
flink (11, 1.15)
9m 57s
flink (11, 1.15)
9m 57s
spark3 (8, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
36m 54s
spark3 (8, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
36m 54s
flink (11, 1.16)
10m 12s
flink (11, 1.16)
10m 12s
spark3 (8, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 55s
spark3 (8, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 55s
flink (11, 1.17)
10m 25s
flink (11, 1.17)
10m 25s
spark3 (8, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 7s
spark3 (8, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 7s
flink (11, 1.18)
10m 48s
flink (11, 1.18)
10m 48s
spark3 (8, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
43m 44s
spark3 (8, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
43m 44s
flink (11, 1.19)
10m 14s
flink (11, 1.19)
10m 14s
spark3 (8, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
39m 20s
spark3 (8, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
45m 1s
flink (11, 1.20)
10m 45s
flink (11, 1.20)
10m 45s
spark3 (8, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
42m 33s
spark3 (8, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
42m 33s
spark3 (8, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
42m 16s
spark3 (8, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
42m 16s
spark3 (11, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
37m 0s
spark3 (11, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
37m 0s
spark3 (11, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 44s
spark3 (11, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 44s
spark3 (11, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
33m 44s
spark3 (11, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
33m 44s
spark3 (11, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 28s
spark3 (11, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 28s
spark3 (11, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 36s
spark3 (11, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 36s
spark3 (11, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 30s
spark3 (11, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 30s
spark3 (11, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
35m 33s
spark3 (11, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
35m 33s
spark3 (17, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 20s
spark3 (17, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 20s
spark3 (17, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 24s
spark3 (17, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 24s
spark3 (17, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 8s
spark3 (17, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
35m 8s
spark3 (17, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
34m 43s
spark3 (17, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
34m 43s
1d 6h 17m 59s