Skip to content
Back to pull request #3055

[CELEBORN-1824] FlinkShuffleClientImpl should close TransportClient of currentClient #13133

Sign in to view logs

[CELEBORN-1824] FlinkShuffleClientImpl should close TransportClient of currentClient

[CELEBORN-1824] FlinkShuffleClientImpl should close TransportClient of currentClient #13133

Run time

Learn about OS pricing on GitHub Actions
Job Run time
service (8)
13m 41s
service (8)
13m 41s
service (11)
13m 19s
service (11)
13m 19s
spark2 (8, 2.4)
16m 6s
spark2 (8, 2.4)
35m 43s
service (17)
13m 48s
service (17)
13m 48s
spark3 (8, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 4s
spark3 (8, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
38m 9s
spark3 (8, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 2s
spark3 (8, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
38m 42s
spark3 (8, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 3s
spark3 (8, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
36m 48s
spark3 (8, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 4s
spark3 (8, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 9s
flink (8, 1.16)
10m 14s
flink (8, 1.16)
10m 14s
mr (8)
11m 40s
mr (8)
11m 40s
spark3 (8, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 4s
spark3 (8, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
43m 35s
flink (8, 1.17)
10m 7s
flink (8, 1.17)
10m 7s
mr (11)
12m 21s
mr (11)
12m 21s
spark3 (8, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 3s
spark3 (8, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
46m 30s
flink (8, 1.18)
10m 27s
flink (8, 1.18)
10m 27s
spark3 (8, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
16m 6s
spark3 (8, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
43m 3s
flink (8, 1.19)
11m 1s
flink (8, 1.19)
11m 1s
spark3 (11, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 5s
spark3 (11, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
37m 47s
flink (8, 1.20)
16m 9s
flink (8, 1.20)
30m 43s
spark3 (11, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 5s
spark3 (11, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
38m 5s
flink (11, 1.16)
10m 23s
flink (11, 1.16)
6m 52s
spark3 (11, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 6s
spark3 (11, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
36m 12s
flink (11, 1.17)
11m 20s
flink (11, 1.17)
11m 20s
flink (11, 1.18)
10m 42s
flink (11, 1.18)
10m 42s
spark3 (11, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 5s
spark3 (11, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
38m 14s
flink (11, 1.19)
10m 25s
flink (11, 1.19)
10m 25s
spark3 (11, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 5s
spark3 (11, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
37m 48s
flink (11, 1.20)
16m 9s
flink (11, 1.20)
30m 58s
spark3 (11, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 5s
spark3 (11, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
38m 0s
spark3 (11, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
16m 3s
spark3 (11, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
37m 57s
spark3 (17, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 4s
spark3 (17, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
37m 53s
spark3 (17, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 3s
spark3 (17, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
37m 41s
spark3 (17, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
16m 5s
spark3 (17, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
37m 44s
spark3 (17, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
16m 4s
spark3 (17, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
37m 41s
23h 53m 27s