summaryrefslogtreecommitdiff
path: root/groot-examples/end-to-end-example
diff options
context:
space:
mode:
authordoufenghu <[email protected]>2024-03-06 20:26:08 +0800
committerdoufenghu <[email protected]>2024-03-06 20:26:08 +0800
commit80e5a4756ca97a52709922956b586fda11377bc5 (patch)
tree8c4cdd1dc156ca082fe1c9c9450014d496e6874f /groot-examples/end-to-end-example
parentf3ecbcc30d01c70bb96634c36c4d1ca7f1e0e869 (diff)
[Feature][Test] Add TestContainner lib for end-to-end testing. Add test-common and test-e2e-base submodules. Support Inline to Print test in Flink13 Container.
Diffstat (limited to 'groot-examples/end-to-end-example')
-rw-r--r--groot-examples/end-to-end-example/src/main/java/com/geedgenetworks/example/GrootStreamExample.java3
1 files changed, 2 insertions, 1 deletions
diff --git a/groot-examples/end-to-end-example/src/main/java/com/geedgenetworks/example/GrootStreamExample.java b/groot-examples/end-to-end-example/src/main/java/com/geedgenetworks/example/GrootStreamExample.java
index 825f79a..aa2cb76 100644
--- a/groot-examples/end-to-end-example/src/main/java/com/geedgenetworks/example/GrootStreamExample.java
+++ b/groot-examples/end-to-end-example/src/main/java/com/geedgenetworks/example/GrootStreamExample.java
@@ -13,11 +13,12 @@ import java.nio.file.Paths;
public class GrootStreamExample {
public static void main(String[] args) throws FileNotFoundException, URISyntaxException {
- String configPath = args.length > 0 ? args[0] : "/examples/kafka_to_print.yaml";
+ String configPath = args.length > 0 ? args[0] : "/examples/inline_to_print.yaml";
String configFile = getTestConfigFile(configPath);
ExecuteCommandArgs executeCommandArgs = new ExecuteCommandArgs();
executeCommandArgs.setConfigFile(configFile);
executeCommandArgs.setCheckConfig(false);
+ executeCommandArgs.setVersion(false);
executeCommandArgs.setDeployMode(DeployMode.RUN);
executeCommandArgs.setTargetType(TargetType.LOCAL);
GrootStreamServer.run(executeCommandArgs.buildCommand());