This is an automated email from the ASF dual-hosted git repository.
jackietien pushed a change to branch ca_performance
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from 85cc63a5498 make field static
add a6cd542b5fe [IOTDB-6084] Pipe: Support node-urls (client HA) in
iotdb-thrift-connector-v1(v2) (#10749) (#10774)
add 12d09e0e17e [IOTDB-6097] Pipe: Avoid subscrption running with the
pattern option causing OOM & Fix de/ser of RecoverProgressIndex (#10767)
(#10775)
add 3f27b70eba7 [IOTDB-6098] Fix a possible flush error when using aligned
timeseries (#10769)
add eb929c920f9 close estimator after calculate memory cost (#10772)
add 7fbe00e0c67 [To rel/1.2] Fix rel/1.2 branch CI issues (#10776)
add fa3def7e42e [To rel/1.2] [IOTDB-6096] Make M4 Function do the nullable
judgement
add fc026e6525d Fix recover last flush time map bug (#10761) (#10763)
add 37eea1d11e9 [IOTDB-6100] Pipe: Fix running in hybrid mode will cause
wal cannot be deleted & some pipe data lost due to wrong ProducerType of
Disruptor (#10790) (#10791)
add 8f4f3952933 [IOTDB-6094] Load: Fix error in if/else judgment of
tsfileResource exists or not & Reduce warn log when timeseries exist (#10762)
(#10792)
new 882d0e73ba9 Merge remote-tracking branch 'origin/rel/1.2' into
ca_performance
new 66cb36d2edd Stop generating FilterExpression if we don't specify the
time filter in last query session api
The 2 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/client-cpp.yml | 5 -
.github/workflows/client-python.yml | 1 -
.github/workflows/sonar-coveralls.yml | 2 +-
docker/src/main/Dockerfile-1c1d | 8 +-
.../db/it/aligned/IoTDBInsertAlignedValues2IT.java | 12 +
.../db/it/udf/IoTDBUDTFBuiltinFunctionIT.java | 58 ++++
iotdb-client/client-py/iotdb/IoTDBContainer.py | 11 +
.../confignode/conf/ConfigNodeStartupCheck.java | 6 -
.../pipe/connector/base/IoTDBThriftConnector.java | 85 ++++++
.../pipe/connector/v1/IoTDBThriftConnectorV1.java | 184 +++++++----
.../pipe/connector/v2/IoTDBThriftConnectorV2.java | 91 +-----
.../PipeRealtimeDataRegionHybridExtractor.java | 90 ++++--
.../PipeRealtimeDataRegionLogExtractor.java | 24 +-
.../PipeRealtimeDataRegionTsFileExtractor.java | 26 +-
.../realtime/assigner/DisruptorQueue.java | 85 ++----
.../realtime/assigner/PipeDataRegionAssigner.java | 10 +-
.../db/pipe/resource/wal/PipeWALResource.java | 4 +
.../pipe/resource/wal/PipeWALResourceManager.java | 12 +-
.../pipe/task/connection/BlockingPendingQueue.java | 22 +-
.../pipe/task/connection/PipeEventCollector.java | 48 ++-
.../protocol/thrift/impl/ClientRPCServiceImpl.java | 2 +-
.../queryengine/plan/analyze/AnalyzeVisitor.java | 91 ++----
.../config/executor/ClusterConfigTaskExecutor.java | 27 +-
.../plan/parser/StatementGenerator.java | 21 +-
.../metadata/DatabaseSchemaStatement.java | 9 +
...ticSerializableTVListBackedSingleColumnRow.java | 2 +-
.../LayerPointReaderBackedSingleColumnRow.java | 6 +-
.../java/org/apache/iotdb/db/service/DataNode.java | 8 -
.../db/storageengine/dataregion/DataRegion.java | 2 +-
.../dataregion/HashLastFlushTimeMap.java | 6 +-
.../performer/impl/FastCompactionPerformer.java | 2 +-
.../execute/task/InnerSpaceCompactionTask.java | 12 +-
.../dataregion/tsfile/TsFileResource.java | 13 +-
.../tsfile/timeindex/DeviceTimeIndex.java | 4 +-
.../dataregion/tsfile/timeindex/FileTimeIndex.java | 4 +-
.../dataregion/tsfile/timeindex/ITimeIndex.java | 7 +-
.../dataregion/LastFlushTimeMapTest.java | 317 +++++++------------
.../resources/conf/iotdb-common.properties | 8 +-
.../iotdb/commons/concurrent/ThreadName.java | 2 +
.../apache/iotdb/commons/conf/CommonConfig.java | 6 +-
.../consensus/index/impl/RecoverProgressIndex.java | 5 +-
.../apache/iotdb/commons/udf/builtin/UDTFM4.java | 338 +++++++++++++--------
.../iotdb/commons/pipe/PipeMetaDeSerTest.java | 57 +++-
.../iotdb/tsfile/write/page/TimePageWriter.java | 4 +-
.../tsfile/write/writer/TimeChunkWriterTest.java | 55 ++++
pom.xml | 1 +
46 files changed, 1065 insertions(+), 728 deletions(-)
create mode 100644
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/connector/base/IoTDBThriftConnector.java
