Fixing bad condition in data completeness checker
@@ -210,13 +210,15 @@ public class DataCompletenessTaskUtils {
try {
ResultSetGroup resultSetGroup = CACHE_REGISTRY.getResultSetGroupCache().get(new PinotQuery(pql, dataset));
if (resultSetGroup == null || resultSetGroup.getResultSetCount() <= 0) {
+ return bucketNameToCountStar;
+ }
ResultSet resultSet = resultSetGroup.getResultSet(0);
for (int i = 0; i < resultSet.getRowCount(); i++) {
Long timeValue = Long.valueOf(resultSet.getGroupKeyString(i, 0));
Long count = resultSet.getLong(i, 0);
timeValueToCount.put(timeValue, count);
}
- }
+
} catch (ExecutionException e) {
LOG.error("Exception in getting count *. PQL:{}", pql, e);
