Skip to content

Commit 5a5bf0c

Browse files
authored
[opt](analyze) add fe conf for force analyze external table (#59587)
1 parent 4f3457b commit 5a5bf0c

File tree

2 files changed

+8
-0
lines changed

2 files changed

+8
-0
lines changed

fe/fe-common/src/main/java/org/apache/doris/common/Config.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2722,6 +2722,10 @@ public class Config extends ConfigBase {
27222722
@ConfField(mutable = true)
27232723
public static boolean force_sample_analyze = false; // avoid full analyze for performance reason
27242724

2725+
@ConfField(mutable = true)
2726+
public static boolean force_analyze_for_external = false;
2727+
2728+
27252729
@ConfField(mutable = true, description = {
27262730
"Export任务允许的最大分区数量",
27272731
"The maximum number of partitions allowed by Export job"})

fe/fe-core/src/main/java/org/apache/doris/datasource/ExternalTable.java

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -26,6 +26,7 @@
2626
import org.apache.doris.catalog.TableIndexes;
2727
import org.apache.doris.catalog.constraint.Constraint;
2828
import org.apache.doris.common.AnalysisException;
29+
import org.apache.doris.common.Config;
2930
import org.apache.doris.common.Pair;
3031
import org.apache.doris.common.io.Text;
3132
import org.apache.doris.common.io.Writable;
@@ -323,6 +324,9 @@ public List<Column> getColumns() {
323324
@Override
324325
public boolean autoAnalyzeEnabled() {
325326
makeSureInitialized();
327+
if (Config.force_analyze_for_external) {
328+
return true;
329+
}
326330
String policy = catalog.getTableAutoAnalyzePolicy().get(Pair.of(dbName, name));
327331
if (policy == null) {
328332
return catalog.enableAutoAnalyze();

0 commit comments

Comments
 (0)