[incubator-iotdb] branch refactor_filenode2 updated: add QueryDataFromUnclosedTsFile IT

[hxd]

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

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


The following commit(s) were added to refs/heads/refactor_filenode2 by this 
push:
     new 26225d6  add QueryDataFromUnclosedTsFile IT
26225d6 is described below

commit 26225d65ad87f03dce29f8a9d145ba2516e12fd6
Author: xiangdong huang <saint...@gmail.com>
AuthorDate: Sun Mar 10 21:48:53 2019 +0800

    add QueryDataFromUnclosedTsFile IT
---
 .../iotdb/db/integration/QueryDataFromUnclosedTsFileIT.java  | 12 +++++++-----
 1 file changed, 7 insertions(+), 5 deletions(-)

diff --git 
a/iotdb/src/test/java/org/apache/iotdb/db/integration/QueryDataFromUnclosedTsFileIT.java
 
b/iotdb/src/test/java/org/apache/iotdb/db/integration/QueryDataFromUnclosedTsFileIT.java
index c01737a..d225e9e 100644
--- 
a/iotdb/src/test/java/org/apache/iotdb/db/integration/QueryDataFromUnclosedTsFileIT.java
+++ 
b/iotdb/src/test/java/org/apache/iotdb/db/integration/QueryDataFromUnclosedTsFileIT.java
@@ -28,6 +28,7 @@ import org.apache.iotdb.db.conf.IoTDBDescriptor;
 import org.apache.iotdb.db.engine.filenode.FileNodeManager;
 import org.apache.iotdb.db.engine.querycontext.QueryDataSource;
 import org.apache.iotdb.db.exception.FileNodeManagerException;
+import org.apache.iotdb.db.exception.MetadataArgsErrorException;
 import org.apache.iotdb.db.exception.PathErrorException;
 import org.apache.iotdb.db.metadata.MManager;
 import org.apache.iotdb.db.postback.sender.FileManager;
@@ -69,17 +70,19 @@ public class QueryDataFromUnclosedTsFileIT {
   public void tearDown() throws FileNodeManagerException, IOException {
     IoTDBDescriptor.getInstance().getConfig().bufferwriteFileSizeThreshold = 
bufferWriteFileSize;
     System.out.println(bufferWriteFileSize);
-    sgManager.deleteAll();
-    mManager.clear();
+    //sgManager.deleteAll();
+    //mManager.clear();
     EnvironmentUtils.cleanEnv();
 
   }
 
   @Test
-  public void test() throws FileNodeManagerException, IOException, 
PathErrorException {
+  public void test()
+      throws FileNodeManagerException, IOException, PathErrorException, 
MetadataArgsErrorException {
     //Path path, TSDataType dataType, TSEncoding encoding, CompressionType 
compressor,
       //  Map<String, String> props
     mManager.setStorageLevelToMTree("root.test");
+    mManager.addPathToMTree("root.test.d1.s1",  TSDataType.INT32, 
TSEncoding.RLE, CompressionType.SNAPPY, Collections.emptyMap());
     sgManager.addTimeSeries(new Path("root.test.d1", "s1"), TSDataType.INT32, 
TSEncoding.RLE, CompressionType.SNAPPY, Collections
         .emptyMap());
     for (int i=0; i < 100; i++) {
@@ -90,8 +93,7 @@ public class QueryDataFromUnclosedTsFileIT {
     QueryDataSet result = queryManager.query(qe);
     while (result.hasNext()) {
       RowRecord record = result.next();
-      System.out.println(record.getTimestamp() + 
record.getFields().get(0).getIntV());
-
+      System.out.println(record.getTimestamp() +"," + 
record.getFields().get(0).getIntV());
     }
 
   }