Skip to content

Commit b971ffb

Browse files
committed
fixed
1 parent cb62b42 commit b971ffb

1 file changed

Lines changed: 1 addition & 2 deletions

File tree

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tsfile/container/TsFileInsertionDataContainer.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,6 @@
2424
import org.apache.iotdb.commons.pipe.datastructure.pattern.PipePattern;
2525
import org.apache.iotdb.commons.pipe.event.EnrichedEvent;
2626
import org.apache.iotdb.db.conf.IoTDBDescriptor;
27-
import org.apache.iotdb.db.pipe.event.common.tsfile.parser.table.TsFileInsertionEventTableParser;
2827
import org.apache.iotdb.db.pipe.metric.overview.PipeTsFileToTabletsMetrics;
2928
import org.apache.iotdb.db.pipe.resource.PipeDataNodeResourceManager;
3029
import org.apache.iotdb.db.pipe.resource.memory.PipeMemoryBlock;
@@ -104,7 +103,7 @@ protected TsFileInsertionDataContainer(
104103
getClass().getSimpleName(),
105104
pipeName,
106105
creationTime,
107-
this instanceof TsFileInsertionEventTableParser ? tablePattern : treePattern,
106+
pattern,
108107
startTime,
109108
endTime,
110109
isWithMod);

0 commit comments

Comments
 (0)