This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ty/explain_format
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f71fa803cda Fix ExplainJsonCliOutputIT and add UTs for Codecov coverage
add 9fe80a48e2c Fix pipe consensus compatibility during rolling upgrade
(#17428)
add dce76a6fe8c Fix error msg for SeeionPoolIT. (#17427)
add 3931c05c22e Resolve type mismatch when WHEN result type differs from
ELSE (INT32 vs INT64) (#17415)
add 79d8fa76ecc Auth: Fixed potential NPE problems && Added clear cache
option to clear the stale auth cache (#17426)
add c91688bd471 Fix IoTDBCopyToTsFileIT (#17429)
add e801885cc2a Bump ratis-thirdparty-misc and ratis versions (#17432)
add 1768bd97f9f Add PlanNodeType enum value for tsfile object piece.
(#17431)
add 9c9eae14f90 Banned the duplicated properties in table
add cfce7d9089c fix: prevent NPE when isFinished() is called before
DataDriver init (#17440)
add fad286945eb Fix recovered consensus pipes staying stopped after
snapshot load (#17438)
add 2e77bf44c37 Add FROM-first query syntax support (#17410)
add b4644ba8f45 fix: improve DataNode reachability check in
ensureNodeStatus (#17446)
add 37fb889aa3a Fixed the bug that session cannot query minus value when
only pass paths (#17389)
add 57fe1c9a48e Pipe: check file receiver write path (#17442)
add c1d16a40a64 Improve state type validation in CombineRequest
deserialization. (#17449)
add b5199bd4832 Pipe: Optimized the memory occupation of pipe realtime
source (#17450)
add 7afedfe0969 Pipe: Refactor AirGap receiver with configurable payload
size control (#17443)
add ab6289af913 Ignore claude code related files (#17453)
add 3e4661bef60 Pipe: Optimized the tablet size by memory estimation
(#17452)
add cca9dbbf0b4 fix the clear logic of specified info of one operator when
print plan in explain analyze (#17454)
add 1c1cbca7760 fix (#17455)
add a45a3006194 resolve conflicts
add a9d1dce242a Enhance diagnostic logging in ExplainJsonCliOutputIT for
Windows CI debugging
No new revisions were added by this update.
Summary of changes:
.gitignore | 4 +-
.../iotdb/it/env/cluster/env/AbstractEnv.java | 27 +-
.../iotdb/cli/it/ExplainJsonCliOutputIT.java | 67 ++++-
.../db/it/aligned/IoTDBAlignedLastQueryIT.java | 3 +-
.../db/it/aligned/IoTDBAlignedSeriesQueryIT.java | 320 +++++++++++----------
.../it/aligned/IoTDBLastQueryWithDeletionIT.java | 3 +-
.../aligned/IoTDBLastQueryWithoutLastCacheIT.java | 3 +-
...DBRawQueryWithoutValueFilterWithDeletionIT.java | 84 +++---
.../iotdb/db/it/auth/IoTDBSystemPermissionIT.java | 1 +
.../IoTDBExplainAnalyzePrintIT.java} | 96 +++----
.../iotdb/db/it/query/IoTDBFilteredRowsIT.java | 1 -
.../apache/iotdb/db/it/utils/AlignedWriteUtil.java | 2 +
.../org/apache/iotdb/db/it/utils/TestUtils.java | 26 ++
.../treemodel/auto/basic/IoTDBPipeDataSinkIT.java | 3 +-
.../it/db/it/IoTDBCaseWhenThenTableIT.java | 12 +-
.../it/query/recent/IoTDBFromFirstQueryIT.java | 126 ++++++++
.../query/recent/copyto/IoTDBCopyToTsFileIT.java | 5 +-
.../iotdb/relational/it/schema/IoTDBTableIT.java | 8 +
.../iotdb/session/it/IoTDBSessionQueryIT.java | 9 +-
.../iotdb/session/it/pool/SessionPoolIT.java | 1 +
.../java/org/apache/iotdb/session/Session.java | 3 +-
.../org/apache/iotdb/db/qp/sql/IdentifierParser.g4 | 1 +
.../org/apache/iotdb/db/qp/sql/IoTDBSqlParser.g4 | 2 +-
.../antlr4/org/apache/iotdb/db/qp/sql/SqlLexer.g4 | 4 +
.../confignode/conf/SystemPropertiesUtils.java | 35 ++-
.../confignode/persistence/pipe/PipeTaskInfo.java | 25 ++
.../AbstractOperateSubscriptionProcedure.java | 1 +
.../pipe/PipeTaskInfoConsensusPipeTest.java | 57 ++++
.../apache/iotdb/consensus/ConsensusFactory.java | 19 +-
.../org/apache/iotdb/db/auth/AuthorityChecker.java | 4 +
.../apache/iotdb/db/auth/BasicAuthorityCache.java | 5 +-
.../java/org/apache/iotdb/db/conf/IoTDBConfig.java | 10 +
.../org/apache/iotdb/db/conf/IoTDBStartCheck.java | 24 +-
.../PipeDataRegionProcessorConstructor.java | 4 +
.../dataregion/PipeDataRegionSinkConstructor.java | 8 +
.../tsfile/parser/TsFileInsertionEventParser.java | 4 +-
.../scan/TsFileInsertionEventScanParser.java | 3 +-
.../table/TsFileInsertionEventTableParser.java | 6 +-
.../twostage/exchange/payload/CombineRequest.java | 10 +-
.../protocol/airgap/IoTDBAirGapReceiver.java | 25 +-
.../visitor/PipeStatementTSStatusVisitor.java | 30 +-
.../pipe/resource/memory/PipeMemoryWeightUtil.java | 34 ++-
.../thrift/async/IoTDBDataRegionAsyncSink.java | 1 -
.../async/handler/PipeTransferTsFileHandler.java | 5 +-
.../realtime/PipeRealtimeDataRegionSource.java | 7 +
.../impl/DataNodeInternalRPCServiceImpl.java | 3 +
.../queryengine/execution/driver/DataDriver.java | 5 +
.../db/queryengine/execution/driver/Driver.java | 4 +-
.../queryengine/execution/driver/SchemaDriver.java | 5 +
.../fragment/FragmentInstanceExecution.java | 1 -
.../execution/config/TableConfigTaskVisitor.java | 4 +
.../db/queryengine/plan/parser/ASTVisitor.java | 5 +-
.../plan/planner/plan/node/PlanNodeType.java | 1 +
.../plan/relational/planner/IrTypeAnalyzer.java | 117 ++++++--
.../plan/relational/sql/parser/AstBuilder.java | 71 ++++-
.../{TypeCoercion.java => TypeCoercionUtils.java} | 24 +-
.../statistics/SpecifiedInfoMergerFactory.java | 13 +
.../statistics/StatisticsMergeUtil.java | 2 -
.../agent/plugin/PipeDataNodePluginAgentTest.java | 30 ++
.../pipe/event/TsFileInsertionEventParserTest.java | 13 +
.../protocol/airgap/IoTDBAirGapReceiverTest.java | 72 +++++
.../pipe/sink/PipeDataNodeThriftRequestTest.java | 58 ++++
.../db/queryengine/execution/DataDriverTest.java | 118 ++++++++
.../plan/relational/analyzer/AnalyzerTest.java | 114 ++++++++
.../commons/auth/authorizer/BasicAuthorizer.java | 6 +-
.../apache/iotdb/commons/conf/CommonConfig.java | 30 +-
.../agent/plugin/builtin/BuiltinPipePlugin.java | 11 +-
.../connection/UnboundedBlockingPendingQueue.java | 4 +
.../iotdb/commons/pipe/config/PipeConfig.java | 7 +
.../iotdb/commons/pipe/config/PipeDescriptor.java | 5 +
.../commons/pipe/receiver/IoTDBFileReceiver.java | 41 ++-
.../commons/schema/cache/CacheClearOptions.java | 1 +
.../pipe/receiver/IoTDBFileReceiverTest.java | 133 +++++++++
.../db/relational/grammar/sql/RelationalSql.g4 | 16 +-
pom.xml | 10 +-
75 files changed, 1634 insertions(+), 418 deletions(-)
copy
integration-test/src/test/java/org/apache/iotdb/db/it/{IoTDBFileTimeIndexIT.java
=> query/IoTDBExplainAnalyzePrintIT.java} (52%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/relational/it/query/recent/IoTDBFromFirstQueryIT.java
copy
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/queryengine/plan/relational/type/{TypeCoercion.java
=> TypeCoercionUtils.java} (58%)
create mode 100644
iotdb-core/datanode/src/test/java/org/apache/iotdb/db/pipe/receiver/protocol/airgap/IoTDBAirGapReceiverTest.java
create mode 100644
iotdb-core/node-commons/src/test/java/org/apache/iotdb/commons/pipe/receiver/IoTDBFileReceiverTest.java
