[incubator-iotdb] branch master updated: Set inferType of MQTT InsertPlan to true (#1291)

[sunzesong]

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

sunzesong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new ae49a78  Set inferType of MQTT InsertPlan to true (#1291)
ae49a78 is described below

commit ae49a78155d810c9491880f0fff24a9631a284aa
Author: Zesong Sun <sz...@mails.tsinghua.edu.cn>
AuthorDate: Sat May 30 17:32:59 2020 +0800

    Set inferType of MQTT InsertPlan to true (#1291)
    
    * Set inferType of mqtt Insertplan to true
    
    * Set values and types
---
 server/src/main/java/org/apache/iotdb/db/mqtt/PublishHandler.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/server/src/main/java/org/apache/iotdb/db/mqtt/PublishHandler.java 
b/server/src/main/java/org/apache/iotdb/db/mqtt/PublishHandler.java
index 4020901..241d0b1 100644
--- a/server/src/main/java/org/apache/iotdb/db/mqtt/PublishHandler.java
+++ b/server/src/main/java/org/apache/iotdb/db/mqtt/PublishHandler.java
@@ -30,6 +30,7 @@ import org.apache.iotdb.db.qp.executor.IPlanExecutor;
 import org.apache.iotdb.db.qp.executor.PlanExecutor;
 import org.apache.iotdb.db.qp.physical.PhysicalPlan;
 import org.apache.iotdb.db.qp.physical.crud.InsertPlan;
+import org.apache.iotdb.tsfile.file.metadata.enums.TSDataType;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -89,7 +90,9 @@ public class PublishHandler extends AbstractInterceptHandler {
             plan.setDeviceId(event.getDevice());
             plan.setTime(event.getTimestamp());
             plan.setMeasurements(event.getMeasurements().toArray(new 
String[event.getMeasurements().size()]));
-            plan.setValues(event.getValues().toArray(new 
String[event.getValues().size()]));
+            plan.setValues(event.getValues().toArray(new 
Object[event.getValues().size()]));
+            plan.setTypes(new TSDataType[event.getValues().size()]);
+            plan.setInferType(true);
 
             boolean status;
             try {