This is an automated email from the ASF dual-hosted git repository. rong pushed a commit to branch pipe-table-model-3 in repository https://gitbox.apache.org/repos/asf/iotdb.git
commit 4afa04ce29a7e83c2ec3281f729cf2827068c7a0 Author: Steve Yurong Su <[email protected]> AuthorDate: Fri Sep 27 12:29:53 2024 +0800 Update IoTDBDataRegionTableModelExtractor.java --- .../extractor/dataregion/IoTDBDataRegionTableModelExtractor.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/table/extractor/dataregion/IoTDBDataRegionTableModelExtractor.java b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/table/extractor/dataregion/IoTDBDataRegionTableModelExtractor.java index 8bee9a23be5..05c6fd51c6c 100644 --- a/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/table/extractor/dataregion/IoTDBDataRegionTableModelExtractor.java +++ b/iotdb-core/datanode/src/main/java/org/apache/iotdb/db/pipe/table/extractor/dataregion/IoTDBDataRegionTableModelExtractor.java @@ -122,8 +122,10 @@ public class IoTDBDataRegionTableModelExtractor extends IoTDBDataRegionExtractor throw new PipeException( "The pipe cannot transfer data when data region is using ratis consensus."); } + // TODO: Support deletion listening if (insertionDeletionListeningOptionPair.getRight().equals(true)) { - throw new PipeException("Table model extractor does not support deletion listening."); + throw new PipeException( + "Table model extractor currently does not support deletion listening."); } // TODO: SQL matcher construction and validation
