This is an automated email from the ASF dual-hosted git repository.
haonan pushed a commit to branch optimize_flushing_memtable_check
in repository https://gitbox.apache.org/repos/asf/iotdb.git
The following commit(s) were added to
refs/heads/optimize_flushing_memtable_check by this push:
new a15e5a07a6d recover code
a15e5a07a6d is described below
commit a15e5a07a6dcb757be5a426b85ce3b52b2390aaf
Author: HTHou <[email protected]>
AuthorDate: Mon Feb 26 10:33:13 2024 +0800
recover code
---
.../main/java/org/apache/iotdb/SessionExample.java | 87 +++++++++++-----------
.../resources/conf/iotdb-datanode.properties | 2 +-
2 files changed, 45 insertions(+), 44 deletions(-)
diff --git a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
index 2f642171341..d5f40452ea8 100644
--- a/example/session/src/main/java/org/apache/iotdb/SessionExample.java
+++ b/example/session/src/main/java/org/apache/iotdb/SessionExample.java
@@ -26,6 +26,7 @@ import org.apache.iotdb.isession.template.Template;
import org.apache.iotdb.isession.util.Version;
import org.apache.iotdb.rpc.IoTDBConnectionException;
import org.apache.iotdb.rpc.StatementExecutionException;
+import org.apache.iotdb.rpc.TSStatusCode;
import org.apache.iotdb.session.Session;
import org.apache.iotdb.session.template.MeasurementNode;
import org.apache.iotdb.tsfile.common.conf.TSFileConfig;
@@ -77,49 +78,49 @@ public class SessionExample {
// set session fetchSize
session.setFetchSize(10000);
- //
- // try {
- // session.createDatabase("root.sg1");
- // } catch (StatementExecutionException e) {
- // if (e.getStatusCode() !=
TSStatusCode.DATABASE_ALREADY_EXISTS.getStatusCode()) {
- // throw e;
- // }
- // }
- //
- // // createTemplate();
- // createTimeseries();
- // createMultiTimeseries();
- // insertRecord();
+
+ try {
+ session.createDatabase("root.sg1");
+ } catch (StatementExecutionException e) {
+ if (e.getStatusCode() !=
TSStatusCode.DATABASE_ALREADY_EXISTS.getStatusCode()) {
+ throw e;
+ }
+ }
+
+ // createTemplate();
+ createTimeseries();
+ createMultiTimeseries();
+ insertRecord();
insertTablet();
- // // insertTabletWithNullValues();
- // // insertTablets();
- // // insertRecords();
- // // insertText();
- // // selectInto();
- // // createAndDropContinuousQueries();
- // // nonQuery();
- // query();
- // // queryWithTimeout();
- // rawDataQuery();
- // lastDataQuery();
- // aggregationQuery();
- // groupByQuery();
- // // queryByIterator();
- // // deleteData();
- // // deleteTimeseries();
- // // setTimeout();
- //
- // sessionEnableRedirect = new Session(LOCAL_HOST, 6667, "root",
"root");
- // sessionEnableRedirect.setEnableQueryRedirection(true);
- // sessionEnableRedirect.open(false);
- //
- // // set session fetchSize
- // sessionEnableRedirect.setFetchSize(10000);
- //
- // fastLastDataQueryForOneDevice();
- // insertRecord4Redirect();
- // query4Redirect();
- // sessionEnableRedirect.close();
+ // insertTabletWithNullValues();
+ // insertTablets();
+ // insertRecords();
+ // insertText();
+ // selectInto();
+ // createAndDropContinuousQueries();
+ // nonQuery();
+ query();
+ // queryWithTimeout();
+ rawDataQuery();
+ lastDataQuery();
+ aggregationQuery();
+ groupByQuery();
+ // queryByIterator();
+ // deleteData();
+ // deleteTimeseries();
+ // setTimeout();
+
+ sessionEnableRedirect = new Session(LOCAL_HOST, 6667, "root", "root");
+ sessionEnableRedirect.setEnableQueryRedirection(true);
+ sessionEnableRedirect.open(false);
+
+ // set session fetchSize
+ sessionEnableRedirect.setFetchSize(10000);
+
+ fastLastDataQueryForOneDevice();
+ insertRecord4Redirect();
+ query4Redirect();
+ sessionEnableRedirect.close();
session.close();
}
@@ -392,7 +393,7 @@ public class SessionExample {
// The schema of measurements of one device
// only measurementId and data type in MeasurementSchema take effects in
Tablet
List<MeasurementSchema> schemaList = new ArrayList<>();
- schemaList.add(new MeasurementSchema("`s1.aaa`", TSDataType.INT64));
+ schemaList.add(new MeasurementSchema("s1", TSDataType.INT64));
schemaList.add(new MeasurementSchema("s2", TSDataType.INT64));
schemaList.add(new MeasurementSchema("s3", TSDataType.INT64));
diff --git
a/iotdb-core/datanode/src/assembly/resources/conf/iotdb-datanode.properties
b/iotdb-core/datanode/src/assembly/resources/conf/iotdb-datanode.properties
index 2d67f46b700..949e3400750 100644
--- a/iotdb-core/datanode/src/assembly/resources/conf/iotdb-datanode.properties
+++ b/iotdb-core/datanode/src/assembly/resources/conf/iotdb-datanode.properties
@@ -199,7 +199,7 @@ dn_seed_config_node=127.0.0.1:10710
# Note: If wal_dirs is assigned an empty string(i.e.,zero-size), it will be
handled as a relative path.
# For windows platform
# If its prefix is a drive specifier followed by "\\", or if its prefix is
"\\\\", then the path is absolute. Otherwise, it is relative.
-dn_wal_dirs=data\\datanode\\wal
+# dn_wal_dirs=data\\datanode\\wal
# For Linux platform
# If its prefix is "/", then the path is absolute. Otherwise, it is relative.
# dn_wal_dirs=data/datanode/wal
