You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by mo...@apache.org on 2022/05/17 14:37:17 UTC
[incubator-doris] branch master updated: [config] Remove some old config and session variable (#9495)
This is an automated email from the ASF dual-hosted git repository.
morningman pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-doris.git
The following commit(s) were added to refs/heads/master by this push:
new 7d9c25e718 [config] Remove some old config and session variable (#9495)
7d9c25e718 is described below
commit 7d9c25e7185e27571655fadf22ea9a597192920f
Author: Mingyu Chen <mo...@gmail.com>
AuthorDate: Tue May 17 22:37:11 2022 +0800
[config] Remove some old config and session variable (#9495)
1. Remove session variable "enable_lateral_view"
2. Remove Fe config: enable_materialized_view
3. Remove Fe config: enable_create_sync_job
4. Fe config dynamic_partition_enable is only used for disable dynamic partition scheduler.
---
docs/en/admin-manual/config/fe-config.md | 26 +---------------------
.../import/import-way/binlog-load-manual.md | 4 ----
docs/zh-CN/admin-manual/config/fe-config.md | 26 +---------------------
.../import/import-way/binlog-load-manual.md | 4 ----
.../doris/analysis/CreateDataSyncJobStmt.java | 6 -----
.../doris/analysis/CreateMaterializedViewStmt.java | 4 ----
.../org/apache/doris/analysis/LateralViewRef.java | 4 ----
.../org/apache/doris/catalog/TableProperty.java | 11 +--------
.../main/java/org/apache/doris/common/Config.java | 12 ----------
.../java/org/apache/doris/qe/SessionVariable.java | 11 ---------
.../java/org/apache/doris/alter/AlterTest.java | 1 -
.../org/apache/doris/alter/RollupJobV2Test.java | 10 ++++-----
.../doris/analysis/CreateDataSyncJobStmtTest.java | 10 ++++-----
.../analysis/CreateMaterializedViewStmtTest.java | 9 ++++----
.../planner/MaterializedViewFunctionTest.java | 2 +-
.../doris/planner/TableFunctionPlanTest.java | 1 -
.../java/org/apache/doris/utframe/DorisAssert.java | 7 ------
.../data/query/lateral_view/test_issue_8850.out | 3 ---
.../suites/query/lateral_view/test_issue_8850.sql | 2 --
.../table_function/explode_json_array.groovy | 2 --
.../table_function/explode_split.groovy | 4 +---
21 files changed, 19 insertions(+), 140 deletions(-)
diff --git a/docs/en/admin-manual/config/fe-config.md b/docs/en/admin-manual/config/fe-config.md
index 0403a4f408..b540484e6c 100644
--- a/docs/en/admin-manual/config/fe-config.md
+++ b/docs/en/admin-manual/config/fe-config.md
@@ -433,20 +433,6 @@ MasterOnly：true
As long as one BE is down, Routine Load cannot be automatically restored
-### enable_materialized_view
-
-Default：true
-
-IsMutable：true
-
-MasterOnly：true
-
-This configuration is used to turn on and off the creation of materialized views. If set to true, the function to create a materialized view is enabled. The user can create a materialized view through the `CREATE MATERIALIZED VIEW` command. If set to false, materialized views cannot be created.
-
-If you get an error `The materialized view is coming soon` or `The materialized view is disabled` when creating the materialized view, it means that the configuration is set to false and the function of creating the materialized view is turned off. You can start to create a materialized view by modifying the configuration to true.
-
-This variable is a dynamic configuration, and users can modify the configuration through commands after the FE process starts. You can also modify the FE configuration file and restart the FE to take effect
-
### check_java_version
Default：true
@@ -471,7 +457,7 @@ IsMutable：true
MasterOnly：true
-Whether to enable dynamic partition, enabled by default
+Whether to enable dynamic partition scheduler, enabled by default
### dynamic_partition_check_interval_seconds
@@ -2126,16 +2112,6 @@ Only for Master FE: false
If set to true, the compaction slower replica will be skipped when select get queryable replicas
-### enable_create_sync_job
-
-Enable Mysql data synchronization job function. The default is false, this function is turned off
-
-Default: false
-
-Is it possible to configure dynamically: true
-
-Whether it is a configuration item unique to the Master FE node: true
-
### sync_commit_interval_second
The maximum time interval for committing transactions. If there is still data in the channel that has not been submitted after this time, the consumer will notify the channel to submit the transaction.
diff --git a/docs/en/data-operate/import/import-way/binlog-load-manual.md b/docs/en/data-operate/import/import-way/binlog-load-manual.md
index 83d174533a..2de46fda97 100644
--- a/docs/en/data-operate/import/import-way/binlog-load-manual.md
+++ b/docs/en/data-operate/import/import-way/binlog-load-manual.md
@@ -510,10 +510,6 @@ You can use [STOP SYNC JOB](../../../sql-manual/sql-reference/Data-Manipulation-
### Fe configuration
The following configuration belongs to the system level configuration of SyncJob. The configuration value can be modified in configuration file fe.conf.
-
-* `enable_create_sync_job`
-
- Turn on the Binlog Load feature. The default value is false. This feature is turned off.
* `sync_commit_interval_second`
diff --git a/docs/zh-CN/admin-manual/config/fe-config.md b/docs/zh-CN/admin-manual/config/fe-config.md
index a4250994e7..2cb6360a95 100644
--- a/docs/zh-CN/admin-manual/config/fe-config.md
+++ b/docs/zh-CN/admin-manual/config/fe-config.md
@@ -419,20 +419,6 @@ show data （其他用法：HELP SHOW DATA）
只要有一个BE宕机，Routine Load 就无法自动恢复
-### `enable_materialized_view`
-
-默认值：true
-
-是否可以动态配置：true
-
-是否为 Master FE 节点独有的配置项：true
-
-该配置用于开启和关闭创建物化视图功能。如果设置为 true，则创建物化视图功能开启。用户可以通过 `CREATE MATERIALIZED VIEW` 命令创建物化视图。如果设置为 false，则无法创建物化视图。
-
-如果在创建物化视图的时候报错 `The materialized view is coming soon` 或 `The materialized view is disabled` 则说明改配置被设置为了 false，创建物化视图功能关闭了。可以通过修改配置为 true 来启动创建物化视图功能。
-
-该变量为动态配置，用户可以在 FE 进程启动后，通过命令修改配置。也可以通过修改 FE 的配置文件，重启 FE 来生效
-
### `check_java_version`
默认值：true
@@ -457,7 +443,7 @@ Doris 将检查已编译和运行的 Java 版本是否兼容，如果不兼容
是否为 Master FE 节点独有的配置项：true
-是否启用动态分区，默认启用
+是否启用动态分区调度，默认启用
### `dynamic_partition_check_interval_seconds`
@@ -2171,16 +2157,6 @@ load 标签清理器将每隔 `label_clean_interval_second` 运行一次以清
如果设置为true，则在选择可查询副本时，将跳过 compaction 较慢的副本
-### enable_create_sync_job
-
-开启 MySQL 数据同步作业功能。默认是 false，关闭此功能
-
-默认值：false
-
-是否可以动态配置：true
-
-是否为 Master FE 节点独有的配置项：true
-
### sync_commit_interval_second
提交事务的最大时间间隔。若超过了这个时间 channel 中还有数据没有提交，consumer 会通知 channel 提交事务。
diff --git a/docs/zh-CN/data-operate/import/import-way/binlog-load-manual.md b/docs/zh-CN/data-operate/import/import-way/binlog-load-manual.md
index 63f0f0ea64..f42974f6a3 100644
--- a/docs/zh-CN/data-operate/import/import-way/binlog-load-manual.md
+++ b/docs/zh-CN/data-operate/import/import-way/binlog-load-manual.md
@@ -494,10 +494,6 @@ binlog_desc
下面配置属于数据同步作业的系统级别配置，主要通过修改 fe.conf 来调整配置值。
-- `enable_create_sync_job`
-
- 开启数据同步作业功能。默认为 false，关闭此功能。
-
- `sync_commit_interval_second`
提交事务的最大时间间隔。若超过了这个时间channel中还有数据没有提交，consumer会通知channel提交事务。
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateDataSyncJobStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateDataSyncJobStmt.java
index 5b51f21163..cbf0bdbf13 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateDataSyncJobStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateDataSyncJobStmt.java
@@ -23,7 +23,6 @@ import org.apache.doris.catalog.KeysType;
import org.apache.doris.catalog.OlapTable;
import org.apache.doris.cluster.ClusterNamespace;
import org.apache.doris.common.AnalysisException;
-import org.apache.doris.common.Config;
import org.apache.doris.common.ErrorCode;
import org.apache.doris.common.ErrorReport;
import org.apache.doris.common.UserException;
@@ -79,11 +78,6 @@ public class CreateDataSyncJobStmt extends DdlStmt {
}
dbName = ClusterNamespace.getFullName(analyzer.getClusterName(), dbName);
- if (!Config.enable_create_sync_job) {
- throw new AnalysisException("Mysql sync job is disabled." +
- " Set config 'enable_create_sync_job' = 'true' to enable this feature. ");
- }
-
if (binlogDesc != null) {
binlogDesc.analyze();
dataSyncJobType = binlogDesc.getDataSyncJobType();
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateMaterializedViewStmt.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateMaterializedViewStmt.java
index 420053358f..b8125417ee 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateMaterializedViewStmt.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/CreateMaterializedViewStmt.java
@@ -24,7 +24,6 @@ import org.apache.doris.catalog.KeysType;
import org.apache.doris.catalog.PrimitiveType;
import org.apache.doris.catalog.Type;
import org.apache.doris.common.AnalysisException;
-import org.apache.doris.common.Config;
import org.apache.doris.common.ErrorCode;
import org.apache.doris.common.ErrorReport;
import org.apache.doris.common.FeConstants;
@@ -131,9 +130,6 @@ public class CreateMaterializedViewStmt extends DdlStmt {
@Override
public void analyze(Analyzer analyzer) throws UserException {
- if (!Config.enable_materialized_view) {
- throw new AnalysisException("The materialized view is disabled");
- }
super.analyze(analyzer);
FeNameFormat.checkTableName(mvName);
// TODO(ml): The mv name in from clause should pass the analyze without error.
diff --git a/fe/fe-core/src/main/java/org/apache/doris/analysis/LateralViewRef.java b/fe/fe-core/src/main/java/org/apache/doris/analysis/LateralViewRef.java
index 975dc5e235..e0fda6333f 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/analysis/LateralViewRef.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/analysis/LateralViewRef.java
@@ -62,10 +62,6 @@ public class LateralViewRef extends TableRef {
@Override
public void analyze(Analyzer analyzer) throws UserException {
- if (!analyzer.getContext().getSessionVariable().isEnableLateralView()) {
- throw new AnalysisException("The session variables `enable_lateral_view` is false");
- }
-
if (isAnalyzed) {
return;
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/catalog/TableProperty.java b/fe/fe-core/src/main/java/org/apache/doris/catalog/TableProperty.java
index 54977acea1..f9d2063284 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/catalog/TableProperty.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/catalog/TableProperty.java
@@ -19,8 +19,6 @@ package org.apache.doris.catalog;
import org.apache.doris.analysis.DataSortInfo;
import org.apache.doris.common.AnalysisException;
-import org.apache.doris.common.Config;
-import org.apache.doris.common.DdlException;
import org.apache.doris.common.FeMetaVersion;
import org.apache.doris.common.io.Text;
import org.apache.doris.common.io.Writable;
@@ -117,14 +115,7 @@ public class TableProperty implements Writable {
return this;
}
- public TableProperty buildDynamicProperty() throws DdlException {
- if (properties.containsKey(DynamicPartitionProperty.ENABLE)
- && Boolean.valueOf(properties.get(DynamicPartitionProperty.ENABLE))
- && !Config.dynamic_partition_enable) {
- throw new DdlException("Could not create table with dynamic partition "
- + "when fe config dynamic_partition_enable is false. "
- + "Please ADMIN SET FRONTEND CONFIG (\"dynamic_partition_enable\" = \"true\") firstly.");
- }
+ public TableProperty buildDynamicProperty() {
executeBuildDynamicProperty();
return this;
}
diff --git a/fe/fe-core/src/main/java/org/apache/doris/common/Config.java b/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
index 1d5299a6e0..4515c623c2 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/common/Config.java
@@ -1288,18 +1288,6 @@ public class Config extends ConfigBase {
@ConfField
public static boolean check_java_version = true;
- /**
- * control materialized view
- */
- @ConfField(mutable = true, masterOnly = true)
- public static boolean enable_materialized_view = true;
-
- /**
- * enable create sync job
- */
- @ConfField(mutable = true, masterOnly = true)
- public static boolean enable_create_sync_job = false;
-
/**
* it can't auto-resume routine load job as long as one of the backends is down
*/
diff --git a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
index c6caa2cb3d..439ca666f5 100644
--- a/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
+++ b/fe/fe-core/src/main/java/org/apache/doris/qe/SessionVariable.java
@@ -415,9 +415,6 @@ public class SessionVariable implements Serializable, Writable {
@VariableMgr.VarAttr(name = CPU_RESOURCE_LIMIT)
public int cpuResourceLimit = -1;
- @VariableMgr.VarAttr(name = ENABLE_LATERAL_VIEW, needForward = true)
- public boolean enableLateralView = false;
-
@VariableMgr.VarAttr(name = DISABLE_JOIN_REORDER)
private boolean disableJoinReorder = false;
@@ -876,14 +873,6 @@ public class SessionVariable implements Serializable, Writable {
return enableParallelOutfile;
}
- public boolean isEnableLateralView() {
- return enableLateralView;
- }
-
- public void setEnableLateralView(boolean enableLateralView) {
- this.enableLateralView = enableLateralView;
- }
-
public boolean isDisableJoinReorder() {
return disableJoinReorder;
}
diff --git a/fe/fe-core/src/test/java/org/apache/doris/alter/AlterTest.java b/fe/fe-core/src/test/java/org/apache/doris/alter/AlterTest.java
index 6cf2d0cb9a..0d3a0bb233 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/alter/AlterTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/alter/AlterTest.java
@@ -67,7 +67,6 @@ public class AlterTest {
public static void beforeClass() throws Exception {
FeConstants.runningUnitTest = true;
FeConstants.default_scheduler_interval_millisecond = 100;
- Config.dynamic_partition_enable = true;
Config.dynamic_partition_check_interval_seconds = 1;
Config.disable_storage_medium_check = true;
UtFrameUtils.createDorisCluster(runningDir);
diff --git a/fe/fe-core/src/test/java/org/apache/doris/alter/RollupJobV2Test.java b/fe/fe-core/src/test/java/org/apache/doris/alter/RollupJobV2Test.java
index cd582d684b..3faf12f344 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/alter/RollupJobV2Test.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/alter/RollupJobV2Test.java
@@ -61,10 +61,7 @@ import org.apache.doris.transaction.FakeTransactionIDGenerator;
import org.apache.doris.transaction.GlobalTransactionMgr;
import com.google.common.collect.Lists;
-import mockit.Expectations;
-import mockit.Mock;
-import mockit.MockUp;
-import mockit.Mocked;
+
import org.junit.After;
import org.junit.Assert;
import org.junit.Before;
@@ -80,6 +77,10 @@ import java.lang.reflect.InvocationTargetException;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
+import mockit.Expectations;
+import mockit.Mock;
+import mockit.MockUp;
+import mockit.Mocked;
public class RollupJobV2Test {
private static String fileName = "./RollupJobV2Test";
@@ -313,7 +314,6 @@ public class RollupJobV2Test {
@Test
public void testSerializeOfRollupJob(@Mocked CreateMaterializedViewStmt stmt) throws IOException,
AnalysisException {
- Config.enable_materialized_view = true;
// prepare file
File file = new File(fileName);
file.createNewFile();
diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateDataSyncJobStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateDataSyncJobStmtTest.java
index 17c9ef140b..044aeb4cd1 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateDataSyncJobStmtTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateDataSyncJobStmtTest.java
@@ -21,7 +21,6 @@ import org.apache.doris.catalog.Catalog;
import org.apache.doris.catalog.Database;
import org.apache.doris.catalog.KeysType;
import org.apache.doris.catalog.OlapTable;
-import org.apache.doris.common.Config;
import org.apache.doris.common.UserException;
import org.apache.doris.load.sync.DataSyncJobType;
import org.apache.doris.mysql.privilege.PaloAuth;
@@ -30,9 +29,7 @@ import org.apache.doris.qe.ConnectContext;
import com.google.common.collect.Lists;
import com.google.common.collect.Maps;
-import mockit.Expectations;
-import mockit.Injectable;
-import mockit.Mocked;
+
import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.junit.Assert;
@@ -41,6 +38,9 @@ import org.junit.Test;
import java.util.List;
import java.util.Map;
+import mockit.Expectations;
+import mockit.Injectable;
+import mockit.Mocked;
public class CreateDataSyncJobStmtTest {
private static final Logger LOG = LogManager.getLogger(CreateDataSyncJobStmtTest.class);
@@ -91,8 +91,6 @@ public class CreateDataSyncJobStmtTest {
result = catalog;
}
};
-
- Config.enable_create_sync_job = true;
}
@Test
public void testNoDb() {
diff --git a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateMaterializedViewStmtTest.java b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateMaterializedViewStmtTest.java
index 40329776d7..a3dba780ba 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateMaterializedViewStmtTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/analysis/CreateMaterializedViewStmtTest.java
@@ -32,15 +32,16 @@ import org.apache.doris.common.jmockit.Deencapsulation;
import org.apache.doris.qe.ConnectContext;
import com.google.common.collect.Lists;
-import mockit.Expectations;
-import mockit.Injectable;
-import mockit.Mocked;
+
import org.junit.Assert;
import org.junit.Before;
import org.junit.Test;
import java.util.ArrayList;
import java.util.List;
+import mockit.Expectations;
+import mockit.Injectable;
+import mockit.Mocked;
public class CreateMaterializedViewStmtTest {
@@ -55,7 +56,7 @@ public class CreateMaterializedViewStmtTest {
@Before
public void initTest() {
- Deencapsulation.setField(Config.class, "enable_materialized_view", true);
+
}
@Test
diff --git a/fe/fe-core/src/test/java/org/apache/doris/planner/MaterializedViewFunctionTest.java b/fe/fe-core/src/test/java/org/apache/doris/planner/MaterializedViewFunctionTest.java
index 09d28a719e..a980ff9a67 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/planner/MaterializedViewFunctionTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/planner/MaterializedViewFunctionTest.java
@@ -58,7 +58,7 @@ public class MaterializedViewFunctionTest {
FeConstants.runningUnitTest = true;
UtFrameUtils.createDorisCluster(runningDir);
dorisAssert = new DorisAssert();
- dorisAssert.withEnableMV().withDatabase(HR_DB_NAME).useDatabase(HR_DB_NAME);
+ dorisAssert.withDatabase(HR_DB_NAME).useDatabase(HR_DB_NAME);
}
@Before
diff --git a/fe/fe-core/src/test/java/org/apache/doris/planner/TableFunctionPlanTest.java b/fe/fe-core/src/test/java/org/apache/doris/planner/TableFunctionPlanTest.java
index a9b59ab8f1..8c3eb90a92 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/planner/TableFunctionPlanTest.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/planner/TableFunctionPlanTest.java
@@ -46,7 +46,6 @@ public class TableFunctionPlanTest {
public static void setUp() throws Exception {
UtFrameUtils.createDorisCluster(runningDir);
ctx = UtFrameUtils.createDefaultCtx();
- ctx.getSessionVariable().setEnableLateralView(true);
String createDbStmtStr = "create database db1;";
CreateDbStmt createDbStmt = (CreateDbStmt) UtFrameUtils.parseAndAnalyzeStmt(createDbStmtStr, ctx);
Catalog.getCurrentCatalog().createDb(createDbStmt);
diff --git a/fe/fe-core/src/test/java/org/apache/doris/utframe/DorisAssert.java b/fe/fe-core/src/test/java/org/apache/doris/utframe/DorisAssert.java
index 94ab05b8b0..ad395117a5 100644
--- a/fe/fe-core/src/test/java/org/apache/doris/utframe/DorisAssert.java
+++ b/fe/fe-core/src/test/java/org/apache/doris/utframe/DorisAssert.java
@@ -32,7 +32,6 @@ import org.apache.doris.analysis.StatementBase;
import org.apache.doris.catalog.Catalog;
import org.apache.doris.cluster.ClusterNamespace;
import org.apache.doris.common.AnalysisException;
-import org.apache.doris.common.Config;
import org.apache.doris.common.util.SqlParserUtils;
import org.apache.doris.planner.Planner;
import org.apache.doris.qe.ConnectContext;
@@ -68,12 +67,6 @@ public class DorisAssert {
this.ctx = ctx;
}
- public DorisAssert withEnableMV() {
- ctx.getSessionVariable().setTestMaterializedView(true);
- Config.enable_materialized_view = true;
- return this;
- }
-
public DorisAssert withDatabase(String dbName) throws Exception {
CreateDbStmt createDbStmt =
(CreateDbStmt) UtFrameUtils.parseAndAnalyzeStmt("create database " + dbName + ";", ctx);
diff --git a/regression-test/data/query/lateral_view/test_issue_8850.out b/regression-test/data/query/lateral_view/test_issue_8850.out
index 17983887f2..4027cbd256 100644
--- a/regression-test/data/query/lateral_view/test_issue_8850.out
+++ b/regression-test/data/query/lateral_view/test_issue_8850.out
@@ -6,10 +6,7 @@
0
-- !test_issue_8850_3 --
-0
-- !test_issue_8850_4 --
-
--- !test_issue_8850_5 --
0
diff --git a/regression-test/suites/query/lateral_view/test_issue_8850.sql b/regression-test/suites/query/lateral_view/test_issue_8850.sql
index d4cb8b9d78..88a9caf6f9 100644
--- a/regression-test/suites/query/lateral_view/test_issue_8850.sql
+++ b/regression-test/suites/query/lateral_view/test_issue_8850.sql
@@ -2,8 +2,6 @@ DROP TABLE IF EXISTS tag_map;
CREATE TABLE `tag_map` ( `tag_group` bigint(20) NULL COMMENT "标签组", `tag_value_id` varchar(64) NULL COMMENT "标签值", `tag_range` int(11) NOT NULL DEFAULT "0" COMMENT "", `partition_sign` varchar(32) NOT NULL COMMENT "分区标识", `bucket` int(11) NOT NULL COMMENT "分桶字段", `confidence` tinyint(4) NULL DEFAULT "100" COMMENT "置信度", `members` bitmap BITMAP_UNION NULL COMMENT "人群") ENGINE=OLAP AGGREGATE KEY(`tag_group`, `tag_value_id`, `tag_range`, `partition_sign`, `bucket`, `confidence`) COMMENT "dm [...]
-set enable_lateral_view=true;
-
with d as (select f1.bucket, bitmap_and(f1.members, f2.members) as members from (select f1.bucket, bitmap_and(f1.members, f2.members) as members from (select bucket, bitmap_union(members) as members from tag_map where partition_sign='2022-03-31-1' and tag_group=810004 and tag_value_id in (5524627,5524628,5524629) group by bucket) f1,(select bucket, bitmap_union(members) as members from tag_map where partition_sign='2022-03-31-1' and tag_group=810007 and tag_value_id in ('5525013_1735712 [...]
DROP TABLE tag_map;
diff --git a/regression-test/suites/query/sql_functions/table_function/explode_json_array.groovy b/regression-test/suites/query/sql_functions/table_function/explode_json_array.groovy
index d5f2af00e6..ebc573cbe2 100644
--- a/regression-test/suites/query/sql_functions/table_function/explode_json_array.groovy
+++ b/regression-test/suites/query/sql_functions/table_function/explode_json_array.groovy
@@ -36,8 +36,6 @@ suite("explode_json_array") {
(300, 'Mike', 80, 3, 'Street 3'),
(400, 'Dan', 50, 4, 'Street 4') """
- sql """ set enable_lateral_view = true """
-
// not vectorized
qt_explode_json_array1 """ SELECT * FROM ${tableName}
LATERAL VIEW EXPLODE_JSON_ARRAY_INT('[30, 60]') t1 as c_age
diff --git a/regression-test/suites/query/sql_functions/table_function/explode_split.groovy b/regression-test/suites/query/sql_functions/table_function/explode_split.groovy
index 4af2bad8d8..95dc6bca55 100644
--- a/regression-test/suites/query/sql_functions/table_function/explode_split.groovy
+++ b/regression-test/suites/query/sql_functions/table_function/explode_split.groovy
@@ -28,8 +28,6 @@ suite("explode_split") {
sql """ INSERT INTO ${tableName} VALUES (1, 'a,b,c') """
- sql """ set enable_lateral_view = true """
-
// not_vectorized
qt_explode_split """ select * from ${tableName}
lateral view explode_split(k2, ',') tmp1 as e1 """
@@ -48,4 +46,4 @@ suite("explode_split") {
lateral view explode_split(k2, ',') tmp1 as e1
lateral view explode_split(k2, ',') tmp2 as e2 """
-}
\ No newline at end of file
+}
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org