add error log in flush timeseries data

src/main/java/cn/edu/tsinghua/tsfile/common/utils/ListByteArrayOutputStream.java

@@ -1,6 +1,5 @@
 package cn.edu.tsinghua.tsfile.common.utils;
 
-import java.io.ByteArrayInputStream;
 import java.io.IOException;
 import java.io.OutputStream;
 import java.util.ArrayList;
@@ -86,17 +85,4 @@ public void reset() {
         list.clear();
         totalSize = 0;
     }
-
-    /**
-     * transform all {@link PublicBAOS} to list of {@link ByteArrayInputStream}
-     *
-     * @return a list of {@link ByteArrayInputStream} contain all page data
-     */
-    public List<ByteArrayInputStream> transform() {
-        List<ByteArrayInputStream> ret = new ArrayList<>();
-        for (PublicBAOS baos : list) {
-            ret.add(baos.transformToInputStream());
-        }
-        return ret;
-    }
 }

src/main/java/cn/edu/tsinghua/tsfile/timeseries/readV2/datatype/Test.java

@@ -0,0 +1,10 @@
+package cn.edu.tsinghua.tsfile.timeseries.readV2.datatype;
+
+public class Test {
+
+	public static void main(String[] args) {
+		// TODO Auto-generated method stub
+		new TsPrimitiveType.TsBoolean(false);
+	}
+
+}

src/main/java/cn/edu/tsinghua/tsfile/timeseries/write/page/IPageWriter.java

@@ -33,13 +33,6 @@ public interface IPageWriter {
     void writePage(ListByteArrayOutputStream listByteArray, int valueCount, Statistics<?> statistics,
                    long maxTimestamp, long minTimestamp) throws PageException;
 
-    /**
-     * query all pages which have been packaged
-     *
-     * @return left is all pages data, right is the name of compression
-     */
-    Pair<List<ByteArrayInputStream>, CompressionTypeName> query();
-
     /**
      * write the page to specified IOWriter
      *

src/main/java/cn/edu/tsinghua/tsfile/timeseries/write/page/PageWriterImpl.java

@@ -44,6 +44,9 @@ public void writePage(ListByteArrayOutputStream listByteArray, int valueCount, S
         // compress the input data
         if (this.minTimestamp == -1)
             this.minTimestamp = minTimestamp;
+        if(this.minTimestamp==-1){
+        	LOG.error("Write page error, {}, minTime:{}, maxTime:{}",desc,minTimestamp,maxTimestamp);
+        }
         this.maxTimestamp = maxTimestamp;
         int uncompressedSize = listByteArray.size();
         ListByteArrayOutputStream compressedBytes = compressor.compress(listByteArray);
@@ -76,22 +79,16 @@ public void writePage(ListByteArrayOutputStream listByteArray, int valueCount, S
                 estimateMaxPageMemSize());
     }
 
-    public Pair<List<ByteArrayInputStream>, CompressionTypeName> query() {
-
-
-        List<ByteArrayInputStream> backupPageList = buf.transform();
-        Pair<List<ByteArrayInputStream>, CompressionTypeName> ret = new Pair<List<ByteArrayInputStream>, CompressionTypeName>(
-                backupPageList, compressor.getCodecName());
-        return ret;
-    }
-
     private void resetTimeStamp() {
         if (totalValueCount == 0)
             minTimestamp = -1;
     }
 
     @Override
     public void writeToFileWriter(TsFileIOWriter writer, Statistics<?> statistics) throws IOException {
+    	if(minTimestamp==-1){
+    		LOG.error("Write page error, {}, minTime:{}, maxTime:{}",desc,minTimestamp,maxTimestamp);
+    	}
         writer.startSeries(desc, compressor.getCodecName(), desc.getType(), statistics, maxTimestamp, minTimestamp);
         long totalByteSize = writer.getPos();
         writer.writeBytesToStream(buf);