diff options
| author | doufenghu <[email protected]> | 2024-11-16 00:26:30 +0800 |
|---|---|---|
| committer | doufenghu <[email protected]> | 2024-11-16 00:26:30 +0800 |
| commit | bc8fe110e1037e75012c4fb655fff888d4356bf4 (patch) | |
| tree | a4352ac83b8a0d95f1a045d90997fc0a6c06cc05 /groot-common/src/main | |
| parent | 7d6c1eb13837931b4b526f05adb550a58fec1aea (diff) | |
[Improve][core] Preprocessing 和 postprocessing 标识已过期，后续任务将被移除。修复了 Split side output 下游节点存在其他边无法正确构建拓扑的问题。
Diffstat (limited to 'groot-common/src/main')
| -rw-r--r-- | groot-common/src/main/java/com/geedgenetworks/common/config/Constants.java | 4 | ||||
| -rw-r--r-- | groot-common/src/main/java/com/geedgenetworks/common/config/GrootStreamConfigBuilder.java | 2 |
2 files changed, 4 insertions, 2 deletions
diff --git a/groot-common/src/main/java/com/geedgenetworks/common/config/Constants.java b/groot-common/src/main/java/com/geedgenetworks/common/config/Constants.java index b67a842..7629d48 100644 --- a/groot-common/src/main/java/com/geedgenetworks/common/config/Constants.java +++ b/groot-common/src/main/java/com/geedgenetworks/common/config/Constants.java @@ -6,9 +6,11 @@ public final class Constants { public static final String SOURCES = "sources"; public static final String FILTERS = "filters"; public static final String SPLITS = "splits"; + @Deprecated public static final String PREPROCESSING_PIPELINES = "preprocessing_pipelines"; - public static final String PROCESSING_PIPELINES = "processing_pipelines"; + @Deprecated public static final String POSTPROCESSING_PIPELINES = "postprocessing_pipelines"; + public static final String PROCESSING_PIPELINES = "processing_pipelines"; public static final String SINKS = "sinks"; public static final int SYSTEM_EXIT_CODE = 2618; public static final String APPLICATION = "application"; diff --git a/groot-common/src/main/java/com/geedgenetworks/common/config/GrootStreamConfigBuilder.java b/groot-common/src/main/java/com/geedgenetworks/common/config/GrootStreamConfigBuilder.java index 842d1bf..8807123 100644 --- a/groot-common/src/main/java/com/geedgenetworks/common/config/GrootStreamConfigBuilder.java +++ b/groot-common/src/main/java/com/geedgenetworks/common/config/GrootStreamConfigBuilder.java @@ -72,7 +72,7 @@ public class GrootStreamConfigBuilder extends AbstractYamlConfigBuilder { grootStreamRoot = yamlRootNode; } - YamlDomChecker.check(grootStreamRoot); + YamlDomChecker.check(grootStreamRoot, null); Node w3cRootNode = asW3cNode(grootStreamRoot); replaceVariables(w3cRootNode); |