(iotdb) branch master updated: Pipe: Reset the inclusion settings to data.insert (#12337)

[rong]

This is an automated email from the ASF dual-hosted git repository.

rong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/iotdb.git


The following commit(s) were added to refs/heads/master by this push:
     new 3d5f7017f8f Pipe: Reset the inclusion settings to data.insert (#12337)
3d5f7017f8f is described below

commit 3d5f7017f8f75e425ac8d6a81c53fcd3033bdfed
Author: Caideyipi <87789683+caidey...@users.noreply.github.com>
AuthorDate: Mon Apr 15 18:54:58 2024 +0800

    Pipe: Reset the inclusion settings to data.insert (#12337)
---
 .../java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeProtocolIT.java   | 1 +
 .../iotdb/commons/pipe/config/constant/PipeExtractorConstant.java       | 2 +-
 2 files changed, 2 insertions(+), 1 deletion(-)

diff --git 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeProtocolIT.java
 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeProtocolIT.java
index be211ca08d5..e8e11e6fec9 100644
--- 
a/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeProtocolIT.java
+++ 
b/integration-test/src/test/java/org/apache/iotdb/pipe/it/autocreate/IoTDBPipeProtocolIT.java
@@ -415,6 +415,7 @@ public class IoTDBPipeProtocolIT extends 
AbstractPipeDualAutoIT {
       connectorAttributes.put("connector.batch.enable", "false");
       connectorAttributes.put("connector.node-urls", 
nodeUrlsBuilder.toString());
 
+      extractorAttributes.put("source.inclusion", "all");
       extractorAttributes.put("source.mods.enable", "true");
 
       // Test forced-log mode, in open releases this might be "file"
diff --git 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeExtractorConstant.java
 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeExtractorConstant.java
index 9d811d6548a..80c102a0b3e 100644
--- 
a/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeExtractorConstant.java
+++ 
b/iotdb-core/node-commons/src/main/java/org/apache/iotdb/commons/pipe/config/constant/PipeExtractorConstant.java
@@ -26,7 +26,7 @@ public class PipeExtractorConstant {
 
   public static final String EXTRACTOR_INCLUSION_KEY = "extractor.inclusion";
   public static final String SOURCE_INCLUSION_KEY = "source.inclusion";
-  public static final String EXTRACTOR_INCLUSION_DEFAULT_VALUE = "all";
+  public static final String EXTRACTOR_INCLUSION_DEFAULT_VALUE = "data.insert";
 
   public static final String EXTRACTOR_EXCLUSION_KEY = 
"extractor.inclusion.exclusion";
   public static final String SOURCE_EXCLUSION_KEY = 
"source.inclusion.exclusion";