[iotdb] branch improve_wal updated: fix unset datatypes

[jiangtian]

This is an automated email from the ASF dual-hosted git repository.

jiangtian pushed a commit to branch improve_wal
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/improve_wal by this push:
     new f60f1a0  fix unset datatypes
f60f1a0 is described below

commit f60f1a0af48172d3fc65a4900990ff6bf8a38fc8
Author: jt <jt2594...@163.com>
AuthorDate: Mon Oct 12 20:37:31 2020 +0800

    fix unset datatypes
---
 server/src/main/java/org/apache/iotdb/db/utils/CommonUtils.java         | 2 ++
 .../org/apache/iotdb/db/writelog/node/DifferentialWriteLogNode.java     | 2 +-
 2 files changed, 3 insertions(+), 1 deletion(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/utils/CommonUtils.java 
b/server/src/main/java/org/apache/iotdb/db/utils/CommonUtils.java
index 4fa0e96..542252f 100644
--- a/server/src/main/java/org/apache/iotdb/db/utils/CommonUtils.java
+++ b/server/src/main/java/org/apache/iotdb/db/utils/CommonUtils.java
@@ -154,10 +154,12 @@ public class CommonUtils {
       InsertRowPlan insertRowPlan = (InsertRowPlan) plan;
       plan = new InsertRowPlan(insertRowPlan.getDeviceId(),
           insertRowPlan.getTime(), insertRowPlan.getMeasurements(), null);
+      ((InsertRowPlan) plan).setDataTypes(insertRowPlan.getDataTypes());
     } else if (plan instanceof InsertTabletPlan) {
       InsertTabletPlan insertTabletPlan = (InsertTabletPlan) plan;
       plan = new InsertTabletPlan(insertTabletPlan.getDeviceId(),
           insertTabletPlan.getMeasurements());
+      ((InsertTabletPlan) plan).setDataTypes(insertTabletPlan.getDataTypes());
     }
     planWindow.add(plan);
   }
diff --git 
a/server/src/main/java/org/apache/iotdb/db/writelog/node/DifferentialWriteLogNode.java
 
b/server/src/main/java/org/apache/iotdb/db/writelog/node/DifferentialWriteLogNode.java
index 6b47cea..7a70c31 100644
--- 
a/server/src/main/java/org/apache/iotdb/db/writelog/node/DifferentialWriteLogNode.java
+++ 
b/server/src/main/java/org/apache/iotdb/db/writelog/node/DifferentialWriteLogNode.java
@@ -41,7 +41,7 @@ public class DifferentialWriteLogNode extends 
ExclusiveWriteLogNode {
 
   private static final Logger logger = 
LoggerFactory.getLogger(DifferentialWriteLogNode.class);
   // TODO: make WINDOW_LENGTH a config
-  public static final int WINDOW_LENGTH = 100;
+  public static final int WINDOW_LENGTH = 2000;
   private Queue<PhysicalPlan> planWindow;
 
   /**