diff options
| author | wangkuan <[email protected]> | 2024-09-10 17:17:25 +0800 |
|---|---|---|
| committer | wangkuan <[email protected]> | 2024-09-10 17:17:25 +0800 |
| commit | f87b41d7fe3e17e6528dfc6744ac33ed155825be (patch) | |
| tree | 847f948b384a78d921aa44ee684fef2e0a86a90a /groot-bootstrap | |
| parent | daf6ee08400b1102bb7e97af2c5663fc5cee24b4 (diff) | |
[improve][test]修改配置文件名称
Diffstat (limited to 'groot-bootstrap')
| -rw-r--r-- | groot-bootstrap/src/test/java/com/geedgenetworks/bootstrap/main/simple/JobSplitWithAggTest.java | 2 | ||||
| -rw-r--r-- | groot-bootstrap/src/test/resources/grootstream_job_agg_test.yaml (renamed from groot-bootstrap/src/test/resources/grootstream_job_split_agg_test.yaml) | 6 |
2 files changed, 1 insertions, 7 deletions
diff --git a/groot-bootstrap/src/test/java/com/geedgenetworks/bootstrap/main/simple/JobSplitWithAggTest.java b/groot-bootstrap/src/test/java/com/geedgenetworks/bootstrap/main/simple/JobSplitWithAggTest.java index 57feb0c..7f19f2a 100644 --- a/groot-bootstrap/src/test/java/com/geedgenetworks/bootstrap/main/simple/JobSplitWithAggTest.java +++ b/groot-bootstrap/src/test/java/com/geedgenetworks/bootstrap/main/simple/JobSplitWithAggTest.java @@ -40,7 +40,7 @@ public class JobSplitWithAggTest { public void testSplitForAgg() { CollectSink.values.clear(); - String[] args ={"--target", "test", "-c", ".\\grootstream_job_split_agg_test.yaml"}; + String[] args ={"--target", "test", "-c", ".\\grootstream_job_agg_test.yaml"}; ExecuteCommandArgs executeCommandArgs = CommandLineUtils .parse(args, new ExecuteCommandArgs(), EngineType.FLINK13.getShellName(), true); diff --git a/groot-bootstrap/src/test/resources/grootstream_job_split_agg_test.yaml b/groot-bootstrap/src/test/resources/grootstream_job_agg_test.yaml index 5163642..ee589ef 100644 --- a/groot-bootstrap/src/test/resources/grootstream_job_split_agg_test.yaml +++ b/groot-bootstrap/src/test/resources/grootstream_job_agg_test.yaml @@ -32,12 +32,6 @@ postprocessing_pipelines: - function: MEAN lookup_fields: [ pkts ] - table_processor: - type: table - functions: - - function: JSON_UNROLL - lookup_fields: [ encapsulation ] - output_fields: [ new_name ] application: # [object] Application Configuration env: # [object] Environment Variables |