fix: fix java case

4paradigm · Nov 1, 2023 · acd8bc2 · acd8bc2
1 parent 629cefc
commit acd8bc2
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/...penmldb-jdbc/src/test/java/com/_4paradigm/openmldb/jdbc/RequestPreparedStatementTest.java b/...penmldb-jdbc/src/test/java/com/_4paradigm/openmldb/jdbc/RequestPreparedStatementTest.java
@@ -317,23 +317,25 @@ public void testBatchRequest(String compressType, String storageMode) {
         }
     }
 
-    @Test
-    public void testDeploymentBatchRequest() {
+    @Test(dataProvider = "createOption")
+    public void testDeploymentBatchRequest(String compressType, String storageMode) {
         java.sql.Statement state = executor.getStatement();
         String dbname = "db" + random.nextInt(100000);
         String deploymentName = "dp_test1";
         try {
             state.execute("drop database if exists " + dbname + ";");
             state.execute("create database " + dbname + ";");
             state.execute("use " + dbname + ";");
-            String createTableSql = "create table trans(c1 string,\n" +
+            String baseSql = "create table trans(c1 string,\n" +
                     "                   c3 int,\n" +
                     "                   c4 bigint,\n" +
                     "                   c5 float,\n" +
                     "                   c6 double,\n" +
                     "                   c7 timestamp,\n" +
                     "                   c8 date,\n" +
-                    "                   index(key=c1, ts=c7));";
+                    "                   index(key=c1, ts=c7))";
+            String createTableSql = String.format(" %s OPTIONS (compress_type='%s', storage_mode='%s');",
+                    baseSql, compressType, storageMode);
             state.execute(createTableSql);
             String selectSql = "SELECT c1, c3, sum(c4) OVER w1 as w1_c4_sum FROM trans WINDOW w1 AS " +
                     "(PARTITION BY trans.c1 ORDER BY trans.c7 ROWS BETWEEN 2 PRECEDING AND CURRENT ROW);";

diff --git a/onebox/start_onebox.sh b/onebox/start_onebox.sh
@@ -75,6 +75,8 @@ cluster_start_component() {
             --zk_keep_alive_check_interval=60000
             --db_root_path="$binlog_dir"
             --recycle_bin_root_path="$recycle_bin_dir"
+            --hdd_root_path="$binlog_dir"
+            --recycle_bin_hdd_root_path="$recycle_bin_dir"
         )
     elif [[ $role = 'nameserver' ]]; then
         extra_opts+=(