Skip to content

Commit d5828da

Browse files
authored
Merge pull request #203 from WeiXinChan/tmp_414
update distributed execution switch
2 parents ee468f2 + 51c1d62 commit d5828da

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/test/java/com/alipay/oceanbase/hbase/util/ObHTableSecondaryPartUtil.java

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -31,14 +31,14 @@
3131

3232
public class ObHTableSecondaryPartUtil {
3333
public static void openDistributedExecute() throws Exception {
34-
Connection conn = ObHTableTestUtil.getSysConnection();
35-
String stmt = "ALTER SYSTEM SET _obkv_feature_mode = 'distributed_execute=on';";
34+
Connection conn = ObHTableTestUtil.getConnection();
35+
String stmt = "ALTER SYSTEM SET _obkv_enable_distributed_execution = true;";
3636
conn.createStatement().execute(stmt);
3737
}
3838

3939
public static void closeDistributedExecute() throws Exception {
40-
Connection conn = ObHTableTestUtil.getSysConnection();
41-
String stmt = "ALTER SYSTEM SET _obkv_feature_mode = 'distributed_execute=off';";
40+
Connection conn = ObHTableTestUtil.getConnection();
41+
String stmt = "ALTER SYSTEM SET _obkv_enable_distributed_execution = false;";
4242
conn.createStatement().execute(stmt);
4343
}
4444

0 commit comments

Comments
 (0)