[incubator-iotdb] branch IOTDB-615-Use-binary-rather-than-string-in-insert-plan updated: fix bug

[xuekaifeng]

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

xuekaifeng pushed a commit to branch 
IOTDB-615-Use-binary-rather-than-string-in-insert-plan
in repository https://gitbox.apache.org/repos/asf/incubator-iotdb.git


The following commit(s) were added to 
refs/heads/IOTDB-615-Use-binary-rather-than-string-in-insert-plan by this push:
     new 783fa4f  fix bug
783fa4f is described below

commit 783fa4f9940a6d48946f4806a36186fa0dd4d510
Author: 151250176 <151250...@smail.nju.edu.cn>
AuthorDate: Wed May 20 08:22:43 2020 +0800

    fix bug
---
 .../apache/iotdb/flink/DefaultIoTSerializationSchemaTest.java | 11 ++++++-----
 1 file changed, 6 insertions(+), 5 deletions(-)

diff --git 
a/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/DefaultIoTSerializationSchemaTest.java
 
b/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/DefaultIoTSerializationSchemaTest.java
index efb5a34..8e696e4 100644
--- 
a/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/DefaultIoTSerializationSchemaTest.java
+++ 
b/flink-iotdb-connector/src/test/java/org/apache/iotdb/flink/DefaultIoTSerializationSchemaTest.java
@@ -18,13 +18,12 @@
 
 package org.apache.iotdb.flink;
 
-import com.google.common.collect.Lists;
-import org.junit.Test;
+import static org.junit.Assert.assertEquals;
 
+import com.google.common.collect.Lists;
 import java.util.HashMap;
 import java.util.Map;
-
-import static org.junit.Assert.*;
+import org.junit.Test;
 
 public class DefaultIoTSerializationSchemaTest {
 
@@ -38,12 +37,14 @@ public class DefaultIoTSerializationSchemaTest {
         tuple.put("device", "root.sg.D01");
         tuple.put("timestamp", "1581861293000");
         tuple.put("measurements", "temperature");
+        tuple.put("types", "DOUBLE");
         tuple.put("values", "36.5");
 
         Event event = serializationSchema.serialize(tuple);
         assertEquals(tuple.get("device"), event.getDevice());
         assertEquals(tuple.get("timestamp"), 
String.valueOf(event.getTimestamp()));
         assertEquals(tuple.get("measurements"), 
event.getMeasurements().get(0));
-        assertEquals(tuple.get("values"), event.getValues().get(0));
+        assertEquals(tuple.get("types"), event.getTypes().get(0).toString());
+        assertEquals(tuple.get("values"), 
String.valueOf(event.getValues().get(0)));
     }
 }