diff options
| -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 |