Fix streamQueryResults in case of a failed SQL query (#3591)

ingef · Oct 7, 2024 · 408e6cc · 408e6cc
1 parent a9a97d0
commit 408e6cc
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/backend/src/main/java/com/bakdata/conquery/sql/execution/SqlExecutionState.java b/backend/src/main/java/com/bakdata/conquery/sql/execution/SqlExecutionState.java
@@ -38,6 +38,10 @@ public SqlExecutionState(ExecutionState state, List<String> columnNames, List<En
 
 	@Override
 	public Stream<EntityResult> streamQueryResults() {
+		// when the SQL execution fails, table is null
+		if (table == null) {
+			return Stream.empty();
+		}
 		return table.stream();
 	}
 }