summaryrefslogtreecommitdiff
path: root/groot-examples
diff options
context:
space:
mode:
authordoufenghu <[email protected]>2024-07-24 11:50:48 +0800
committerdoufenghu <[email protected]>2024-07-24 11:50:48 +0800
commitbdf64cb08bce82523f6c61d96c8bed36d9d90385 (patch)
tree85a3556e8168c7c8fa9bfc1790b5148bf44e84f5 /groot-examples
parent3cff9a87fa0beab38caff2b34d7344b4186e24e1 (diff)
[Feature][e2e-kafka] Flink image add flink-shaded-hadoop-2-uber-2.7.5-8.0.jar. Add mock data to kafka integration test.
Diffstat (limited to 'groot-examples')
-rw-r--r--groot-examples/end-to-end-example/src/main/resources/examples/session_record_mock_to_print.yaml2
1 files changed, 1 insertions, 1 deletions
diff --git a/groot-examples/end-to-end-example/src/main/resources/examples/session_record_mock_to_print.yaml b/groot-examples/end-to-end-example/src/main/resources/examples/session_record_mock_to_print.yaml
index f115643..e59360d 100644
--- a/groot-examples/end-to-end-example/src/main/resources/examples/session_record_mock_to_print.yaml
+++ b/groot-examples/end-to-end-example/src/main/resources/examples/session_record_mock_to_print.yaml
@@ -115,7 +115,7 @@ application: # [object] Define job configuration
object-reuse: true
topology:
- name: mock_source
- downstream: [ print_sink ]
+ downstream: [ etl_processor ]
- name: etl_processor
downstream: [ print_sink ]
- name: print_sink