You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/02/16 12:00:56 UTC
[incubator-seatunnel] branch dev updated: [Bug][Core]When engine type is illegal throw IllegalArgumentException (#1249)
This is an automated email from the ASF dual-hosted git repository.
kirs 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 3bee687 [Bug][Core]When engine type is illegal throw IllegalArgumentException (#1249)
3bee687 is described below
commit 3bee6873d2f87144957d5707a9e0a0f09a6999a7
Author: Wenjun Ruan <we...@apache.org>
AuthorDate: Wed Feb 16 20:00:49 2022 +0800
[Bug][Core]When engine type is illegal throw IllegalArgumentException (#1249)
---
.../src/main/java/org/apache/seatunnel/config/ConfigBuilder.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/config/ConfigBuilder.java b/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/config/ConfigBuilder.java
index fb144ed..7bb8c7a 100644
--- a/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/config/ConfigBuilder.java
+++ b/seatunnel-core/seatunnel-core-base/src/main/java/org/apache/seatunnel/config/ConfigBuilder.java
@@ -190,7 +190,7 @@ public class ConfigBuilder {
env = new FlinkEnvironment();
break;
default:
- break;
+ throw new IllegalArgumentException("Engine: " + engine + " is not supported");
}
env.setConfig(envConfig);
env.prepare(streaming);