Skip to content
Back to pull request #2905

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

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 #6076

Run time

Learn about OS pricing on GitHub Actions
Job Run time
flink (8, 1.14)
5m 14s
openapi-codegen-check (11)
49s
mr (8)
8m 17s
flink (8, 1.15)
5m 18s
service (8, 2.12.15)
17m 16s
mr (11)
8m 21s
flink (8, 1.16)
5m 10s
service (8, 2.13.5)
17m 13s
spark2 (8, 2.4, 2.11.12)
27m 33s
flink (8, 1.17)
5m 23s
service (11, 2.12.15)
17m 44s
flink (8, 1.18)
5m 9s
spark2 (8, 2.4, 2.12.10)
27m 35s
service (11, 2.13.5)
17m 48s
service (17, 2.12.15)
17m 37s
flink (8, 1.19)
5m 13s
spark3 (3.0, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
31m 1s
service (17, 2.13.5)
17m 31s
flink (8, 1.20)
5m 49s
spark3 (3.0, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 35s
flink (11, 1.14)
5m 14s
spark3 (3.1, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 46s
flink (11, 1.15)
5m 18s
spark3 (3.1, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
31m 4s
flink (11, 1.16)
5m 27s
spark3 (3.2, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
29m 32s
flink (11, 1.17)
5m 15s
spark3 (3.2, 8, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
29m 4s
flink (11, 1.18)
5m 33s
spark3 (3.2, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
28m 46s
flink (11, 1.19)
5m 31s
spark3 (3.2, 11, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
28m 46s
flink (11, 1.20)
5m 48s
spark3 (3.3, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
38m 57s
spark3 (3.3, 8, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
38m 25s
spark3 (3.3, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 59s
spark3 (3.3, 11, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 37s
spark3 (3.3, 17, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 4s
spark3 (3.3, 17, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 7s
spark3 (3.4, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
39m 38s
spark3 (3.4, 8, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
39m 21s
spark3 (3.4, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 47s
spark3 (3.4, 11, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 41s
spark3 (3.4, 17, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 18s
spark3 (3.4, 17, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 22s
spark3 (3.5, 8, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
38m 39s
spark3 (3.5, 8, 2.12, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
37m 25s
spark3 (3.5, 8, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
38m 39s
spark3 (3.5, 8, 2.13, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
33m 24s
spark3 (3.5, 11, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 32s
spark3 (3.5, 11, 2.12, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
30m 28s
spark3 (3.5, 11, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 41s
spark3 (3.5, 11, 2.13, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
31m 8s
spark3 (3.5, 17, 2.12, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 2s
spark3 (3.5, 17, 2.12, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
29m 55s
spark3 (3.5, 17, 2.13, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
30m 52s
spark3 (3.5, 17, 2.13, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
30m 24s
21h 25m 5s