This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch rel/1.2
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from f8f3ad79a61 [To rel/1.2] Add schema_ engine_mode config to
iotdb-commons.properties and User-Guide (#10047)
new 18e485a909b [IOTDB-5965] Pipe: failed to transfer insert node when
using schema template (#10041)
new 56255be410d [IOTDB-5968] Pipe: pipe task does not work properly after
cluster reboot (#10046)
new 15a4d199b86 [IOTDB-5966] Pipe: Revision of Tablet serialize and
deserialize (#10045)
new 53a1329203e [IOTDB-5967] Pipe: fix convertToTablet bug and introduce
PipeEmptyTabletInsertionEvent (#10044)
The 4 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:
.../iotdb/confignode/manager/node/NodeManager.java | 9 +-
.../confignode/persistence/pipe/PipeTaskInfo.java | 9 +-
.../runtime/PipeHandleLeaderChangeProcedure.java | 8 +-
.../runtime/PipeHandleMetaChangeProcedure.java | 24 +-
.../impl/pipe/runtime/PipeMetaSyncProcedure.java | 8 +-
.../pipe/task/AbstractOperatePipeProcedureV2.java | 8 +
.../iotdb/pipe/api/collector/RowCollector.java | 5 +-
.../consensus/index/impl/SimpleProgressIndex.java | 2 +-
.../iotdb/commons/pipe/task/meta/PipeTaskMeta.java | 5 +-
.../db/pipe/agent/runtime/HeartbeatScheduler.java | 23 --
.../db/pipe/agent/runtime/PipeAgentLauncher.java | 12 +-
.../iotdb/db/pipe/agent/task/PipeTaskAgent.java | 51 ++-
.../impl/iotdb/v1/IoTDBThriftConnectorV1.java | 38 +-
.../v1/request/PipeTransferInsertNodeReq.java | 4 +-
.../event/impl/PipeEmptyTabletInsertionEvent.java | 28 +-
...ava => PipeInsertNodeTabletInsertionEvent.java} | 31 +-
...nt.java => PipeTabletTabletInsertionEvent.java} | 6 +-
.../realtime/PipeRealtimeCollectEventFactory.java | 6 +-
.../core/event/realtime/TsFileEpochManager.java | 12 +-
.../db/pipe/core/event/view/access/PipeRow.java | 22 +-
.../event/view/collector/PipeRowCollector.java | 10 +-
.../TabletInsertionDataContainer.java | 106 ++----
.../TsFileInsertionDataContainer.java | 4 +-
.../db/sync/common/ClusterSyncInfoFetcher.java | 13 +-
.../PipeInsertNodeTabletInsertionEventTest.java | 178 +++++++++
.../apache/iotdb/tsfile/write/record/Tablet.java | 422 +++++++++++++--------
.../iotdb/tsfile/write/record/TabletTest.java | 38 ++
27 files changed, 704 insertions(+), 378 deletions(-)
delete mode 100644
server/src/main/java/org/apache/iotdb/db/pipe/agent/runtime/HeartbeatScheduler.java
copy
iotdb-api/pipe-api/src/main/java/org/apache/iotdb/pipe/api/collector/RowCollector.java
=>
server/src/main/java/org/apache/iotdb/db/pipe/core/event/impl/PipeEmptyTabletInsertionEvent.java
(65%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/core/event/impl/{PipeInsertNodeInsertionEvent.java
=> PipeInsertNodeTabletInsertionEvent.java} (83%)
rename
server/src/main/java/org/apache/iotdb/db/pipe/core/event/impl/{PipeTabletInsertionEvent.java
=> PipeTabletTabletInsertionEvent.java} (92%)
create mode 100644
server/src/test/java/org/apache/iotdb/db/pipe/core/event/PipeInsertNodeTabletInsertionEventTest.java
