diff options
| author | doufenghu <[email protected]> | 2024-04-02 17:36:46 +0800 |
|---|---|---|
| committer | doufenghu <[email protected]> | 2024-04-02 17:36:46 +0800 |
| commit | 95bcb7db323b12d7e7f864dff615d73622d7e688 (patch) | |
| tree | 919b582cbcefb9304004444fda1d350a3041a2f5 /groot-examples | |
| parent | 80e93523eb12f986acac73a81f2614516c718a5e (diff) | |
[Feature][Tests] add Kafka Container for unit test.
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> |