Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
aqni committed Dec 21, 2024
1 parent 7aec595 commit 355c17b
Showing 1 changed file with 2 additions and 22 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -104,9 +104,8 @@ public OptimizerIT() {

String rules = executor.execute("SHOW RULES;");
this.isOptimizerOpen = rules.contains("FilterPushDownRule| ON|");
if (isOptimizerOpen) {
ruleList = getRuleList();
}
Assume.assumeTrue(isOptimizerOpen);
ruleList = getRuleList();
}

@BeforeClass
Expand Down Expand Up @@ -245,8 +244,6 @@ public void clearData() {

@Test
public void testModifyRules() {
Assume.assumeTrue(isOptimizerOpen);

String statement, expected;
statement = "show rules;";

Expand Down Expand Up @@ -282,8 +279,6 @@ public void testModifyRules() {

@Test
public void testFilterPushDownExplain() {
Assume.assumeTrue(isOptimizerOpen);

executor.execute("SET RULES FilterPushDownRule=on;");

String insert =
Expand Down Expand Up @@ -683,7 +678,6 @@ public void testFilterPushDownExplain() {

@Test
public void testFilterFragmentOptimizer() {
Assume.assumeTrue(isOptimizerOpen);
Assume.assumeFalse(isScaling);

String policy = executor.execute("SHOW CONFIG \"policyClassName\";");
Expand Down Expand Up @@ -884,7 +878,6 @@ public void testFilterFragmentOptimizer() {

@Test
public void testColumnPruningAndFragmentPruning() {
Assume.assumeTrue(isOptimizerOpen);
Assume.assumeFalse(isScaling);

StringBuilder insert =
Expand Down Expand Up @@ -1146,8 +1139,6 @@ public void testColumnPruningAndFragmentPruning() {

@Test
public void testConstantPropagation() {
Assume.assumeTrue(isOptimizerOpen);

String openRule = "SET RULES ConstantPropagationRule=on;";
String closeRule = "SET RULES ConstantPropagationRule=off;";

Expand Down Expand Up @@ -1202,8 +1193,6 @@ public void testConstantPropagation() {
/** 对常量折叠进行测试,因为RowTransform常量折叠和Filter常量折叠使用的代码都是公共的,所以这里只测试更好对比结果的RowTransform常量折叠 */
@Test
public void testConstantFolding() {
Assume.assumeTrue(isOptimizerOpen);

String openRule = "SET RULES ConstantFoldingRule=on;";
String closeRule = "SET RULES ConstantFoldingRule=off;";

Expand Down Expand Up @@ -1321,8 +1310,6 @@ public void testConstantFolding() {

@Test
public void testDistinctEliminate() {
Assume.assumeTrue(isOptimizerOpen);

// 插入数据
StringBuilder insert = new StringBuilder();
insert.append("INSERT INTO us.d2 (key, s1, s2) VALUES ");
Expand Down Expand Up @@ -1407,7 +1394,6 @@ public void testDistinctEliminate() {

@Test
public void testJoinFactorizationRule() {
Assume.assumeTrue(isOptimizerOpen);
Assume.assumeFalse(isScaling);

String openRule = "SET RULES JoinFactorizationRule=on;";
Expand Down Expand Up @@ -1619,8 +1605,6 @@ public void testJoinFactorizationRule() {

@Test
public void testOuterJoinEliminate() {
Assume.assumeTrue(isOptimizerOpen);

StringBuilder insert = new StringBuilder();
insert.append("INSERT INTO us (key, d2.s1, d2.s2, d3.s1, d3.s2) VALUES ");
int rows = 15000;
Expand Down Expand Up @@ -1674,8 +1658,6 @@ public void testOuterJoinEliminate() {

@Test
public void testInFilterTransformRule() {
Assume.assumeTrue(isOptimizerOpen);

// 插入数据
StringBuilder insert = new StringBuilder();
insert.append("INSERT INTO us.d2 (key, s1, s2) VALUES ");
Expand Down Expand Up @@ -1747,8 +1729,6 @@ public void testInFilterTransformRule() {

@Test
public void testAllowNullColumnRule() {
Assume.assumeTrue(isOptimizerOpen);

String openRule = "SET RULES AllowNullColumnRule=on;";
String closeRule = "SET RULES AllowNullColumnRule=off;";
String statement = "SELECT * FROM us.d1 WHERE s1 = 1;";
Expand Down

0 comments on commit 355c17b

Please sign in to comment.