Skip to content
Celeborn CI

[CELEBORN-1912] ReadClientHandler should support reconnection for ChannelInboundHandler#channelInactive #13604

Sign in to view logs

[CELEBORN-1912] ReadClientHandler should support reconnection for ChannelInboundHandler#channelInactive

[CELEBORN-1912] ReadClientHandler should support reconnection for ChannelInboundHandler#channelInactive #13604

Run time

Learn about OS pricing on GitHub Actions
Job Run time
spark2 (8, 2.4)
18m 11s
spark2 (8, 2.4)
39m 5s
spark2 (8, 2.4)
39m 5s
service (8)
4m 2s
service (8)
4m 29s
service (8)
14m 31s
service (11)
4m 17s
service (11)
4m 33s
service (11)
4m 36s
spark3 (8, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 7s
spark3 (8, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
42m 21s
spark3 (8, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
42m 21s
service (17)
4m 14s
service (17)
4m 13s
service (17)
14m 33s
spark3 (8, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 7s
spark3 (8, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
43m 0s
spark3 (8, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
43m 0s
spark3 (8, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 7s
spark3 (8, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
40m 16s
spark3 (8, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
40m 16s
spark3 (8, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 7s
spark3 (8, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
49m 37s
spark3 (8, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
49m 37s
mr (8)
12m 7s
mr (8)
12m 7s
mr (8)
12m 7s
flink (8, 1.16)
10m 42s
flink (8, 1.16)
10m 42s
flink (8, 1.16)
10m 42s
spark3 (8, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 12s
spark3 (8, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
47m 13s
spark3 (8, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
47m 13s
mr (11)
12m 40s
mr (11)
12m 40s
mr (11)
12m 40s
flink (8, 1.17)
11m 23s
flink (8, 1.17)
11m 23s
flink (8, 1.17)
11m 23s
spark3 (8, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 7s
spark3 (8, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
46m 29s
spark3 (8, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
46m 29s
flink (8, 1.18)
10m 28s
flink (8, 1.18)
10m 28s
flink (8, 1.18)
10m 28s
spark3 (8, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
18m 6s
spark3 (8, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
49m 56s
spark3 (8, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
49m 56s
flink (8, 1.19)
10m 33s
flink (8, 1.19)
10m 33s
flink (8, 1.19)
10m 33s
spark3 (11, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 10s
spark3 (11, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
42m 23s
spark3 (11, 3.0, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
42m 23s
spark3 (11, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 10s
spark3 (11, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 14s
spark3 (11, 3.1, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 14s
spark3 (11, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 10s
spark3 (11, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
39m 34s
spark3 (11, 3.2, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
39m 34s
flink (8, 1.20)
11m 12s
flink (8, 1.20)
11m 12s
flink (8, 1.20)
11m 12s
spark3 (11, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 8s
spark3 (11, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 36s
spark3 (11, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 36s
flink (11, 1.16)
10m 13s
flink (11, 1.16)
10m 13s
flink (11, 1.16)
10m 13s
spark3 (11, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 9s
spark3 (11, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 44s
spark3 (11, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 44s
flink (11, 1.17)
11m 17s
flink (11, 1.17)
11m 17s
flink (11, 1.17)
11m 17s
spark3 (11, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 9s
spark3 (11, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 55s
spark3 (11, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 55s
flink (11, 1.18)
10m 30s
flink (11, 1.18)
10m 30s
flink (11, 1.18)
10m 30s
spark3 (11, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
18m 9s
spark3 (11, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
41m 45s
spark3 (11, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
41m 45s
flink (11, 1.19)
11m 31s
flink (11, 1.19)
11m 31s
flink (11, 1.19)
11m 31s
spark3 (17, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 9s
spark3 (17, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 18s
spark3 (17, 3.3, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 18s
flink (11, 1.20)
11m 21s
flink (11, 1.20)
11m 44s
flink (11, 1.20)
11m 44s
spark3 (17, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 8s
spark3 (17, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 0s
spark3 (17, 3.4, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
41m 0s
spark3 (17, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
18m 7s
spark3 (17, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
40m 37s
spark3 (17, 3.5, org.apache.spark.shuffle.sort.io.LocalDiskShuffleDataIO)
40m 37s
spark3 (17, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
18m 7s
spark3 (17, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
41m 26s
spark3 (17, 3.5, org.apache.spark.shuffle.celeborn.CelebornShuffleDataIO)
41m 26s
1d 16h 31m 43s