Change group id in aggregate processor
@@ -78,11 +78,11 @@ public class AggregationController extends FlinkDataProcessorDeclarer<Aggregatio
.requiredAlternatives(Labels.withId(WINDOW),
Alternatives.from(Labels.withId(COUNT_WINDOW_OPTION),
- StaticProperties.group(Labels.from("group", "", ""),
+ StaticProperties.group(Labels.from("group1", "", ""),
StaticProperties.integerFreeTextProperty(Labels.withId(COUNT_WINDOW_KEY)),
StaticProperties.integerFreeTextProperty(Labels.withId(OUTPUT_EVERY_KEY_EVENT)))),
Alternatives.from(Labels.withId(TIME_WINDOW_OPTION),
- StaticProperties.group(Labels.from("group", "", ""),
+ StaticProperties.group(Labels.from("group2", "", ""),
StaticProperties.integerFreeTextProperty(Labels.withId(TIME_WINDOW_KEY)),
StaticProperties.integerFreeTextProperty(Labels.withId(OUTPUT_EVERY_KEY_SECOND)))))
