This is an automated email from the ASF dual-hosted git repository.
lijibing pushed a commit to branch branch-2.0
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/branch-2.0 by this push:
new 40a14446559 Fix load stats cache FE ut case. (#31166)
40a14446559 is described below
commit 40a14446559c52a57dfc53b3eac739b09f32b9d5
Author: Jibing-Li <64681310+jibing...@users.noreply.github.com>
AuthorDate: Tue Feb 20 21:54:08 2024 +0800
Fix load stats cache FE ut case. (#31166)
---
.../org/apache/doris/statistics/CacheTest.java | 28 +++++++++++++++-------
1 file changed, 19 insertions(+), 9 deletions(-)
diff --git
a/fe/fe-core/src/test/java/org/apache/doris/statistics/CacheTest.java
b/fe/fe-core/src/test/java/org/apache/doris/statistics/CacheTest.java
index ef5428e342c..e3a14ecfc5f 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/statistics/CacheTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/statistics/CacheTest.java
@@ -272,15 +272,25 @@ public class CacheTest extends TestWithFeService {
try {
StatisticsCache statisticsCache = new StatisticsCache();
ColumnStatistic columnStatistic =
statisticsCache.getColumnStatistics(1, 1, 1, -1, "col");
- Thread.sleep(3000);
- columnStatistic = statisticsCache.getColumnStatistics(1, 1, 1, -1,
"col");
- Assertions.assertEquals(1, columnStatistic.count);
- Assertions.assertEquals(2, columnStatistic.ndv);
- Assertions.assertEquals(3, columnStatistic.avgSizeByte);
- Assertions.assertEquals(4, columnStatistic.numNulls);
- Assertions.assertEquals(5, columnStatistic.dataSize);
- Assertions.assertEquals(6, columnStatistic.minValue);
- Assertions.assertEquals(7, columnStatistic.maxValue);
+ for (int i = 0; i < 15; i++) {
+ columnStatistic = statisticsCache.getColumnStatistics(1, 1, 1,
-1, "col");
+ if (columnStatistic != ColumnStatistic.UNKNOWN) {
+ break;
+ }
+ System.out.println("Not ready yet.");
+ Thread.sleep(1000);
+ }
+ if (columnStatistic != ColumnStatistic.UNKNOWN) {
+ Assertions.assertEquals(1, columnStatistic.count);
+ Assertions.assertEquals(2, columnStatistic.ndv);
+ Assertions.assertEquals(3, columnStatistic.avgSizeByte);
+ Assertions.assertEquals(4, columnStatistic.numNulls);
+ Assertions.assertEquals(5, columnStatistic.dataSize);
+ Assertions.assertEquals(6, columnStatistic.minValue);
+ Assertions.assertEquals(7, columnStatistic.maxValue);
+ } else {
+ System.out.println("Cached is not loaded, skip test.");
+ }
} catch (Throwable t) {
t.printStackTrace();
}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@doris.apache.org
For additional commands, e-mail: commits-h...@doris.apache.org
