This is an automated email from the ASF dual-hosted git repository.
morrysnow 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 556dd8a23cf [fix](statistics) Fix show auto analyze missing jobs bug
(#27761)
556dd8a23cf is described below
commit 556dd8a23cf94b10890244906b0402a2674e7602
Author: Jibing-Li <[email protected]>
AuthorDate: Wed Nov 29 19:35:22 2023 +0800
[fix](statistics) Fix show auto analyze missing jobs bug (#27761)
---
.../java/org/apache/doris/statistics/AnalysisManager.java | 2 +-
.../org/apache/doris/statistics/AnalysisManagerTest.java | 13 +++++++++++++
2 files changed, 14 insertions(+), 1 deletion(-)
diff --git
a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java
b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java
index 61c72926f2d..cd633792354 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/statistics/AnalysisManager.java
@@ -1058,7 +1058,7 @@ public class AnalysisManager implements Writable {
a -> {
// DO NOTHING
return null;
- }, null);
+ }, collection);
}
// Remove col stats status from TableStats if failed load some col stats
after analyze corresponding column so that
diff --git
a/fe/fe-core/src/test/java/org/apache/doris/statistics/AnalysisManagerTest.java
b/fe/fe-core/src/test/java/org/apache/doris/statistics/AnalysisManagerTest.java
index afce13df7a3..72754943404 100644
---
a/fe/fe-core/src/test/java/org/apache/doris/statistics/AnalysisManagerTest.java
+++
b/fe/fe-core/src/test/java/org/apache/doris/statistics/AnalysisManagerTest.java
@@ -29,6 +29,7 @@ import org.apache.doris.common.DdlException;
import org.apache.doris.statistics.AnalysisInfo.AnalysisType;
import org.apache.doris.statistics.AnalysisInfo.JobType;
import org.apache.doris.statistics.AnalysisInfo.ScheduleType;
+import org.apache.doris.statistics.util.SimpleQueue;
import org.apache.doris.statistics.util.StatisticsUtil;
import com.google.common.annotations.VisibleForTesting;
@@ -445,4 +446,16 @@ public class AnalysisManagerTest {
Assertions.assertEquals(2, analysisManager.autoJobs.size());
}
+ @Test
+ public void testCreateSimpleQueue() {
+ AnalysisManager analysisManager = new AnalysisManager();
+ ArrayList<AnalysisInfo> jobs = Lists.newArrayList();
+ jobs.add(new AnalysisInfoBuilder().setJobId(1).build());
+ jobs.add(new AnalysisInfoBuilder().setJobId(2).build());
+ SimpleQueue<AnalysisInfo> simpleQueue =
analysisManager.createSimpleQueue(jobs, analysisManager);
+ Assertions.assertEquals(2, simpleQueue.size());
+ simpleQueue = analysisManager.createSimpleQueue(null, analysisManager);
+ Assertions.assertEquals(0, simpleQueue.size());
+ }
+
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
