This is an automated email from the ASF dual-hosted git repository.
jiangtian pushed a change to branch force_ci/alter_column_datatype
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from e9b50895d1d fix it
add 9e973b751cf Fix IoTConsensus safe deleted index (#14883)
add adba099046c Pipe: bind memory block for PipeTransferTsFileHandler and
PipeInsertNodeTabletInsertionEvent & unify the memory threshold judgment for
tablet and tsfile block & close data container when internally decrease
reference count of PipeTsFileInsertionEvent (#14873)
add 85f85cec61d Pipe: Optimize the data logic of distinguishing table
model and tree model (#14803)
add f8082c651aa Pipe: Reduce degrade log from
PipeRealtimeDataRegionHybridExtractor (#14888)
add 2964bd20079 Pipe: Fixed the bug that the create/delete database cannot
be passed to the receiver & SchemaRegionSnapshot parsing failure & The
historical table/databases cannot be transferred & The class cast exception at
receiver (#14876)
add 7883265abcc Fix the incorrect configuration of the JAVA_HOME
environment variable in script." (#14893)
add 4e0ecc24541 Add Date and Float data IT (#14892)
add 4aadc09fb20 Fix IoTConsensus safe deleted index again (#14897)
add 7b588c81b17 Pipe: fix threshold judgment for tablet and tsfile memory
block & Subscription: close data container for current PipeTsFileInsertionEvent
in batch (#14901)
add 897e989261d Fixed the bug that procedure rollback may generate NPE &&
some of the rollback steps may not be / be extra executed (#14871)
add 065a58d68bd Subscription: add methods to obtain the consumer
identifier in the top-level interface (#14904)
add 8760e10b796 Pipe: Avoid stuck in insertion process because failed to
allocate memory (#14899)
add 8e4fef3b8f0 Update dockerfile to use the latest ubuntu 24 (#14903)
add 7615222e8fe Subscription: close memory block for previous tsfile
response (#14909)
add b8438dd0165 Add connection_time_out_in_ms for Python SDK (#14898)
add 43ed88f4909 Allow to write time column only (#14703)
add 9a93a0e29f1 Reject inserting invalid timestamp string (#14913)
add 547e7f6f6b8 Initialize WALNode when DataRegion is created for iotv1
and iotv2 (#14918)
add 85326097340 Memtable enhancement for query (#14591)
add 481a79d3c14 Fix that failure of one row in relational InsertRows will
fail other rows (#14912)
add b498285c4f4 Pipe: Modify MaxAllowedPinnedMemTableCount to adapt to
changes in the number of DRs & Modify the implementation of the poll method in
PipeRealtimePriorityBlockingQueue to reduce commit queue backlog & Adjust the
default thread count related to Pipe for better performance & Significantly
reduce pipeMemoryAllocateRetryIntervalMs & Provide a switch for memory control
of ConnectorReadFileBuffer (#14917)
add 650bbcc25f7 [RTO/RPO] Unify retry logic on SessionConnection (#14894)
add 61576c0a5bc Implemented JDBC for IoTDB based on tables
add 083ae4858fa Fix IT names & Fix region operation related IT (#14905)
add 4d965e9d6ec Don't log known error's exception thread stack
add 6b5e5b00e4c [To Master] MQTT Extensions to the Table Model Using the
Row Protocol (#14848)
add babc2af50ee Replace ExportTsFile By SubscriptionTsFile (#14812)
add ca8482a7bb1 Improve authority control of cluster management (#14924)
add 69a4eb2897b Subscription: avoid null pointer exception when get
current response due to concurrent operations (#14926)
add 82624e21d5f Load: auto detect TsFile's model (tree/table) (#14751)
add 4866f6d2cfa Add logs for PartitionTableAutoCleaner (#14934)
add 57ce941d889 Load: Add mods file metrics count (#14930)
add a864d9fabc4 Fix class name of RPCServiceMBean #14940
add bb8a5f74356 Pipe: Fix the protential resource leak issue of async
client when async manager is closed (#14929)
add 72dd41d62ed Pipe: Add memory control mechanism for TsFile batch mode
in sinks (#14911)
add 9733c7540cf Delete remove node logic in ServerCommandLine #14933
add ab2ab36fa7d Subscription: check if all topic messages have been
consumed when client polling (#14937)
add aeeec751511 Merge branch 'master' into force_ci/alter_column_datatype
No new revisions were added by this update.
Summary of changes:
docker/src/main/DockerCompose/do-docker-build.sh | 4 +-
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 +-
.../server/CustomizedJsonPayloadFormatter.java | 2 +-
.../org/apache/iotdb/mqtt/server/MyMessage.java | 31 +-
.../java/org/apache/iotdb/mqtt/MQTTClient.java | 39 +-
.../java/org/apache/iotdb/CountPointProcessor.java | 3 +-
.../apache/iotdb/SubscriptionSessionExample.java | 2 +-
.../TableModelSubscriptionSessionExample.java | 16 +-
integration-test/pom.xml | 4 +
.../iotdb/it/env/cluster/ClusterConstant.java | 1 +
.../it/env/cluster/config/MppCommonConfig.java | 10 +-
.../it/env/cluster/config/MppDataNodeConfig.java | 12 +
.../env/cluster/config/MppSharedCommonConfig.java | 13 +-
.../iotdb/it/env/cluster/node/DataNodeWrapper.java | 3 +
.../it/env/remote/config/RemoteCommonConfig.java | 7 +-
.../it/env/remote/config/RemoteDataNodeConfig.java | 10 +
.../org/apache/iotdb/itbase/env/CommonConfig.java | 4 +-
.../apache/iotdb/itbase/env/DataNodeConfig.java | 4 +
.../{AbstractScript.java => AbstractScriptIT.java} | 2 +-
.../apache/iotdb/cli/it/StartClientScriptIT.java | 2 +-
....java => IoTDBAutoRegionGroupExtension2IT.java} | 4 +-
...st.java => IoTDBPartitionTableAutoCleanIT.java} | 2 +-
...IoTDBRegionOperationReliabilityITFramework.java | 72 -
.../IoTDBRegionGroupExpandAndShrinkForIoTV1IT.java | 20 +-
...IoTDBRegionMigrateNormalITForIoTV2BatchIT.java} | 2 +-
...=> IoTDBRegionMigrateOtherForIoTV2BatchIT.java} | 2 +-
... IoTDBRegionMigrateNormalForIoTV2StreamIT.java} | 2 +-
...IoTDBRegionMigrateOtherITForIoTV2StreamIT.java} | 2 +-
...rCrashWhenRemoveRemotePeerForIoTV2BatchIT.java} | 2 +-
...RegionMigrateDataNodeCrashForIoTV2BatchIT.java} | 2 +-
...alCrashWhenDeleteLocalPeerForIoTV2BatchIT.java} | 2 +-
...lCrashWhenRemoveRemotePeerForIoTV2BatchIT.java} | 2 +-
...CrashWhenRemoveRemotePeerForIoTV2StreamIT.java} | 2 +-
...egionMigrateDataNodeCrashForIoTV2StreamIT.java} | 2 +-
...lCrashWhenDeleteLocalPeerForIoTV2StreamIT.java} | 2 +-
...CrashWhenRemoveRemotePeerForIoTV2StreamIT.java} | 2 +-
...oTDBRegionMigrateClusterCrashIoTV2BatchIT.java} | 2 +-
...BRegionMigrateConfigNodeCrashIoTV2BatchIT.java} | 2 +-
...TDBRegionMigrateClusterCrashIoTV2StreamIT.java} | 2 +-
...RegionMigrateConfigNodeCrashIoTV2StreamIT.java} | 2 +-
.../apache/iotdb/db/it/IoTDBDuplicateTimeIT.java | 5 +-
.../apache/iotdb/db/it/IoTDBFloatPrecisionIT.java | 45 +
.../org/apache/iotdb/db/it/IoTDBRestartIT.java | 4 +-
.../org/apache/iotdb/db/it/IoTDBSimpleQueryIT.java | 38 +
.../org/apache/iotdb/db/it/auth/IoTDBAuthIT.java | 119 +
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 2 -
.../iotdb/db/it/groupby/IoTDBGroupByUnseqIT.java | 2 +-
.../relational/it/db/it/IoTDBInsertTableIT.java | 11 +-
.../relational/it/db/it/IoTDBRestartTableIT.java | 3 -
.../relational/it/mqtt/IoTDBMQTTServiceIT.java | 132 +
.../it/session/IoTDBSessionRelationalIT.java | 64 +
.../iotdb/session/it/IoTDBSessionSimpleIT.java | 84 +
.../regression/param/IoTDBTestParamTopicIT.java | 2 +-
.../apache/iotdb/tools/it/ExportDataTestIT.java | 4 +-
.../apache/iotdb/tools/it/ExportSchemaTestIT.java | 4 +-
.../apache/iotdb/tools/it/ExportTsFileTestIT.java | 36 +-
.../apache/iotdb/tools/it/ImportDataTestIT.java | 4 +-
.../apache/iotdb/tools/it/ImportSchemaTestIT.java | 4 +-
.../src/test/resources/logback-test.xml | 2 +-
iotdb-client/cli/pom.xml | 4 +
.../org/apache/iotdb/tool/common/Constants.java | 30 +-
.../org/apache/iotdb/tool/common/OptionsUtil.java | 112 +
.../org/apache/iotdb/tool/tsfile/ExportTsFile.java | 539 +--
.../subscription/AbstractSubscriptionTsFile.java | 74 +
.../tool/tsfile/subscription/CommonParam.java | 212 +
.../subscription/SubscriptionTableTsFile.java | 186 +
.../subscription/SubscriptionTreeTsFile.java | 183 +
iotdb-client/client-py/iotdb/Session.py | 61 +-
iotdb-client/client-py/iotdb/SessionPool.py | 4 +
iotdb-client/client-py/iotdb/table_session.py | 3 +
iotdb-client/client-py/iotdb/table_session_pool.py | 2 +
iotdb-client/jdbc/pom.xml | 55 +-
.../main/java/org/apache/iotdb/jdbc/Constant.java | 4 +-
...ata.java => IoTDBAbstractDatabaseMetadata.java} | 4330 +++++++++-----------
.../org/apache/iotdb/jdbc/IoTDBConnection.java | 26 +-
.../apache/iotdb/jdbc/IoTDBDatabaseMetadata.java | 3555 ++--------------
.../IoTDBRelationalDatabaseMetadata.java | 405 ++
.../java/org/apache/iotdb/session/Session.java | 15 +-
.../apache/iotdb/session/SessionConnection.java | 1019 ++---
.../consumer/ISubscriptionTablePullConsumer.java | 18 +
.../consumer/ISubscriptionTablePushConsumer.java | 18 +
.../consumer/ISubscriptionTreePullConsumer.java | 18 +
.../consumer/ISubscriptionTreePushConsumer.java | 18 +
.../base/AbstractSubscriptionConsumer.java | 22 +-
.../consumer/table/SubscriptionTableProvider.java | 18 +-
.../table/SubscriptionTablePullConsumer.java | 34 +-
.../table/SubscriptionTablePushConsumer.java | 36 +-
.../consumer/tree/SubscriptionTreeProvider.java | 18 +-
.../tree/SubscriptionTreePullConsumer.java | 34 +-
.../tree/SubscriptionTreePushConsumer.java | 34 +-
.../apache/iotdb/session/util/CheckedSupplier.java | 32 -
.../statemachine/ConfigRegionStateMachine.java | 6 +-
.../pipe/event/PipeConfigRegionSnapshotEvent.java | 3 +-
.../pipe/extractor/IoTDBConfigRegionExtractor.java | 8 +-
.../receiver/protocol/IoTDBConfigNodeReceiver.java | 33 +-
.../partition/DatabasePartitionTable.java | 14 +-
.../schema/CNPhysicalPlanGenerator.java | 15 +-
...otParser.java => ConfigNodeSnapshotParser.java} | 24 +-
.../procedure/PartitionTableAutoCleaner.java | 3 +
.../procedure/impl/StateMachineProcedure.java | 7 +-
.../impl/schema/AlterLogicalViewProcedure.java | 4 +-
.../iotdb/confignode/service/ConfigNode.java | 44 +-
.../consensus/iot/IoTConsensusServerImpl.java | 32 +-
.../src/assembly/resources/sbin/start-datanode.bat | 2 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 9 +
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 45 +-
.../org/apache/iotdb/db/conf/IoTDBDescriptor.java | 22 +-
.../db/pipe/agent/task/PipeDataNodeTaskAgent.java | 4 +-
.../PipeRealtimePriorityBlockingQueue.java | 8 +-
.../processor/PipeProcessorSubtaskWorker.java | 6 +-
.../client/IoTDBDataNodeAsyncClientManager.java | 4 +
.../evolvable/batch/PipeTabletEventBatch.java | 37 +-
.../evolvable/batch/PipeTabletEventPlainBatch.java | 41 +-
.../batch/PipeTabletEventTsFileBatch.java | 11 +-
.../async/IoTDBDataRegionAsyncConnector.java | 16 +-
.../handler/PipeTransferTrackableHandler.java | 33 +-
.../async/handler/PipeTransferTsFileHandler.java | 70 +-
.../db/pipe/event/common/PipeInsertionEvent.java | 64 +-
.../db/pipe/event/common/row/PipeRowCollector.java | 27 +-
.../schema/PipeSchemaRegionSnapshotEvent.java | 7 +-
.../tablet/PipeInsertNodeTabletInsertionEvent.java | 56 +-
.../common/tablet/PipeRawTabletInsertionEvent.java | 26 +-
.../common/tsfile/PipeTsFileInsertionEvent.java | 37 +-
.../query/TsFileInsertionEventQueryParser.java | 70 +-
.../scan/TsFileInsertionEventScanParser.java | 35 +-
.../table/TsFileInsertionEventTableParser.java | 70 +-
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 6 +
.../event/realtime/PipeRealtimeEventFactory.java | 12 +-
...oricalDataRegionTsFileAndDeletionExtractor.java | 10 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 8 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 55 +-
.../realtime/assigner/PipeDataRegionAssigner.java | 19 +
.../listener/PipeInsertionDataNodeListener.java | 4 +-
.../iotdb/db/pipe/metric/PipeResourceMetrics.java | 28 +
.../processor/aggregate/AggregateProcessor.java | 18 +-
.../twostage/plugin/TwoStageCountProcessor.java | 14 +-
.../protocol/thrift/IoTDBDataNodeReceiver.java | 12 +-
.../db/pipe/resource/memory/PipeMemoryManager.java | 137 +-
.../db/protocol/mqtt/JSONPayloadFormatter.java | 6 +-
.../db/protocol/mqtt/LinePayloadFormatter.java | 252 ++
.../iotdb/db/protocol/mqtt/MPPPublishHandler.java | 239 +-
.../org/apache/iotdb/db/protocol/mqtt/Message.java | 58 +-
.../iotdb/db/protocol/mqtt/TableMessage.java | 144 +
.../mqtt/{Message.java => TreeMessage.java} | 16 +-
.../db/protocol/rest/impl/PingApiServiceImpl.java | 4 +-
.../iotdb/db/protocol/session/SessionManager.java | 12 +
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../fragment/FragmentInstanceContext.java | 38 +
.../fragment/FragmentInstanceManager.java | 2 +
.../execution/fragment/QueryContext.java | 9 +
.../queryengine/plan/analyze/AnalyzeVisitor.java | 29 +-
.../plan/analyze/load/LoadTsFileAnalyzer.java | 558 ++-
.../load/LoadTsFileToTableModelAnalyzer.java | 226 -
.../load/LoadTsFileToTreeModelAnalyzer.java | 187 -
.../load/TreeSchemaAutoCreatorAndVerifier.java | 4 +-
.../analyze/schema/ClusterSchemaFetchExecutor.java | 4 +-
.../plan/planner/LogicalPlanVisitor.java | 4 +-
.../plan/planner/plan/node/write/InsertNode.java | 2 +
.../planner/plan/node/write/InsertRowNode.java | 3 +
.../plan/node/write/RelationalInsertRowNode.java | 5 +
.../node/write/RelationalInsertTabletNode.java | 8 +
.../relational/analyzer/StatementAnalyzer.java | 27 +-
.../fetcher/TableHeaderSchemaValidator.java | 4 -
.../plan/relational/planner/RelationPlanner.java | 3 +-
.../plan/relational/sql/ast/InsertRows.java | 3 +
.../plan/relational/sql/ast/LoadTsFile.java | 14 +-
.../plan/relational/sql/parser/AstBuilder.java | 3 +-
.../plan/statement/crud/InsertBaseStatement.java | 28 +-
.../plan/statement/crud/InsertRowStatement.java | 3 +
.../plan/statement/crud/LoadTsFileStatement.java | 18 +-
.../metadata/CountTimeSlotListStatement.java | 7 +
.../statement/metadata/GetRegionIdStatement.java | 7 +
.../metadata/GetSeriesSlotListStatement.java | 7 +
.../metadata/GetTimeSlotListStatement.java | 7 +
.../metadata/RemoveConfigNodeStatement.java | 9 +-
.../metadata/RemoveDataNodeStatement.java | 9 +-
.../statement/metadata/ShowClusterIdStatement.java | 7 +
.../statement/metadata/ShowClusterStatement.java | 9 +-
.../metadata/ShowConfigNodesStatement.java | 4 +-
.../statement/metadata/ShowDataNodesStatement.java | 4 +-
.../statement/metadata/ShowRegionStatement.java | 4 +-
.../metadata/model/ShowAINodesStatement.java | 7 +
.../metadata/region/ExtendRegionStatement.java | 9 +-
.../metadata/region/MigrateRegionStatement.java | 9 +-
.../region/ReconstructRegionStatement.java | 9 +-
.../metadata/region/RemoveRegionStatement.java | 9 +-
.../plan/statement/sys/KillQueryStatement.java | 9 +-
.../plan/statement/sys/ShowQueriesStatement.java | 9 +-
.../statement/sys/TestConnectionStatement.java | 3 +-
.../schemaregion/utils/ResourceByPathUtils.java | 146 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 66 +-
.../iotdb/db/service/DataNodeShutdownHook.java | 22 +-
.../{RPCService.java => ExternalRPCService.java} | 6 +-
...viceMBean.java => ExternalRPCServiceMBean.java} | 2 +-
.../org/apache/iotdb/db/service/MQTTService.java | 2 +
.../iotdb/db/service/metrics/WritingMetrics.java | 29 +-
.../iotdb/db/storageengine/StorageEngine.java | 4 +
.../db/storageengine/dataregion/DataRegion.java | 17 +-
.../dataregion/flush/MemTableFlushTask.java | 16 +-
.../dataregion/memtable/AbstractMemTable.java | 162 +-
.../memtable/AlignedReadOnlyMemChunk.java | 588 ++-
.../memtable/AlignedWritableMemChunk.java | 752 +++-
.../memtable/AlignedWritableMemChunkGroup.java | 21 +-
.../dataregion/memtable/IMemTable.java | 8 +-
.../dataregion/memtable/IWritableMemChunk.java | 56 +-
.../memtable/IWritableMemChunkGroup.java | 9 +-
.../dataregion/memtable/ReadOnlyMemChunk.java | 274 +-
.../dataregion/memtable/TsFileProcessor.java | 65 +-
.../dataregion/memtable/WritableMemChunk.java | 595 ++-
.../dataregion/memtable/WritableMemChunkGroup.java | 35 +-
.../filescan/impl/MemAlignedChunkHandleImpl.java | 21 +-
.../read/reader/chunk/MemAlignedChunkReader.java | 259 +-
.../read/reader/chunk/MemAlignedPageReader.java | 136 +-
.../read/reader/chunk/MemChunkReader.java | 139 +-
.../read/reader/chunk/MemPageReader.java | 129 +-
.../reader/chunk/metadata/AlignedPageMetadata.java | 74 +
.../read/reader/chunk/metadata/PageMetadata.java | 90 +
.../dataregion/tsfile/TsFileResource.java | 39 +-
.../load/config/LoadTsFileConfigurator.java | 24 -
.../broker/SubscriptionPrefetchingTabletQueue.java | 10 +
.../broker/SubscriptionPrefetchingTsFileQueue.java | 10 +
.../batch/SubscriptionPipeTabletEventBatch.java | 4 +
.../event/cache/SubscriptionPollResponseCache.java | 11 +
.../response/SubscriptionEventTsFileResponse.java | 7 +-
.../org/apache/iotdb/db/utils/DateTimeUtils.java | 4 +-
.../java/org/apache/iotdb/db/utils/MathUtils.java | 24 +-
.../db/utils/datastructure/AlignedTVList.java | 412 +-
.../db/utils/datastructure/BackAlignedTVList.java | 66 +-
.../db/utils/datastructure/BackBinaryTVList.java | 72 +-
.../db/utils/datastructure/BackBooleanTVList.java | 71 +-
.../db/utils/datastructure/BackDoubleTVList.java | 71 +-
.../db/utils/datastructure/BackFloatTVList.java | 71 +-
.../db/utils/datastructure/BackIntTVList.java | 72 +-
.../db/utils/datastructure/BackLongTVList.java | 71 +-
.../iotdb/db/utils/datastructure/BackwardSort.java | 66 +-
.../iotdb/db/utils/datastructure/BinaryTVList.java | 128 +-
.../db/utils/datastructure/BooleanTVList.java | 75 +-
.../iotdb/db/utils/datastructure/DoubleTVList.java | 76 +-
.../iotdb/db/utils/datastructure/FloatTVList.java | 76 +-
.../iotdb/db/utils/datastructure/IntTVList.java | 75 +-
.../iotdb/db/utils/datastructure/LongTVList.java | 75 +-
.../MergeSortAlignedTVListIterator.java | 242 ++
.../datastructure/MergeSortTvListIterator.java | 162 +
.../PageColumnAccessInfo.java} | 43 +-
.../db/utils/datastructure/QuickAlignedTVList.java | 34 +-
.../db/utils/datastructure/QuickBinaryTVList.java | 34 +-
.../db/utils/datastructure/QuickBooleanTVList.java | 31 +-
.../db/utils/datastructure/QuickDoubleTVList.java | 31 +-
.../db/utils/datastructure/QuickFloatTVList.java | 31 +-
.../db/utils/datastructure/QuickIntTVList.java | 37 +-
.../db/utils/datastructure/QuickLongTVList.java | 31 +-
.../iotdb/db/utils/datastructure/QuickSort.java | 28 +-
.../iotdb/db/utils/datastructure/TVList.java | 363 +-
.../db/utils/datastructure/TimAlignedTVList.java | 109 +-
.../db/utils/datastructure/TimBinaryTVList.java | 113 +-
.../db/utils/datastructure/TimBooleanTVList.java | 111 +-
.../db/utils/datastructure/TimDoubleTVList.java | 111 +-
.../db/utils/datastructure/TimFloatTVList.java | 112 +-
.../iotdb/db/utils/datastructure/TimIntTVList.java | 112 +-
.../db/utils/datastructure/TimLongTVList.java | 111 +-
.../iotdb/db/utils/datastructure/TimSort.java | 105 +-
....apache.iotdb.db.protocol.mqtt.PayloadFormatter | 1 +
.../db/protocol/mqtt/JSONPayloadFormatterTest.java | 8 +-
.../db/protocol/mqtt/LinePayloadFormatterTest.java | 91 +
.../db/protocol/mqtt/PayloadFormatManagerTest.java | 2 +-
.../db/protocol/rest/IoTDBRestServiceTest.java | 6 +-
.../storageengine/dataregion/DataRegionTest.java | 6 +-
.../memtable/MemChunkDeserializeTest.java | 332 ++
.../dataregion/memtable/PrimitiveMemTableTest.java | 41 +-
.../dataregion/memtable/TsFileProcessorTest.java | 448 +-
.../read/control/FileReaderManagerTest.java | 5 +-
.../reader/chunk/AlignedMemPageReaderTest.java | 32 +-
.../reader/chunk/MemAlignedChunkLoaderTest.java | 138 +-
.../read/reader/chunk/MemChunkLoaderTest.java | 260 +-
.../read/reader/chunk/MemPageReaderTest.java | 12 +-
.../wal/recover/file/TsFilePlanRedoerTest.java | 18 +-
.../apache/iotdb/db/utils/DateTimeUtilsTest.java | 14 +
.../apache/iotdb/db/utils/EnvironmentUtils.java | 4 -
.../db/utils/datastructure/AlignedTVListTest.java | 20 +-
.../db/utils/datastructure/BinaryTVListTest.java | 30 -
.../datanode/src/test/resources/logback-test.xml | 2 +-
.../conf/iotdb-system.properties.template | 40 +-
.../src/assembly/resources/sbin/health_check.bat | 2 +-
.../async/AsyncPipeDataTransferServiceClient.java | 14 +
.../apache/iotdb/commons/conf/CommonConfig.java | 32 +-
.../iotdb/commons/conf/CommonDescriptor.java | 14 +-
.../apache/iotdb/commons/conf/IoTDBConstant.java | 1 +
.../commons/partition/DataPartitionTable.java | 10 +-
.../commons/partition/SeriesPartitionTable.java | 20 +-
.../iotdb/commons/pipe/config/PipeConfig.java | 15 +-
.../db/relational/grammar/sql/RelationalSql.g4 | 3 +-
pom.xml | 4 +-
295 files changed, 13023 insertions(+), 11146 deletions(-)
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/Message.java
=>
example/mqtt-customize/src/main/java/org/apache/iotdb/mqtt/server/MyMessage.java
(68%)
rename
integration-test/src/test/java/org/apache/iotdb/cli/it/{AbstractScript.java =>
AbstractScriptIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBAutoRegionGroupExtensionIT2.java
=> IoTDBAutoRegionGroupExtension2IT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/partition/{IoTDBPartitionTableAutoCleanTest.java
=> IoTDBPartitionTableAutoCleanIT.java} (99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/batch/{IoTDBRegionMigrateNormalITForIoTV2Batch.java
=> IoTDBRegionMigrateNormalITForIoTV2BatchIT.java} (96%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/batch/{IoTDBRegionMigrateOtherITForIoTV2Batch.java
=> IoTDBRegionMigrateOtherForIoTV2BatchIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/stream/{IoTDBRegionMigrateNormalITForIoTV2Stream.java
=> IoTDBRegionMigrateNormalForIoTV2StreamIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/commit/stream/{IoTDBRegionMigrateOtherITForIoTV2Stream.java
=> IoTDBRegionMigrateOtherITForIoTV2StreamIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2Batch.java
=> IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2BatchIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateDataNodeCrashForIoTV2Batch.java
=> IoTDBRegionMigrateDataNodeCrashForIoTV2BatchIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2Batch.java
=> IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2BatchIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/batch/{IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2Batch.java
=> IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2BatchIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2Stream.java
=>
IoTDBRegionMigrateCoordinatorCrashWhenRemoveRemotePeerForIoTV2StreamIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateDataNodeCrashForIoTV2Stream.java
=> IoTDBRegionMigrateDataNodeCrashForIoTV2StreamIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2Stream.java
=> IoTDBRegionMigrateOriginalCrashWhenDeleteLocalPeerForIoTV2StreamIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/datanodecrash/iotv2/stream/{IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2Stream.java
=> IoTDBRegionMigrateOriginalCrashWhenRemoveRemotePeerForIoTV2StreamIT.java}
(99%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/batch/{IoTDBRegionMigrateClusterCrashIoTV2Batch.java
=> IoTDBRegionMigrateClusterCrashIoTV2BatchIT.java} (97%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/batch/{IoTDBRegionMigrateConfigNodeCrashIoTV2Batch.java
=> IoTDBRegionMigrateConfigNodeCrashIoTV2BatchIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/stream/{IoTDBRegionMigrateClusterCrashIoTV2Stream.java
=> IoTDBRegionMigrateClusterCrashIoTV2StreamIT.java} (98%)
rename
integration-test/src/test/java/org/apache/iotdb/confignode/it/regionmigration/pass/daily/iotv2/stream/{IoTDBRegionMigrateConfigNodeCrashIoTV2Stream.java
=> IoTDBRegionMigrateConfigNodeCrashIoTV2StreamIT.java} (98%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/mqtt/IoTDBMQTTServiceIT.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/AbstractSubscriptionTsFile.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/CommonParam.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/SubscriptionTableTsFile.java
create mode 100644
iotdb-client/cli/src/main/java/org/apache/iotdb/tool/tsfile/subscription/SubscriptionTreeTsFile.java
copy
iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/{IoTDBDatabaseMetadata.java
=> IoTDBAbstractDatabaseMetadata.java} (61%)
create mode 100644
iotdb-client/jdbc/src/main/java/org/apache/iotdb/jdbc/relational/IoTDBRelationalDatabaseMetadata.java
delete mode 100644
iotdb-client/session/src/main/java/org/apache/iotdb/session/util/CheckedSupplier.java
rename
iotdb-core/confignode/src/main/java/org/apache/iotdb/confignode/persistence/schema/{ConfignodeSnapshotParser.java
=> ConfigNodeSnapshotParser.java} (91%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/LinePayloadFormatter.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/TableMessage.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/protocol/mqtt/{Message.java
=> TreeMessage.java} (87%)
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileToTableModelAnalyzer.java
delete mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/analyze/load/LoadTsFileToTreeModelAnalyzer.java
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/{RPCService.java
=> ExternalRPCService.java} (95%)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/service/{RPCServiceMBean.java
=> ExternalRPCServiceMBean.java} (96%)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/metadata/AlignedPageMetadata.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/storageengine/dataregion/read/reader/chunk/metadata/PageMetadata.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortAlignedTVListIterator.java
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/datastructure/MergeSortTvListIterator.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/utils/{SetThreadName.java
=> datastructure/PageColumnAccessInfo.java} (57%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/protocol/mqtt/LinePayloadFormatterTest.java
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/storageengine/dataregion/memtable/MemChunkDeserializeTest.java
