This is an automated email from the ASF dual-hosted git repository.
haonan pushed a change to branch rc/1.2.0
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)
add 18e485a909b [IOTDB-5965] Pipe: failed to transfer insert node when
using schema template (#10041)
add 56255be410d [IOTDB-5968] Pipe: pipe task does not work properly after
cluster reboot (#10046)
add 15a4d199b86 [IOTDB-5966] Pipe: Revision of Tablet serialize and
deserialize (#10045)
add 53a1329203e [IOTDB-5967] Pipe: fix convertToTablet bug and introduce
PipeEmptyTabletInsertionEvent (#10044)
No new revisions were added by this update.
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
