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);

Reply via email to