Skip to content

Commit 29af136

Browse files
committed
fix
1 parent af1eb36 commit 29af136

File tree

1 file changed

+0
-7
lines changed

1 file changed

+0
-7
lines changed

iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/event/common/tablet/PipeTabletCollector.java

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -21,7 +21,6 @@
2121

2222
import org.apache.iotdb.commons.pipe.agent.task.meta.PipeTaskMeta;
2323
import org.apache.iotdb.commons.pipe.event.EnrichedEvent;
24-
import org.apache.iotdb.db.pipe.event.common.PipeInsertionEvent;
2524
import org.apache.iotdb.pipe.api.collector.TabletCollector;
2625

2726
import org.apache.tsfile.write.record.Tablet;
@@ -34,14 +33,8 @@ public PipeTabletCollector(PipeTaskMeta pipeTaskMeta, EnrichedEvent sourceEvent)
3433

3534
@Override
3635
public void collectTablet(final Tablet tablet) {
37-
final PipeInsertionEvent pipeInsertionEvent =
38-
sourceEvent instanceof PipeInsertionEvent ? ((PipeInsertionEvent) sourceEvent) : null;
3936
tabletInsertionEventList.add(
4037
new PipeRawTabletInsertionEvent(
41-
isTableModel,
42-
sourceEventDataBaseName,
43-
pipeInsertionEvent == null ? null : pipeInsertionEvent.getRawTableModelDataBase(),
44-
pipeInsertionEvent == null ? null : pipeInsertionEvent.getRawTreeModelDataBase(),
4538
tablet,
4639
isAligned,
4740
sourceEvent == null ? null : sourceEvent.getPipeName(),

0 commit comments

Comments
 (0)