This is an automated email from the ASF dual-hosted git repository.
rong pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git
from ac19367dd77 Fix DataNodeWrapper didn't set Timezone
add 7a131b8eeaa Pipe: Fixed the bug that the insertion for newer tsFile in
one region may report progress beyond the older tsFile when it is not flushed
(#15515)
No new revisions were added by this update.
Summary of changes:
.../common/tsfile/PipeTsFileInsertionEvent.java | 9 ++--
.../db/pipe/event/realtime/PipeRealtimeEvent.java | 5 ++
.../PipeRealtimeDataRegionHybridExtractor.java | 3 ++
.../realtime/assigner/PipeDataRegionAssigner.java | 34 ++++++++++----
...ava => PipeTsFileEpochProgressIndexKeeper.java} | 53 ++++++++--------------
.../dataregion/realtime/epoch/TsFileEpoch.java | 14 ++++--
.../dataregion/tsfile/TsFileResource.java | 10 ++--
7 files changed, 67 insertions(+), 61 deletions(-)
rename
iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/assigner/{PipeTimePartitionProgressIndexKeeper.java
=> PipeTsFileEpochProgressIndexKeeper.java} (55%)
