diff --git a/fe/fe-core/src/test/java/com/starrocks/statistic/StatisticsCollectionTriggerTest.java b/fe/fe-core/src/test/java/com/starrocks/statistic/StatisticsCollectionTriggerTest.java index 227ada1b6e2348..934c261f943af0 100644 --- a/fe/fe-core/src/test/java/com/starrocks/statistic/StatisticsCollectionTriggerTest.java +++ b/fe/fe-core/src/test/java/com/starrocks/statistic/StatisticsCollectionTriggerTest.java @@ -81,14 +81,14 @@ public void triggerOnLoad() throws Exception { InsertTxnCommitAttachment attachment = new InsertTxnCommitAttachment(1, 5); transactionState.setTxnCommitAttachment(attachment); StatisticsCollectionTrigger trigger = - StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true); + StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true, true); Assert.assertEquals(null, trigger.getAnalyzeType()); } { InsertTxnCommitAttachment attachment = new InsertTxnCommitAttachment(1000, 5); transactionState.setTxnCommitAttachment(attachment); StatisticsCollectionTrigger trigger = - StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true); + StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true, true); Assert.assertEquals(StatsConstants.AnalyzeType.FULL, trigger.getAnalyzeType()); } @@ -96,7 +96,7 @@ public void triggerOnLoad() throws Exception { InsertTxnCommitAttachment attachment = new InsertTxnCommitAttachment(1000000, 5); transactionState.setTxnCommitAttachment(attachment); StatisticsCollectionTrigger trigger = - StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true); + StatisticsCollectionTrigger.triggerOnFirstLoad(transactionState, db, table, true, true); Assert.assertEquals(StatsConstants.AnalyzeType.SAMPLE, trigger.getAnalyzeType()); } } @@ -128,7 +128,7 @@ public void triggerOnInsertOverwrite() throws Exception { { InsertOverwriteJobStats stats = new InsertOverwriteJobStats( List.of(sourceId), List.of(targetId), 1000, 1001); - StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true); + StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true, true); Partition targetPartition = new Partition(targetId, "p1", null, null); Map> tableStats = storage.getTableStatistics(table.getId(), List.of(targetPartition)); @@ -140,7 +140,7 @@ public void triggerOnInsertOverwrite() throws Exception { InsertOverwriteJobStats stats = new InsertOverwriteJobStats( List.of(sourceId), List.of(targetId), 1000, 50000); StatisticsCollectionTrigger trigger = - StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true); + StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true, true); Assert.assertEquals(StatsConstants.AnalyzeType.FULL, trigger.getAnalyzeType()); } @@ -149,7 +149,7 @@ public void triggerOnInsertOverwrite() throws Exception { InsertOverwriteJobStats stats = new InsertOverwriteJobStats( List.of(sourceId), List.of(targetId), 1000, 50000000); StatisticsCollectionTrigger trigger = - StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true); + StatisticsCollectionTrigger.triggerOnInsertOverwrite(stats, db, table, true, true); Assert.assertEquals(StatsConstants.AnalyzeType.SAMPLE, trigger.getAnalyzeType()); } }