diff options
| author | 窦凤虎 <[email protected]> | 2024-04-07 06:06:23 +0000 |
|---|---|---|
| committer | 窦凤虎 <[email protected]> | 2024-04-07 06:06:23 +0000 |
| commit | 7c242c5984644b4e216e9ba723a5e2d4a974bb56 (patch) | |
| tree | 8fcfc812125d4ef966c721ec010692b4e5eb536e /groot-examples | |
| parent | e736bdfa5dcef0af17b2a0d4ecbdfa6b4cd3aeee (diff) | |
| parent | 58460028cf73336292bbf9a6b05fc7612e3f891b (diff) | |
Merge branch 'feature/test-e2e-kafka' into 'develop'
Feature/test e2e kafka
See merge request galaxy/platform/groot-stream!31
Diffstat (limited to 'groot-examples')
4 files changed, 10 insertions, 8 deletions
diff --git a/groot-examples/end-to-end-example/pom.xml b/groot-examples/end-to-end-example/pom.xml index 0839e8e..34709fd 100644 --- a/groot-examples/end-to-end-example/pom.xml +++ b/groot-examples/end-to-end-example/pom.xml @@ -13,8 +13,9 @@ <name>Groot : Examples : End-to-end</name> <properties> - <maven.install.skip>true</maven.install.skip> - <maven.deploy.skip>true</maven.deploy.skip> + <maven.install.skip>false</maven.install.skip> + <maven.deploy.skip>false</maven.deploy.skip> </properties> + </project>
\ No newline at end of file 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 aa2cb76..1f236d7 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,7 +13,7 @@ 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/inline_to_print.yaml"; + String configPath = args.length > 0 ? args[0] : "/examples/kafka_to_print.yaml"; String configFile = getTestConfigFile(configPath); ExecuteCommandArgs executeCommandArgs = new ExecuteCommandArgs(); executeCommandArgs.setConfigFile(configFile); diff --git a/groot-examples/end-to-end-example/src/main/resources/examples/kafka_to_print.yaml b/groot-examples/end-to-end-example/src/main/resources/examples/kafka_to_print.yaml index e883bce..bf8ebf2 100644 --- a/groot-examples/end-to-end-example/src/main/resources/examples/kafka_to_print.yaml +++ b/groot-examples/end-to-end-example/src/main/resources/examples/kafka_to_print.yaml @@ -30,6 +30,8 @@ application: # [object] Define job configuration parallelism: 1 pipeline: object-reuse: true + flink: + restart-strategy: none topology: - name: kafka_source downstream: [print_sink] diff --git a/groot-examples/pom.xml b/groot-examples/pom.xml index fc08086..1fb6212 100644 --- a/groot-examples/pom.xml +++ b/groot-examples/pom.xml @@ -30,28 +30,27 @@ <dependency> <groupId>com.geedgenetworks</groupId> <artifactId>groot-bootstrap</artifactId> - <version>${revision}</version> + <version>${project.version}</version> </dependency> - <dependency> <groupId>com.geedgenetworks</groupId> <artifactId>connector-kafka</artifactId> - <version>${revision}</version> + <version>${project.version}</version> <scope>${scope}</scope> </dependency> <dependency> <groupId>com.geedgenetworks</groupId> <artifactId>connector-clickhouse</artifactId> - <version>${revision}</version> + <version>${project.version}</version> <scope>${scope}</scope> </dependency> <dependency> <groupId>com.geedgenetworks</groupId> <artifactId>connector-ipfix-collector</artifactId> - <version>${revision}</version> + <version>${project.version}</version> <scope>${scope}</scope> </dependency> |