diff --git a/src/main/java/org/geppetto/datasources/ExecuteMultipleQueriesVisitor.java b/src/main/java/org/geppetto/datasources/ExecuteMultipleQueriesVisitor.java index b7d0336..ee80d91 100644 --- a/src/main/java/org/geppetto/datasources/ExecuteMultipleQueriesVisitor.java +++ b/src/main/java/org/geppetto/datasources/ExecuteMultipleQueriesVisitor.java @@ -120,17 +120,9 @@ public QueryResults getResults() throws GeppettoDataSourceException boolean first = true; for(QueryResults result : results.keySet()) { - if(finalResults.getHeader().isEmpty()) - { - finalResults.getHeader().addAll(result.getHeader()); - } - else - { - if(!finalResults.getHeader().equals(result.getHeader())) - { - throw new GeppettoDataSourceException("Multiple queries were executed but they returned incompatible headers"); - } - } + // Merge all headers into finalResults instead of only when is empty + finalResults.getHeader().addAll(result.getHeader()); + BooleanOperator o = results.get(result); switch(o) {