Skip to content

Commit 10e7451

Browse files
committed
reduce log
1 parent 8577b84 commit 10e7451

File tree

1 file changed

+7
-4
lines changed

1 file changed

+7
-4
lines changed

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

+7-4
Original file line numberDiff line numberDiff line change
@@ -82,13 +82,17 @@ public boolean isNeedListenToInsertNode() {
8282
}
8383

8484
private void extractTabletInsertion(final PipeRealtimeEvent event) {
85-
if (canNotUseTabletAnyMore(event)) {
85+
final TsFileEpoch.State state = event.getTsFileEpoch().getState(this);
86+
87+
if (state != TsFileEpoch.State.USING_TSFILE
88+
&& state != TsFileEpoch.State.USING_BOTH
89+
&& canNotUseTabletAnyMore(event)) {
8690
event
8791
.getTsFileEpoch()
8892
.migrateState(
8993
this,
90-
state -> {
91-
switch (state) {
94+
curState -> {
95+
switch (curState) {
9296
case EMPTY:
9397
case USING_TSFILE:
9498
return TsFileEpoch.State.USING_TSFILE;
@@ -100,7 +104,6 @@ private void extractTabletInsertion(final PipeRealtimeEvent event) {
100104
});
101105
}
102106

103-
final TsFileEpoch.State state = event.getTsFileEpoch().getState(this);
104107
switch (state) {
105108
case USING_TSFILE:
106109
// Ignore the tablet event.

0 commit comments

Comments
 (0)