diff options
| author | doufenghu <[email protected]> | 2024-03-06 20:26:08 +0800 |
|---|---|---|
| committer | doufenghu <[email protected]> | 2024-03-06 20:26:08 +0800 |
| commit | 80e5a4756ca97a52709922956b586fda11377bc5 (patch) | |
| tree | 8c4cdd1dc156ca082fe1c9c9450014d496e6874f /groot-examples/end-to-end-example | |
| parent | f3ecbcc30d01c70bb96634c36c4d1ca7f1e0e869 (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.java | 3 |
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()); |
