Skip to content

Commit

Permalink
Fix UT
Browse files Browse the repository at this point in the history
  • Loading branch information
gavinchou committed Dec 31, 2024
1 parent 83249b0 commit b1471f5
Show file tree
Hide file tree
Showing 3 changed files with 13 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@

package org.apache.doris.analysis;

import org.apache.doris.common.Config;
import org.apache.doris.common.FeConstants;
import org.apache.doris.common.UserException;
import org.apache.doris.load.ExportJob;
Expand Down Expand Up @@ -47,6 +48,12 @@ public class ExportToOutfileLogicalPlanTest extends TestWithFeService {
private String dbName = "testDb";
private String tblName = "table1";

private final boolean defaultEnableAdvanceNextId = Config.enable_advance_next_id; // backup

{
enableAdvanceNextId = false;
}

/**
* create a database and a table
*
Expand All @@ -65,6 +72,7 @@ protected void runBeforeAll() throws Exception {
+ "PARTITION p4 VALUES LESS THAN (\"50\")\n" + ")\n"
+ " distributed by hash(k1) buckets 10\n"
+ "properties(\"replication_num\" = \"1\");");
Config.enable_advance_next_id = defaultEnableAdvanceNextId; // restore
}

/**
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -96,7 +96,7 @@ public void testFetchResult() throws AnalysisException {
Assert.assertEquals(procResult.getRows().get(3).get(5), "col_4");
Assert.assertEquals(procResult.getRows().get(3).get(11), "NGRAM_BF");
Assert.assertEquals(procResult.getRows().get(3).get(12), "ngram_bf index on col_4");
Assert.assertEquals(procResult.getRows().get(3).get(13), "(\"gram_size\" = \"3\", \"bf_size\" = \"256\")");
Assert.assertEquals(procResult.getRows().get(3).get(13), "(\"bf_size\" = \"256\", \"gram_size\" = \"3\")");

}
}
Original file line number Diff line number Diff line change
Expand Up @@ -140,6 +140,8 @@ public abstract class TestWithFeService {
protected ConnectContext connectContext;
protected boolean needCleanDir = true;
protected int lastFeRpcPort = 0;
// make it default to enable_advance_next_id
protected boolean enableAdvanceNextId = Config.enable_advance_next_id;

protected static final String DEFAULT_CLUSTER_PREFIX = "";

Expand All @@ -152,6 +154,8 @@ public Set<Integer> getEnableNereidsRules() {

@BeforeAll
public final void beforeAll() throws Exception {
// this.enableAdvanceNextId may be reset by children classes
Config.enable_advance_next_id = this.enableAdvanceNextId;
FeConstants.enableInternalSchemaDb = false;
FeConstants.shouldCreateInternalWorkloadGroup = false;
beforeCreatingConnectContext();
Expand Down

0 comments on commit b1471f5

Please sign in to comment.