You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@iotdb.apache.org by ro...@apache.org on 2024/04/15 10:55:04 UTC
(iotdb) branch master updated: Pipe: Reset the inclusion settings to data.insert (#12337)
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 <87...@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";