This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch cluster_new
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 0736499 Merge pull request #2189 from
apache/cluster_configuration_consensus
add 20fed99 [IOTDB-1035] Add test for ReadChunkMetadataInDevice (#2157)
add 581d34f fix flink iotdb example for writing data with incorrect data
types (#2181)
add 605a752 fix when one row failed, then insertRecords() does not clear
the failed messages (#2191)
add c411218 IOTDB-1039 hive-connector mvn failed
add e652563 [ISSUE-2187] Fix compaction encoding bug after
deserialization merge (#2188)
add a521f7f change mem control lock usage (#2153)
add 12fe408 Fix desc batchdata count bug (#2186)
add c311192 Merge branch 'master' into cluster_new
add ff06133 fix reviews
No new revisions were added by this update.
Summary of changes:
example/flink/pom.xml | 25 ++
.../org/apache/iotdb/flink/FlinkIoTDBSink.java | 17 +-
hive-connector/pom.xml | 4 +
pom.xml | 1 +
.../resources/conf/iotdb-engine.properties | 7 +
.../org/apache/iotdb/db/engine/StorageEngine.java | 5 +-
.../engine/compaction/utils/CompactionUtils.java | 21 +-
.../engine/storagegroup/StorageGroupProcessor.java | 9 +-
.../db/engine/storagegroup/TsFileProcessor.java | 16 +-
.../db/engine/storagegroup/TsFileResource.java | 3 -
...ption.java => WriteProcessRejectException.java} | 14 +-
.../iotdb/db/query/reader/chunk/MemPageReader.java | 2 +-
.../iotdb/db/query/reader/series/SeriesReader.java | 4 +-
.../org/apache/iotdb/db/rescon/SystemInfo.java | 37 +-
.../org/apache/iotdb/db/service/TSServiceImpl.java | 3 +-
.../iotdb/db/tools/TsFileResourcePrinter.java | 2 +-
.../iotdb/db/integration/IOTDBGroupByIT.java | 5 +
.../iotdb/db/integration/IoTDBAggregationIT.java | 5 +
.../integration/IoTDBAggregationLargeDataIT.java | 5 +
.../integration/IoTDBAggregationSmallDataIT.java | 7 +-
.../iotdb/db/integration/IoTDBAlignByDeviceIT.java | 7 +-
.../iotdb/db/integration/IoTDBCompactionIT.java | 55 +++
.../iotdb/db/integration/IoTDBLargeDataIT.java | 5 +
.../IoTDBMultiOverlappedChunkInUnseqIT.java | 5 +
.../db/integration/IoTDBMultiOverlappedPageIT.java | 5 +
.../iotdb/db/integration/IoTDBMultiSeriesIT.java | 5 +
.../db/integration/IoTDBMultiStatementsIT.java | 5 +
.../db/integration/IoTDBOverlappedPageIT.java | 5 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../apache/iotdb/tsfile/read/common/BatchData.java | 35 +-
.../iotdb/tsfile/read/common/BatchDataFactory.java | 7 +-
.../{DescBatchData.java => DescReadBatchData.java} | 14 +-
.../tsfile/read/common/DescReadWriteBatchData.java | 374 +++++++++++++++++++++
.../iotdb/tsfile/read/reader/page/PageReader.java | 2 +-
.../tsfile/read/TsFileSequenceReaderTest.java | 41 ++-
35 files changed, 666 insertions(+), 92 deletions(-)
copy
server/src/main/java/org/apache/iotdb/db/exception/{LoadFileException.java =>
WriteProcessRejectException.java} (70%)
rename
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/{DescBatchData.java =>
DescReadBatchData.java} (84%)
create mode 100644
tsfile/src/main/java/org/apache/iotdb/tsfile/read/common/DescReadWriteBatchData.java
