Handle ConnectionUnavailable
@@ -203,10 +203,14 @@ public class IncrementalAggregateCompileCondition implements CompiledCondition {
.getAttributeList().toArray(new Attribute[0])
);
} catch (ConnectionUnavailableException e) {
- // TODO: ???
- LOG.error("Unable to query table '" + tableForPerDuration.getTableDefinition().getId() + "', "
+ // Store query does not have retry logi and normal mode is used
+ if (LOG.isDebugEnabled()) {
+ LOG.debug("Unable to query table '" + tableForPerDuration.getTableDefinition().getId() + "', "
+ "as the datasource is unavailable.");
}
+ withinMatchFromPersistedEvents = tableForPerDuration.find(matchingEvent,
+ withinTableCompiledConditions.get(perValue));
+ }
} else {
withinMatchFromPersistedEvents = tableForPerDuration.find(matchingEvent,
withinTableCompiledConditions.get(perValue));
