@@ -580,20 +580,23 @@ abstract class GlutenClickHouseTPCHAbstractSuite
580
580
}
581
581
582
582
override protected def afterAll (): Unit = {
583
- // guava cache invalidate event trigger remove operation may in seconds delay, so wait a bit
584
- // normally this doesn't take more than 1s
585
- eventually(timeout(60 .seconds), interval(1 .seconds)) {
586
- // Spark listener message was not sent in time with ci env.
587
- // In tpch case, there are more then 10 hbj data has build.
588
- // Let's just verify it was cleaned ever.
589
- assert(CHBroadcastBuildSideCache .size() <= 10 )
590
- }
583
+ try {
584
+ // guava cache invalidate event trigger remove operation may in seconds delay, so wait a bit
585
+ // normally this doesn't take more than 1s
586
+ eventually(timeout(60 .seconds), interval(1 .seconds)) {
587
+ // Spark listener message was not sent in time with ci env.
588
+ // In tpch case, there are more then 10 hbj data has build.
589
+ // Let's just verify it was cleaned ever.
590
+ assert(CHBroadcastBuildSideCache .size() <= 10 )
591
+ }
591
592
592
- ClickhouseSnapshot .clearAllFileStatusCache()
593
- DeltaLog .clearCache()
594
- super .afterAll()
595
- // init GlutenConfig in the next beforeAll
596
- GlutenConfig .ins = null
593
+ ClickhouseSnapshot .clearAllFileStatusCache()
594
+ DeltaLog .clearCache()
595
+ // init GlutenConfig in the next beforeAll
596
+ GlutenConfig .ins = null
597
+ } finally {
598
+ super .afterAll()
599
+ }
597
600
}
598
601
599
602
override protected def runTPCHQuery (
0 commit comments