This is an automated email from the ASF dual-hosted git repository.
yongzao pushed a change to branch thread-safely-seriespartitiontable
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 92f1129fb43 finish
add d0f17446687 JDBC: Fix IndexOutOfBoundsException when calling getBytes
(#12662)
add 5b26dfa620b [IOTDB-6335] Redundant rows when using GROUP BY TIME with
LIMIT
add 4de7e691116 Pipe: Enhance error handling logic in pipe async
connector's handlers (#12669)
add d78413ec657 Print log when read resource error (#12666)
add a60b181a354 Load: Make load SQL option VERIFY can only be set to true
(#12670)
add 6639d5742b7 Pipe: Improved hybrid algorithm and avoid the caculations
of tsfiles in connector pending queue tsfiles to block the forwarding of
realtime requests (#12668)
add a0832455944 Migrate to Develocity Maven Extension (#12658)
add 2e433b5ec95 Update import schema logic implementation and optimize
-help display information (#12643)
add 351ab3075ba Subscription: fix topic now timestamp precision (#12663)
add 4c6e110e28f [IOTDB-6337] Refine the count calculation in RegionScan
framework
add baa9e5dd86a Bump version of master branch to 1.3.3-SNAPSHOT (#12672)
add 0073a3d3bf2 Pipe: Reduce warn log when
PipeConfigRegionExtractorMetrics does not exist (#12673)
add e2c705aa898 [IOTDB-6061] Fix the instability failure caused by
initServer in IoTConsensus UT not binding to the corresponding port (#12674)
add 036d73679c2 Load: Make load SQL option VERIFY can only be set to true
(A follow-up fix for #12670) (#12676)
add 223f95cde8c Pipe: add compression level config for connector ZSTD
compressor (#12630)
add 849c09fae2e [PY-client] Unify setup.py and requirement.txt (#12601)
add 82f203e4039 Pipe IT: Ignore failed cases caused by cluster restart
failure (#12678)
add 18d7f0ba6b0 update import and export data -help description (#12677)
add 46daebab423 Pipe: Fix potential NPE when lastEvent == null in
PipeConnectorSubtask (#12680)
add ca21828796e Merge branch 'master' into
thread-safely-seriespartitiontable
No new revisions were added by this update.
Summary of changes:
.github/workflows/cluster-it-1c1d.yml | 2 +-
.github/workflows/cluster-it-1c3d.yml | 2 +-
.github/workflows/pipe-it-2cluster.yml | 2 +-
.github/workflows/sonar-codecov.yml | 2 +-
.github/workflows/unit-test.yml | 2 +-
.gitignore | 1 +
.mvn/{gradle-enterprise.xml => develocity.xml} | 17 +-
.mvn/extensions.xml | 6 +-
code-coverage/pom.xml | 2 +-
distribution/pom.xml | 10 +-
example/client-cpp-example/pom.xml | 2 +-
example/jdbc/pom.xml | 2 +-
.../java/org/apache/iotdb/JDBCCharsetExample.java | 2 +-
example/mqtt-customize/pom.xml | 2 +-
example/mqtt/pom.xml | 2 +-
example/pipe-count-point-processor/pom.xml | 2 +-
example/pipe-opc-ua-sink/pom.xml | 2 +-
example/pom.xml | 2 +-
example/rest-java-example/pom.xml | 2 +-
example/schema/pom.xml | 2 +-
example/session/pom.xml | 2 +-
example/trigger/pom.xml | 2 +-
example/udf/pom.xml | 2 +-
integration-test/pom.xml | 32 ++--
.../org/apache/iotdb/db/it/IoTDBRepairDataIT.java | 3 +-
.../db/it/regionscan/IoTDBActiveRegionScanIT.java | 23 ++-
.../it/autocreate/IoTDBPipeAutoConflictIT.java | 9 +-
.../pipe/it/autocreate/IoTDBPipeClusterIT.java | 44 +++--
.../IoTDBPipeConnectorCompressionIT.java | 126 +++++++++++++
.../pipe/it/autocreate/IoTDBPipeLifeCycleIT.java | 31 +++-
.../it/manual/IoTDBPipeMetaLeaderChangeIT.java | 2 +-
.../pipe/it/manual/IoTDBPipeMetaRestartIT.java | 18 +-
.../it/dual/AbstractSubscriptionDualIT.java | 13 +-
.../it/dual/IoTDBSubscriptionConsumerGroupIT.java | 9 +
.../it/dual/IoTDBSubscriptionTimePrecisionIT.java | 195 +++++++++++++++++++++
.../it/dual/IoTDBSubscriptionTopicIT.java | 2 +-
.../it/local/IoTDBSubscriptionRestartIT.java | 31 +++-
.../apache/iotdb/tools/it/ExportDataTestIT.java | 12 +-
.../apache/iotdb/tools/it/ImportDataTestIT.java | 16 +-
iotdb-api/external-api/pom.xml | 2 +-
iotdb-api/pipe-api/pom.xml | 2 +-
iotdb-api/pom.xml | 2 +-
iotdb-api/trigger-api/pom.xml | 2 +-
iotdb-api/udf-api/pom.xml | 2 +-
iotdb-client/cli/pom.xml | 18 +-
.../org/apache/iotdb/tool/AbstractDataTool.java | 33 ++--
.../java/org/apache/iotdb/tool/ExportData.java | 14 +-
.../java/org/apache/iotdb/tool/ImportData.java | 8 +-
.../java/org/apache/iotdb/tool/ImportSchema.java | 62 +++----
iotdb-client/client-cpp/pom.xml | 4 +-
iotdb-client/client-py/pom.xml | 4 +-
iotdb-client/client-py/requirements.txt | 4 +-
iotdb-client/client-py/resources/setup.py | 7 +-
iotdb-client/isession/pom.xml | 8 +-
iotdb-client/jdbc/pom.xml | 8 +-
.../org/apache/iotdb/jdbc/IoTDBJDBCResultSet.java | 12 +-
iotdb-client/pom.xml | 2 +-
iotdb-client/service-rpc/pom.xml | 6 +-
.../java/org/apache/iotdb/rpc/IoTDBRpcDataSet.java | 8 +-
iotdb-client/session/pom.xml | 10 +-
iotdb-core/antlr/pom.xml | 2 +-
iotdb-core/confignode/pom.xml | 24 +--
.../metric/PipeConfigRegionExtractorMetrics.java | 4 +-
.../subscription/topic/CreateTopicProcedure.java | 6 +-
iotdb-core/consensus/pom.xml | 14 +-
.../apache/iotdb/consensus/iot/ReplicateTest.java | 51 +++---
iotdb-core/datanode/pom.xml | 36 ++--
.../PipeTransferTabletBatchEventHandler.java | 28 +--
.../PipeTransferTabletInsertionEventHandler.java | 22 +--
.../PipeTransferTsFileInsertionEventHandler.java | 18 +-
.../event/common/heartbeat/PipeHeartbeatEvent.java | 48 ++---
.../PipeHistoricalDataRegionTsFileExtractor.java | 12 +-
.../realtime/PipeRealtimeDataRegionExtractor.java | 11 +-
.../PipeRealtimeDataRegionHybridExtractor.java | 9 +-
.../PipeDataNodeRemainingEventAndTimeOperator.java | 3 -
.../subtask/connector/PipeConnectorSubtask.java | 2 +-
.../process/ActiveRegionScanMergeOperator.java | 37 ++--
.../AbstractRegionScanDataSourceOperator.java | 19 +-
.../source/ActiveDeviceRegionScanOperator.java | 40 +++--
.../source/ActiveTimeSeriesRegionScanOperator.java | 34 +++-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 23 +--
.../config/executor/ClusterConfigTaskExecutor.java | 8 +-
.../plan/optimization/LimitOffsetPushDown.java | 3 +-
.../db/queryengine/plan/parser/ASTVisitor.java | 5 +-
.../plan/planner/OperatorTreeGenerator.java | 8 +-
.../plan/planner/distribution/SourceRewriter.java | 1 +
.../dataregion/tsfile/TsFileResource.java | 22 ++-
.../tsfile/timeindex/DeviceTimeIndex.java | 16 ++
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 5 +
.../plan/optimization/LimitOffsetPushDownTest.java | 28 +++
iotdb-core/metrics/core/pom.xml | 4 +-
iotdb-core/metrics/interface/pom.xml | 8 +-
iotdb-core/metrics/pom.xml | 2 +-
iotdb-core/node-commons/pom.xml | 26 +--
.../config/constant/PipeConnectorConstant.java | 10 ++
.../compressor/PipeCompressorConfig.java} | 23 ++-
.../compressor/PipeCompressorFactory.java | 62 +++++--
.../connector/compressor/PipeZSTDCompressor.java | 17 +-
.../pipe/connector/protocol/IoTDBConnector.java | 25 ++-
.../commons/subscription/meta/topic/TopicMeta.java | 2 +-
iotdb-core/pom.xml | 2 +-
iotdb-protocol/openapi/pom.xml | 2 +-
iotdb-protocol/pom.xml | 2 +-
iotdb-protocol/thrift-commons/pom.xml | 2 +-
iotdb-protocol/thrift-confignode/pom.xml | 4 +-
iotdb-protocol/thrift-consensus/pom.xml | 4 +-
iotdb-protocol/thrift-datanode/pom.xml | 4 +-
library-udf/pom.xml | 4 +-
pom.xml | 2 +-
109 files changed, 1115 insertions(+), 485 deletions(-)
rename .mvn/{gradle-enterprise.xml => develocity.xml} (69%)
create mode 100644
integration-test/src/test/java/org/apache/iotdb/subscription/it/dual/IoTDBSubscriptionTimePrecisionIT.java
copy
iotdb-core/{confignode/src/main/java/org/apache/iotdb/confignode/procedure/impl/pipe/PipeTaskOperation.java
=>
node-commons/src/main/java/org/apache/iotdb/commons/pipe/connector/compressor/PipeCompressorConfig.java}
(66%)
