This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/TableModelGrammar
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 36e49f2331d Table model ingestion
new 9dd02e819a3 load-tsfile: Avoid request redirection caused by
SessionPool param enableAutoFetch = true (#12894)
new 07a6d1f7566 Subscription: deduplicate tsfile event before prefetching
(#12887)
new 63d303d0d75 Optimize the error msg while encountering memory not
enough exception
new e2b1bb5572f Allow inserting negative timestamp type of value
new 604e30e2486 Limit the row count of a single TVList to
avg_series_point_number_threshold (#12898)
new 85e829177e8 Add count and time statistics for timeseries metadata
modification
new c12cf6d31e2 Pipe Plugin: Pipe Task Safe Deletion, Plugin Directory
Structure Reorganization, and Isolated Pipe Plugin ClassLoader Implementation
(#12868)
new 7b95e1318c8 Fix the comment of float_precision (#12905)
new b8ef640bb4b Load: Fix multi dir strategy applying on loadTsFileDirs
(#12903)
new 3411b72f118 Consider TTL of device in Region scan for active data
new b6247278705 Extend fucntion of EXPLAIN ANALYZE
new 21a8a77a301 Insertion compaction may cause new data lost (#12908)
new 890f04aa529 avoid restart failure when procedure is timeout (#12897)
new f8eed36b185 Fix IndexController visibility issues in concurrency #12911
new 7931cecd002 Pipe: Introduce counter to reduce historical data buildup
in PipeRealtimePriorityBlockingQueue (#12881)
new b8c97cf0ac8 Pipe/Subscription: use heartbeat only extractor if enable
snapshot mode (#12904)
new c0b309cfc7f Fix Unseq data can't update the seq data bug (#12918)
new 0e91323bab1 Perfect the print result of dispatch and timeseries
metadata modification in explain analyze
new b02b8891d27 Perfect impl of dispatch cost in ExplainAnalyze
new 576f0e483e4 Subscription: improve tsfile event deduplication & fix
some minor concurrency-related issues (#12915)
new 632d5fbe78a Pipe: Fix async client returning self too early when
downgrade from handshake v2 to v1 (#12913)
new a07f6425d98 Fixed the bug that fetchSeriesSchema returns series in
black list when the given pattern tree is without wildcards
new 8c0a7e64366 Pipe/Subscription: Update the way SubscriptionCoordinator
and PipeTaskCoordinator acquire locks to prevent procedure success without any
effect (#12909)
new bb514a14eb8 Use max bytes to allocate WAL compressed buffer (#12928)
new c366a247ec5 PipeConsensus: Avoid pipe task being restarted frequently
by Pipe framework (#12931)
new ecd7b86ec74 Optimized DeleteTimeSeriesProcedure not to set mods when
the deleted time series are all views
new 095b2af9f8b Fix uncaught IllegalArgumentException when reading broken
WAL files (#12912)
new 96a589c7cac Do not remove top-level load dir after load & add retry
for getting disk space (#12920)
new 04ef0cc056d Fix python client dependency issue (#12934)
new a0474ca0e74 Support new dataType in select into clause and fill clause
new bfb5c4a524a fix compression ratio warn log (#12936)
new 58f333cc8e3 PipeConsensus: Fix leader write points metric (#12933)
new df133792049 Reduce default mod file threshold for settle compaction
(#12935)
new 0f4e4976919 Subscription: improve end-to-end latency (#12925)
new 7e41c81c05e Subscription: avoid invalidating cache for null response &
improve exception message (#12939)
new 3b3cdb97a24 Skip compiling cpp test code when using -DskipTests
(#12944)
new a8758cde8bc Update dockerfile to use java 17 (#12948)
new d31075986ab Cherry pick Partite Graph Replication #12946
new af17fc9e751 Fix PointPriorityReader compare PointElement (#12945)
new 317e62270e9 Upgrade thrift plugin and optimize codegen for go client
(#12949)
new 9af38c3b3b7 Fix flush error due to compression ratio (#12953)
new 15c6edee952 Pipe: Fixed the bug that historical alias/attributes/tags
may not be transferred in meta pipe when the time series already exists in
receiver & create timeseries non idempotent in PBTree
new 2e2dc91d2ff Bump jline version to 3.26.2 (#12956)
new 2f5dc67f456 Pipe: support alter pipe source (#12932)
new 80a673d90fc Fixed the bug that some schema IT does not run in PBTree
mode
new 18dd6f84e3d Fix sync stuck problem of IoTConsensus and WAL (#12955)
new aadc6fca4ee Remove warning log when CheckPointManager find memtable id
= -1 #12959
new ebbc5a0ea59 Pipe: filter out databases whose name starts with
`root.__system.` (#12957)
new cc4f03f342e Modify the default parameters of DataNode to accelerated
startup #12941
new 31730dbbea8 PipeConsensus: Fix circular replicate in kill -9/restart
cases (#12937)
new f5972a24525 Fixed issue where the wal version kept increasing after
the write load stopped (#12960)
new 175c0e90b51 Enhance the automatic metadata creation logic of
root.__system prefixed devices #12962
new 618e9107104 upgrade thrift maven plugin for cpp client (#12964)
new fd6f14e15dc Export Data And Schema: filter out databases whose name
starts with root.__system. (#12963)
new 6a155246706 Wraps DateTimeUtilsTest in a session (#12971)
new ae5c3b833f8 Remove verbose download log spam from CI builds (#12972)
new 126719722f7 Fixed potential NPE in local write execution & Refactored
queryTerminator
new 21711a615e4 fix CompactionTaskManager ut (#12923)
new efb859c01f4 Optimize log for broken wal. (#12977)
new 8094e3627e9 Clear storage engine snapshot after region migration
(#12975)
new 2726627cd27 Subscription: fix the issue with nodeUrls parameter being
ineffective & missing return for create topic (#12974)
The 61 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:
.github/workflows/cluster-it-1c1d.yml | 1 +
.github/workflows/cluster-it-1c3d.yml | 1 +
.github/workflows/daily-it.yml | 1 +
.github/workflows/multi-language-client.yml | 20 +-
.github/workflows/pipe-it-2cluster.yml | 1 +
.github/workflows/sonar-codecov.yml | 1 +
.github/workflows/unit-test.yml | 1 +
docker/src/main/DockerCompose/do-docker-build.sh | 4 +-
docker/src/main/Dockerfile-0.10.1 | 39 --
docker/src/main/Dockerfile-0.11.4 | 41 --
docker/src/main/Dockerfile-0.12.6-cluster | 53 ---
docker/src/main/Dockerfile-0.12.6-node | 45 ---
docker/src/main/Dockerfile-0.13.0-cluster | 53 ---
docker/src/main/Dockerfile-0.13.3-node | 45 ---
.../src/main/Dockerfile-0.13.3-node-multi-platform | 45 ---
docker/src/main/Dockerfile-0.8.1 | 40 --
docker/src/main/Dockerfile-0.9.1 | 41 --
docker/src/main/Dockerfile-0.9.1-jre8 | 41 --
docker/src/main/Dockerfile-1.0.0-confignode | 2 +-
docker/src/main/Dockerfile-1.0.0-datanode | 2 +-
docker/src/main/Dockerfile-1.0.0-standalone | 2 +-
docker/src/main/Dockerfile-1c1d | 2 +-
.../it/env/cluster/config/MppCommonConfig.java | 6 +
.../env/cluster/config/MppSharedCommonConfig.java | 7 +
.../it/env/remote/config/RemoteCommonConfig.java | 5 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 2 +
...trangePathIT.java => IoTDBDuplicateTimeIT.java} | 42 +-
.../apache/iotdb/db/it/IoTDBInsertWithQueryIT.java | 34 ++
.../db/it/fill/IoTDBFillWithNewDataTypeIT.java | 145 +++++++
.../apache/iotdb/db/it/schema/IoTDBTagAlterIT.java | 1 +
.../org/apache/iotdb/db/it/schema/IoTDBTagIT.java | 1 +
.../apache/iotdb/db/it/schema/IoTDBTagLimitIT.java | 15 +-
.../it/schema/quota/IoTDBClusterDeviceQuotaIT.java | 3 +-
.../db/it/schema/quota/IoTDBClusterQuotaIT.java | 1 +
.../schema/regionscan/IoTDBActiveRegionScanIT.java | 21 +-
.../regionscan/IoTDBActiveRegionScanIT2.java | 15 +-
.../IoTDBActiveRegionScanWithModsIT.java | 25 +-
.../IoTDBActiveRegionScanWithModsIT2.java | 15 +-
.../regionscan/IoTDBActiveRegionScanWithTTLIT.java | 137 +++++++
.../iotdb/db/it/selectinto/IoTDBSelectInto2IT.java | 3 +-
.../iotdb/db/it/selectinto/IoTDBSelectInto3IT.java | 3 +-
.../iotdb/db/it/selectinto/IoTDBSelectIntoIT.java | 56 ++-
.../iotdb/pipe/it/autocreate/IoTDBPipeAlterIT.java | 183 ++++++++-
.../pipe/it/autocreate/IoTDBPipeIdempotentIT.java | 84 ++--
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 22 +-
.../session/it/IoTDBSessionSchemaTemplateIT.java | 4 +-
.../it/dual/IoTDBSubscriptionTopicIT.java | 15 +-
.../it/local/IoTDBSubscriptionBasicIT.java | 96 ++++-
.../org/apache/iotdb/util/AbstractSchemaIT.java | 15 +-
.../java/org/apache/iotdb/tool/ExportData.java | 6 +-
.../java/org/apache/iotdb/tool/ExportSchema.java | 2 +-
.../java/org/apache/iotdb/tool/ImportTsFile.java | 12 +-
iotdb-client/client-cpp/pom.xml | 32 +-
iotdb-client/client-py/pom.xml | 7 +
.../java/org/apache/iotdb/rpc/TSStatusCode.java | 1 +
.../rpc/subscription/config/ConsumerConstant.java | 3 +-
.../subscription/payload/poll/TabletsPayload.java | 5 +-
.../session/subscription/SubscriptionSession.java | 1 +
.../consumer/SubscriptionConsumer.java | 29 +-
.../consumer/SubscriptionPushConsumer.java | 6 +-
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 8 +
.../manager/load/balancer/RegionBalancer.java | 7 +-
...artiteGraphReplicationRegionGroupAllocator.java | 256 ++++++++++++
.../runtime/PipeLeaderChangeHandler.java | 5 +-
.../pipe/coordinator/task/PipeTaskCoordinator.java | 22 +-
.../coordinator/task/PipeTaskCoordinatorLock.java | 2 +-
.../pipe/extractor/ConfigRegionListeningQueue.java | 25 +-
.../subscription/SubscriptionCoordinator.java | 18 +-
.../persistence/pipe/PipePluginInfo.java | 32 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 73 ++++
.../impl/pipe/AbstractOperatePipeProcedureV2.java | 16 +-
.../impl/pipe/plugin/DropPipePluginProcedure.java | 18 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 12 +
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 12 +
.../impl/pipe/task/AlterPipeProcedureV2.java | 58 ++-
.../impl/pipe/task/CreatePipeProcedureV2.java | 4 +-
.../impl/schema/DeleteTimeSeriesProcedure.java | 152 +++----
.../AbstractOperateSubscriptionProcedure.java | 16 +-
.../runtime/ConsumerGroupMetaSyncProcedure.java | 12 +
...bstractOperateSubscriptionAndPipeProcedure.java | 6 +-
.../topic/runtime/TopicMetaSyncProcedure.java | 12 +
.../procedure/store/ProcedureFactory.java | 5 +-
.../confignode/procedure/store/ProcedureType.java | 1 +
.../ConfigRegionListeningQueueTest.java | 13 +-
.../impl/pipe/task/AlterPipeProcedureV2Test.java | 10 +-
...reV2Test.java => AlterPipeProcedureV3Test.java} | 19 +-
.../org/apache/iotdb/consensus/IStateMachine.java | 9 +
.../consensus/iot/IoTConsensusServerImpl.java | 1 +
.../consensus/iot/log/ConsensusReqReader.java | 2 +-
.../iot/logdispatcher/IndexController.java | 41 +-
.../apache/iotdb/consensus/pipe/PipeConsensus.java | 47 ++-
.../consensus/pipe/PipeConsensusServerImpl.java | 39 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 16 +-
.../dataregion/DataExecutionVisitor.java | 6 +
.../dataregion/DataRegionStateMachine.java | 14 +-
.../schemaregion/SchemaExecutionVisitor.java | 168 +++++---
.../pipe/agent/plugin/PipeDataNodePluginAgent.java | 35 +-
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 8 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 71 ++--
.../pipeconsensus/PipeConsensusAsyncConnector.java | 8 +-
.../async/IoTDBDataRegionAsyncConnector.java | 6 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 7 +
.../dataregion/IoTDBDataRegionExtractor.java | 27 +-
.../PipeHistoricalDataRegionTsFileExtractor.java | 6 +-
... PipeRealtimeDataRegionHeartbeatExtractor.java} | 58 +--
.../schemaregion/SchemaRegionListeningQueue.java | 22 +-
.../pipeconsensus/PipeConsensusProcessor.java | 7 +-
.../pipeconsensus/PipeConsensusReceiver.java | 3 +-
.../PipeRealtimePriorityBlockingQueue.java | 54 ++-
.../iotdb/db/protocol/client/ConfigNodeClient.java | 4 +-
.../impl/DataNodeInternalRPCServiceImpl.java | 50 ++-
.../db/queryengine/common/MPPQueryContext.java | 11 +
.../execution/executor/RegionWriteExecutor.java | 81 ++--
.../fragment/FragmentInstanceContext.java | 73 ++--
.../fragment/FragmentInstanceExecution.java | 1 +
.../execution/fragment/QueryStatistics.java | 229 +++++++++--
.../execution/load/LoadTsFileManager.java | 26 +-
.../execution/load/LoadTsFileRateLimiter.java | 2 +-
.../execution/operator/ExplainAnalyzeOperator.java | 7 +-
.../operator/process/AbstractIntoOperator.java | 12 +
.../operator/process/FilterAndProjectOperator.java | 4 +-
.../AbstractRegionScanForActiveDataUtil.java | 16 +-
.../source/ActiveDeviceRegionScanOperator.java | 4 +-
.../source/ActiveTimeSeriesRegionScanOperator.java | 3 +-
.../execution/operator/source/FileLoaderUtils.java | 100 +++--
.../source/RegionScanForActiveDeviceUtil.java | 17 +-
.../source/RegionScanForActiveTimeSeriesUtil.java | 13 +-
.../execution/operator/source/SeriesScanUtil.java | 24 +-
.../metric/SeriesScanCostMetricSet.java | 49 +++
.../analyze/cache/partition/PartitionCache.java | 20 +-
.../config/executor/ClusterConfigTaskExecutor.java | 6 +
.../db/queryengine/plan/parser/ASTVisitor.java | 13 +
.../plan/planner/LocalExecutionPlanner.java | 5 +-
.../plan/planner/OperatorTreeGenerator.java | 42 +-
.../plan/planner/plan/node/PlanNodeType.java | 2 +
.../ContinuousSameSearchIndexSeparatorNode.java} | 27 +-
.../scheduler/FragmentInstanceDispatcherImpl.java | 72 ++--
.../plan/scheduler/SimpleQueryTerminator.java | 96 ++---
.../plan/statement/literal/BooleanLiteral.java | 4 +-
.../plan/statement/literal/DoubleLiteral.java | 3 +-
.../plan/statement/literal/Literal.java | 4 +
.../plan/statement/literal/LongLiteral.java | 26 +-
.../plan/statement/literal/StringLiteral.java | 21 +-
.../metadata/pipe/AlterPipeStatement.java | 18 +
.../statement/sys/ExplainAnalyzeStatement.java | 6 +
.../FragmentInstanceStatisticsDrawer.java | 32 ++
.../statistics/QueryPlanStatistics.java | 9 +
.../schemaengine/schemaregion/ISchemaRegion.java | 20 +-
.../schemaregion/impl/SchemaRegionMemoryImpl.java | 146 ++++---
.../schemaregion/impl/SchemaRegionPBTreeImpl.java | 155 +++++---
.../mtree/impl/mem/MTreeBelowSGMemoryImpl.java | 120 +++---
.../mtree/impl/pbtree/MTreeBelowSGCachedImpl.java | 131 ++++--
.../mtree/impl/pbtree/mnode/ICachedMNode.java | 1 +
.../schemaregion/mtree/traverser/Traverser.java | 7 +
.../write/req/SchemaRegionWritePlanFactory.java | 2 +-
.../req/impl/CreateAlignedTimeSeriesPlanImpl.java | 45 ++-
.../write/req/impl/CreateTimeSeriesPlanImpl.java | 9 +
.../java/org/apache/iotdb/db/service/DataNode.java | 2 +-
.../metrics/IoTDBInternalLocalReporter.java | 1 +
.../iotdb/db/storageengine/StorageEngine.java | 6 +-
.../db/storageengine/dataregion/DataRegion.java | 34 +-
.../execute/utils/reader/PointPriorityReader.java | 12 +-
.../impl/RewriteCrossSpaceCompactionSelector.java | 75 +++-
.../utils/InsertionCompactionCandidateStatus.java} | 10 +-
.../dataregion/flush/CompressionRatio.java | 46 ++-
.../dataregion/memtable/AbstractMemTable.java | 16 +-
.../memtable/AlignedWritableMemChunk.java | 38 +-
.../dataregion/memtable/IMemTable.java | 7 +-
.../dataregion/memtable/IWritableMemChunk.java | 20 +-
.../dataregion/memtable/TsFileProcessor.java | 26 +-
.../dataregion/memtable/WritableMemChunk.java | 77 ++--
.../read/reader/chunk/DiskAlignedChunkLoader.java | 4 +-
.../read/reader/chunk/DiskChunkLoader.java | 4 +-
.../read/reader/chunk/MemAlignedChunkLoader.java | 4 +-
.../read/reader/chunk/MemChunkLoader.java | 4 +-
.../read/reader/common/PriorityMergeReader.java | 24 +-
.../dataregion/snapshot/SnapshotTaker.java | 25 ++
.../dataregion/tsfile/TsFileResource.java | 26 +-
.../dataregion/wal/buffer/AbstractWALBuffer.java | 4 +-
.../dataregion/wal/buffer/IWALBuffer.java | 4 +-
.../dataregion/wal/buffer/WALBuffer.java | 20 +-
.../dataregion/wal/buffer/WALEntry.java | 3 +
.../dataregion/wal/buffer/WALEntryType.java | 1 +
.../dataregion/wal/buffer/WALInfoEntry.java | 1 +
.../wal/checkpoint/CheckpointManager.java | 3 +-
...rException.java => BrokenWALFileException.java} | 12 +-
.../storageengine/dataregion/wal/io/LogWriter.java | 9 +-
.../dataregion/wal/io/WALMetaData.java | 64 +--
.../storageengine/dataregion/wal/io/WALWriter.java | 2 -
.../dataregion/wal/node/IWALNode.java | 4 +
.../dataregion/wal/node/WALFakeNode.java | 7 +
.../storageengine/dataregion/wal/node/WALNode.java | 17 +-
.../rescon/disk/strategy/SequenceStrategy.java | 24 +-
.../agent/SubscriptionBrokerAgent.java | 28 +-
.../agent/SubscriptionConsumerAgent.java | 12 +-
.../subscription/agent/SubscriptionTopicAgent.java | 10 +-
.../broker/SubscriptionBlockingPendingQueue.java} | 23 +-
.../db/subscription/broker/SubscriptionBroker.java | 95 +++--
.../broker/SubscriptionPrefetchingQueue.java | 72 ++--
.../broker/SubscriptionPrefetchingTabletQueue.java | 21 +-
.../broker/SubscriptionPrefetchingTsFileQueue.java | 181 +++++----
.../TsFileDeduplicationBlockingPendingQueue.java | 81 ++++
.../db/subscription/event/SubscriptionEvent.java | 18 +-
.../batch/SubscriptionPipeTabletEventBatch.java | 2 +-
.../batch/SubscriptionPipeTsFileEventBatch.java | 2 +-
.../receiver/SubscriptionReceiverV1.java | 90 +++--
.../org/apache/iotdb/db/utils/CommonUtils.java | 41 +-
.../iotdb/db/utils/TimeFilterForDeviceTTL.java | 76 ++++
.../db/utils/datastructure/AlignedTVList.java | 4 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 4 +-
.../iotdb/db/utils/datastructure/TVList.java | 6 +-
.../schemaRegion/AbstractSchemaRegionTest.java | 9 +-
.../schemaRegion/SchemaRegionAliasAndTagTest.java | 8 +-
.../schemaRegion/SchemaRegionBasicTest.java | 382 +++++++++++++-----
.../schemaRegion/SchemaRegionManagementTest.java | 4 +-
.../SchemaRegionSimpleRecoverTest.java | 135 ++++++-
.../schemaRegion/SchemaRegionTemplateTest.java | 15 +-
.../schemaRegion/SchemaRegionTestUtil.java | 52 ++-
.../schemaRegion/SchemaStatisticsTest.java | 146 +++----
.../agent/plugin/PipeDataNodePluginAgentTest.java | 39 +-
.../extractor/SchemaRegionListeningQueueTest.java | 15 +-
.../compaction/CompactionTaskManagerTest.java | 5 +-
.../InsertionCrossSpaceCompactionSelectorTest.java | 441 +--------------------
.../dataregion/flush/CompressionRatioTest.java | 36 ++
.../dataregion/wal/io/WALFileTest.java | 15 +
.../org/apache/iotdb/db/tools/MLogParserTest.java | 2 +-
.../apache/iotdb/db/utils/DateTimeUtilsTest.java | 63 +--
.../db/utils/SchemaRegionSnapshotParserTest.java | 10 +-
.../reporter/iotdb/IoTDBSessionReporter.java | 2 +-
.../conf/iotdb-system.properties.template | 7 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 32 +-
.../iotdb/commons/conf/CommonDescriptor.java | 17 +-
.../commons/executable/ExecutableManager.java | 3 +
.../pipe/agent/plugin/PipePluginConstructor.java | 14 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 16 +-
.../pipe/connector/limiter/GlobalRateLimiter.java | 2 +-
.../connector/limiter/PipeEndPointRateLimiter.java | 2 +-
.../pipe/plugin/meta/PipePluginMetaKeeper.java | 35 +-
.../service/PipePluginClassLoaderManager.java | 42 +-
.../service/PipePluginExecutableManager.java | 43 +-
.../connection/UnboundedBlockingPendingQueue.java | 2 +-
.../schema/node/role/IMeasurementMNode.java | 2 +-
.../commons/schema/node/utils/IMNodeFactory.java | 1 +
.../subscription/config/SubscriptionConfig.java | 7 +
.../org/apache/iotdb/commons/utils/IOUtils.java | 32 ++
.../apache/iotdb/commons/utils/JVMCommonUtils.java | 30 +-
.../pipe/plugin/meta/PipePluginMetaTest.java | 2 +-
.../src/main/thrift/confignode.thrift | 2 +
.../src/main/thrift/datanode.thrift | 9 +-
pom.xml | 14 +-
250 files changed, 5095 insertions(+), 2778 deletions(-)
delete mode 100644 docker/src/main/Dockerfile-0.10.1
delete mode 100644 docker/src/main/Dockerfile-0.11.4
delete mode 100644 docker/src/main/Dockerfile-0.12.6-cluster
delete mode 100644 docker/src/main/Dockerfile-0.12.6-node
delete mode 100644 docker/src/main/Dockerfile-0.13.0-cluster
delete mode 100644 docker/src/main/Dockerfile-0.13.3-node
delete mode 100644 docker/src/main/Dockerfile-0.13.3-node-multi-platform
delete mode 100644 docker/src/main/Dockerfile-0.8.1
delete mode 100644 docker/src/main/Dockerfile-0.9.1
delete mode 100644 docker/src/main/Dockerfile-0.9.1-jre8
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{strangepath/IoTDBStrangePathIT.java
=> IoTDBDuplicateTimeIT.java} (61%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/fill/IoTDBFillWithNewDataTypeIT.java
create mode 100644
integration-test/src/test/java/org/apache/iotdb/db/it/schema/regionscan/IoTDBActiveRegionScanWithTTLIT.java
create mode 100644
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/manager/load/balancer/region/PartiteGraphReplicationRegionGroupAllocator.java
copy
iotdb-core/confignode/src/test/java/org/apache/iotdb/confignode/procedure/impl/pipe/task/{AlterPipeProcedureV2Test.java
=> AlterPipeProcedureV3Test.java} (78%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/{PipeRealtimeDataRegionFakeExtractor.java
=> PipeRealtimeDataRegionHeartbeatExtractor.java} (51%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{storageengine/dataregion/wal/utils/listener/WALFlushListener.java
=>
queryengine/plan/planner/plan/node/write/ContinuousSameSearchIndexSeparatorNode.java}
(55%)
copy
iotdb-core/datanode/src/{test/java/org/apache/iotdb/db/storageengine/dataregion/compaction/utils/CompactionTimeseriesType.java
=>
main/java/org/apache/iotdb/db/storageengine/dataregion/compaction/selector/utils/InsertionCompactionCandidateStatus.java}
(89%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/wal/exception/{WALRecoverException.java
=> BrokenWALFileException.java} (78%)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/{pipe/event/common/watermark/PipeWatermarkEvent.java
=> subscription/broker/SubscriptionBlockingPendingQueue.java} (59%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/subscription/broker/TsFileDeduplicationBlockingPendingQueue.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/TimeFilterForDeviceTTL.java
