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 22ca27025 Set the first program argument as configure file path,
Instand every test situation to make new class (#2464)
22ca27025 is described below
commit 22ca27025cfe1c3a9d9b4dddf1e88af1e3c971b5
Author: 巧克力黑 <[email protected]>
AuthorDate: Fri Aug 19 10:07:58 2022 +0800
Set the first program argument as configure file path, Instand every test
situation to make new class (#2464)
---
.../org/apache/seatunnel/example/flink/v2/SeaTunnelApiExample.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
diff --git
a/seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/java/org/apache/seatunnel/example/flink/v2/SeaTunnelApiExample.java
b/seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/java/org/apache/seatunnel/example/flink/v2/SeaTunnelApiExample.java
index 79912ae96..87d693ed1 100644
---
a/seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/java/org/apache/seatunnel/example/flink/v2/SeaTunnelApiExample.java
+++
b/seatunnel-examples/seatunnel-flink-connector-v2-example/src/main/java/org/apache/seatunnel/example/flink/v2/SeaTunnelApiExample.java
@@ -31,7 +31,8 @@ import java.nio.file.Paths;
public class SeaTunnelApiExample {
public static void main(String[] args) throws FileNotFoundException,
URISyntaxException, CommandException {
- String configFile =
getTestConfigFile("/examples/fake_to_console.conf");
+ String configurePath = args.length > 0 ? args[0] :
"/examples/fake_to_console.conf";
+ String configFile = getTestConfigFile(configurePath);
FlinkCommandArgs flinkCommandArgs = new FlinkCommandArgs();
flinkCommandArgs.setConfigFile(configFile);
flinkCommandArgs.setCheckConfig(false);