This is an automated email from the ASF dual-hosted git repository.
xuekaifeng pushed a change to branch virtual_partition
in repository https://gitbox.apache.org/repos/asf/iotdb.git.
from 2deea20 forbidden set ttl
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)
new 52e00d7 Merge branch 'master' of https://github.com/apache/iotdb into
virtual_partition
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
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 | 37 +-
.../engine/compaction/utils/CompactionUtils.java | 21 +-
.../engine/storagegroup/StorageGroupProcessor.java | 9 +-
.../db/engine/storagegroup/TsFileProcessor.java | 16 +-
...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/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 +-
32 files changed, 656 insertions(+), 88 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
