You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by wu...@apache.org on 2022/03/17 09:40:49 UTC

[incubator-seatunnel] branch dev updated: [Improve][Config] Remove useless config path condition (#1379)

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

wuchunfu pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new b9643ed  [Improve][Config] Remove useless config path condition (#1379)
b9643ed is described below

commit b9643ede30a74e458b8e7f5b899158e8b09b1caa
Author: Simon <zh...@cvte.com>
AuthorDate: Thu Mar 17 17:40:06 2022 +0800

    [Improve][Config] Remove useless config path condition (#1379)
---
 .../seatunnel/shade/com/typesafe/config/impl/ConfigParser.java       | 5 +----
 1 file changed, 1 insertion(+), 4 deletions(-)

diff --git a/seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/ConfigParser.java b/seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/ConfigParser.java
index 1f00f37..6ff0ed1 100644
--- a/seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/ConfigParser.java
+++ b/seatunnel-config/seatunnel-config-shade/src/main/java/org/apache/seatunnel/shade/com/typesafe/config/impl/ConfigParser.java
@@ -112,10 +112,7 @@ final class ConfigParser {
                 Path path = pathStack.peekFirst();
 
                 if (path != null
-                    && ("input".equals(path.first())
-                    || "filter".equals(path.first())
-                    || "output".equals(path.first())
-                    || "source".equals(path.first())
+                    && ("source".equals(path.first())
                     || "transform".equals(path.first())
                     || "sink".equals(path.first()))) {
                     v = parseObjectForWaterdrop((ConfigNodeObject) n);