Skip to content

Commit 1cea612

Browse files
committed
Update PipeRealtimeDataRegionLogExtractor.java
1 parent 6428005 commit 1cea612

1 file changed

Lines changed: 1 addition & 4 deletions

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/extractor/dataregion/realtime/PipeRealtimeDataRegionLogExtractor.java

Lines changed: 1 addition & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -82,10 +82,7 @@ private void extractTabletInsertion(PipeRealtimeEvent event) {
8282
private void extractTsFileInsertion(PipeRealtimeEvent event) {
8383
final PipeTsFileInsertionEvent tsFileInsertionEvent =
8484
(PipeTsFileInsertionEvent) event.getEvent();
85-
if (!(tsFileInsertionEvent.isLoaded()
86-
// some insert nodes in the tsfile epoch are not captured by pipe
87-
|| tsFileInsertionEvent.getFileStartTime()
88-
< event.getTsFileEpoch().getInsertNodeMinTime())) {
85+
if (!(tsFileInsertionEvent.isLoaded())) {
8986
// All data in the tsfile epoch has been extracted in tablet mode, so we should
9087
// simply ignore this event.
9188
event.decreaseReferenceCount(PipeRealtimeDataRegionLogExtractor.class.getName(), false);

0 commit comments

Comments
 (0)