Fix SHARD_ID not added as one of the primarykey coloumn
@@ -180,6 +180,7 @@ public class AggregationParser {
throw new SiddhiAppCreationException("Configuration 'shardId' not provided for @partitionbyid " +
"annotation");
}
+ enablePartioning = true;
}
boolean isLatestEventAdded = populateIncomingAggregatorsAndExecutors(
