Merge pull request #3807 from ingef/fix/excel-result-init

thoniTUB · web-flow · commit 45d6858d5e49 · 2025-11-05T11:48:19.000+01:00
fix: excel result init
diff --git a/backend/src/main/java/com/bakdata/conquery/apiv1/QueryProcessor.java b/backend/src/main/java/com/bakdata/conquery/apiv1/QueryProcessor.java
@@ -622,7 +622,7 @@ public <E extends ManagedExecution & SingleTableResult> ResultStatistics getResu
 
 		managedQuery.initExecutable();
 
-		final List<ResultInfo> resultInfos = managedQuery.getResultInfos();
+		final List<ResultInfo> resultInfos = managedQuery.collectResultInfos();
 
 		final Optional<ResultInfo>
 				dateInfo =
diff --git a/backend/src/main/java/com/bakdata/conquery/io/result/arrow/ResultArrowProcessor.java b/backend/src/main/java/com/bakdata/conquery/io/result/arrow/ResultArrowProcessor.java
@@ -103,7 +103,7 @@ public static <E extends ManagedExecution & SingleTableResult> Response getArrow
 
 		// Collect ResultInfos for id columns and result columns
 		final List<ResultInfo> resultInfosId = config.getIdColumns().getIdResultInfos();
-		final List<ResultInfo> resultInfosExec = exec.getResultInfos();
+		final List<ResultInfo> resultInfosExec = exec.collectResultInfos();
 
 		StreamingOutput out = output -> {
 			CountingOutputStream countingOutputStream = new CountingOutputStream(output);
diff --git a/backend/src/main/java/com/bakdata/conquery/io/result/csv/ResultCsvProcessor.java b/backend/src/main/java/com/bakdata/conquery/io/result/csv/ResultCsvProcessor.java
@@ -63,7 +63,7 @@ public <E extends ManagedExecution & SingleTableResult> Response createResult(E
 		final StreamingOutput out = os -> {
 			try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(os, charset))) {
 				final CsvRenderer renderer = new CsvRenderer(config.getCsv().createWriter(writer), settings);
-				renderer.toCSV(config.getIdColumns().getIdResultInfos(), exec.getResultInfos(), exec.streamResults(limit), settings, charset);
+				renderer.toCSV(config.getIdColumns().getIdResultInfos(), exec.collectResultInfos(), exec.streamResults(limit), settings, charset);
 			}
 			catch (EofException e) {
 				log.trace("User canceled download");
diff --git a/backend/src/main/java/com/bakdata/conquery/io/result/parquet/ResultParquetProcessor.java b/backend/src/main/java/com/bakdata/conquery/io/result/parquet/ResultParquetProcessor.java
@@ -60,7 +60,7 @@ public Response createResultFile(Subject subject, ManagedExecutionId execId, boo
 			ParquetRenderer.writeToStream(
 					output,
 					config.getIdColumns().getIdResultInfos(),
-					singleTableResult.getResultInfos(),
+					singleTableResult.collectResultInfos(),
 					settings,
 					singleTableResult.streamResults(limit)
 			);
diff --git a/backend/src/main/java/com/bakdata/conquery/models/forms/managed/ManagedInternalForm.java b/backend/src/main/java/com/bakdata/conquery/models/forms/managed/ManagedInternalForm.java
@@ -21,6 +21,7 @@
 import com.bakdata.conquery.models.identifiable.ids.specific.UserId;
 import com.bakdata.conquery.models.messages.namespaces.specific.ExecuteForm;
 import com.bakdata.conquery.models.query.ColumnDescriptor;
+import com.bakdata.conquery.models.query.ExecutionManager;
 import com.bakdata.conquery.models.query.ManagedQuery;
 import com.bakdata.conquery.models.query.QueryResolveContext;
 import com.bakdata.conquery.models.query.SingleTableResult;
@@ -142,11 +143,18 @@ public List<ColumnDescriptor> generateColumnDescriptions(boolean isInitialized,
 
 	@Override
 	@JsonIgnore
-	public List<ResultInfo> getResultInfos() {
+	public List<ResultInfo> collectResultInfos() {
 		if (subQueries.size() != 1) {
 			throw new UnsupportedOperationException("Cannot gather result info when multiple tables are generated");
 		}
-		return ((ManagedQuery) subQueries.values().iterator().next().resolve()).getResultInfos();
+		return ((ManagedQuery) subQueries.values().iterator().next().resolve()).collectResultInfos();
+	}
+
+	@Override
+	@JsonIgnore
+	public List<ResultInfo> getResultInfos() {
+		ExecutionManager.InternalExecutionInfo executionInfo = getNamespace().getExecutionManager().getExecutionInfo(getId());
+		return executionInfo.getResultInfos();
 	}
 
 	@Override
diff --git a/backend/src/main/java/com/bakdata/conquery/models/query/DistributedExecutionManager.java b/backend/src/main/java/com/bakdata/conquery/models/query/DistributedExecutionManager.java
@@ -1,6 +1,7 @@
 package com.bakdata.conquery.models.query;
 
 import java.util.Collection;
+import java.util.Collections;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
@@ -23,6 +24,7 @@
 import com.bakdata.conquery.models.identifiable.ids.specific.ManagedExecutionId;
 import com.bakdata.conquery.models.identifiable.ids.specific.WorkerId;
 import com.bakdata.conquery.models.messages.namespaces.specific.CancelQuery;
+import com.bakdata.conquery.models.query.resultinfo.ResultInfo;
 import com.bakdata.conquery.models.query.results.EntityResult;
 import com.bakdata.conquery.models.query.results.ShardResult;
 import com.bakdata.conquery.models.worker.DatasetRegistry;
@@ -51,10 +53,12 @@ protected <E extends ManagedExecution & InternalExecution> void doExecute(E exec
 
 		log.info("Executing Query[{}] in Dataset[{}]", execution.getQueryId(), execution.getDataset());
 
-		addState(execution.getId(), new DistributedExecutionInfo());
+		List<ResultInfo> resultInfo = execution instanceof SingleTableResult singleTableResult ? singleTableResult.collectResultInfos() : Collections.emptyList();
+
+		addState(execution.getId(), new DistributedExecutionInfo(resultInfo));
 
 		if (execution instanceof ManagedInternalForm<?> form) {
-			form.getSubQueries().values().forEach((query) -> addState(query, new DistributedExecutionInfo()));
+			form.getSubQueries().values().forEach((query) -> addState(query, new DistributedExecutionInfo(form.collectResultInfos())));
 		}
 
 		final WorkerHandler workerHandler = getWorkerHandler(execution.getDataset());
@@ -146,10 +150,11 @@ public static class DistributedExecutionInfo implements InternalExecutionInfo {
 		@NonNull
 		private ExecutionState executionState;
 		private Map<WorkerId, List<EntityResult>> results;
+		private List<ResultInfo> resultInfos;
 		private CountDownLatch executingLock;
 
-		public DistributedExecutionInfo() {
-			this(ExecutionState.RUNNING, new ConcurrentHashMap<>(), new CountDownLatch(1));
+		public DistributedExecutionInfo(List<ResultInfo> resultInfos) {
+			this(ExecutionState.RUNNING, new ConcurrentHashMap<>(), resultInfos, new CountDownLatch(1));
 		}
 
 		@NotNull
diff --git a/backend/src/main/java/com/bakdata/conquery/models/query/ExecutionManager.java b/backend/src/main/java/com/bakdata/conquery/models/query/ExecutionManager.java
@@ -2,6 +2,7 @@
 
 import static com.bakdata.conquery.models.execution.ExecutionState.RUNNING;
 
+import java.util.List;
 import java.util.NoSuchElementException;
 import java.util.Optional;
 import java.util.UUID;
@@ -22,6 +23,7 @@
 import com.bakdata.conquery.models.forms.managed.ExternalExecution;
 import com.bakdata.conquery.models.identifiable.ids.specific.ManagedExecutionId;
 import com.bakdata.conquery.models.identifiable.ids.specific.UserId;
+import com.bakdata.conquery.models.query.resultinfo.ResultInfo;
 import com.bakdata.conquery.models.query.results.EntityResult;
 import com.bakdata.conquery.models.worker.DatasetRegistry;
 import com.bakdata.conquery.models.worker.Namespace;
@@ -299,6 +301,7 @@ public interface ExecutionInfo {
 
 	public interface InternalExecutionInfo extends ExecutionInfo {
 		Stream<EntityResult> streamQueryResults();
+		List<ResultInfo> getResultInfos();
 	}
 
 
diff --git a/backend/src/main/java/com/bakdata/conquery/models/query/ManagedQuery.java b/backend/src/main/java/com/bakdata/conquery/models/query/ManagedQuery.java
@@ -117,11 +117,18 @@ protected void setAdditionalFieldsForStatusWithColumnDescription(Subject subject
 	}
 
 	@JsonIgnore
-	public List<ResultInfo> getResultInfos() {
+	public List<ResultInfo> collectResultInfos() {
 		Preconditions.checkState(isInitialized());
 		return query.getResultInfos();
 	}
 
+	@Override
+	@JsonIgnore
+	public List<ResultInfo> getResultInfos() {
+		ExecutionManager.InternalExecutionInfo executionInfo = getNamespace().getExecutionManager().getExecutionInfo(getId());
+		return executionInfo.getResultInfos();
+	}
+
 	@Override
 	@JsonIgnore
 	public QueryDescription getSubmitted() {
@@ -132,8 +139,8 @@ public QueryDescription getSubmitted() {
 	 * Creates a default label based on the submitted {@link QueryDescription}.
 	 * The Label is customized by mentioning that a description contained a
 	 * {@link CQExternal}, {@link CQReusedQuery} or {@link CQConcept}, in this order.
-	 * In case of one ore more {@link CQConcept} the distinct labels of the concepts are chosen
-	 * and concatinated until a length of MAX_CONCEPT_LABEL_CONCAT_LENGTH is reached.
+	 * In case of one or more {@link CQConcept} the distinct labels of the concepts are chosen
+	 * and concatenated until a length of MAX_CONCEPT_LABEL_CONCAT_LENGTH is reached.
 	 * All further labels are dropped.
 	 */
 	@Override
diff --git a/backend/src/main/java/com/bakdata/conquery/models/query/SingleTableResult.java b/backend/src/main/java/com/bakdata/conquery/models/query/SingleTableResult.java
@@ -36,13 +36,25 @@ default List<ColumnDescriptor> generateColumnDescriptions(boolean isInitialized,
 		}
 
 		final UniqueNamer collector = new UniqueNamer(settings);
-		getResultInfos().forEach(info -> columnDescriptions.add(info.asColumnDescriptor(collector, settings)));
+		collectResultInfos().forEach(info -> columnDescriptions.add(info.asColumnDescriptor(collector, settings)));
 		return columnDescriptions;
 	}
 
 	@JsonIgnore
 	Namespace getNamespace();
 
+	/**
+	 * Collect result infos from the submitted query that this execution wraps
+	 * @return The result infos for this execution
+	 * @implNote The execution may need to be initialised beforehand
+	 */
+	@JsonIgnore
+	List<ResultInfo> collectResultInfos();
+
+	/**
+	 * Collect result infos from the submitted query that this execution wraps
+	 * @return The result infos for this execution
+	 */
 	@JsonIgnore
 	List<ResultInfo> getResultInfos();
 
diff --git a/backend/src/main/java/com/bakdata/conquery/models/query/preview/EntityPreviewExecution.java b/backend/src/main/java/com/bakdata/conquery/models/query/preview/EntityPreviewExecution.java
@@ -155,13 +155,14 @@ private List<EntityPreviewStatus.Info> transformQueryResultToInfos(
 
 		// Submitted Query is a single line of an AbsoluteFormQuery => MultilineEntityResult with a single line.
 		final MultilineEntityResult result = (MultilineEntityResult) infoCardExecution.streamResults(OptionalLong.empty()).collect(MoreCollectors.onlyElement());
-		final Object[] values = result.getValues().get(0);
+		final Object[] values = result.getValues().getFirst();
 
 		final List<EntityPreviewStatus.Info> extraInfos = new ArrayList<>(values.length);
 
 		// We are only interested in the Select results.
-		for (int index = AbsoluteFormQuery.FEATURES_OFFSET; index < infoCardExecution.getResultInfos().size(); index++) {
-			final ResultInfo resultInfo = infoCardExecution.getResultInfos().get(index);
+		List<ResultInfo> resultInfos = infoCardExecution.collectResultInfos();
+		for (int index = AbsoluteFormQuery.FEATURES_OFFSET; index < resultInfos.size(); index++) {
+			final ResultInfo resultInfo = resultInfos.get(index);
 
 			final Object value = values[index];
 			final Object printed;
@@ -206,7 +207,7 @@ private List<EntityPreviewStatus.TimeStratifiedInfos> toChronoInfos(
 					description.selects().stream().collect(Collectors.toMap(PreviewConfig.InfoCardSelect::select, Function.identity()));
 
 			// Group lines by year and quarter.
-			final Function<Object[], Map<String, Object>> lineTransformer = createLineToMapTransformer(query.getResultInfos(), select2desc, printSettings, printers);
+			final Function<Object[], Map<String, Object>> lineTransformer = createLineToMapTransformer(query.collectResultInfos(), select2desc, printSettings, printers);
 			final List<EntityPreviewStatus.YearEntry> yearEntries = createYearEntries(entityResult, lineTransformer);
 
 			final Object[] completeResult = getCompleteLine(entityResult);
@@ -315,7 +316,7 @@ private static List<ColumnDescriptor> createChronoColumnDescriptors(SingleTableR
 
 		final List<ColumnDescriptor> columnDescriptions = new ArrayList<>();
 
-		for (ResultInfo info : query.getResultInfos()) {
+		for (ResultInfo info : query.collectResultInfos()) {
 			if (info instanceof SelectResultInfo selectResultInfo) {
 				final PreviewConfig.InfoCardSelect desc = select2desc.get(selectResultInfo.getSelect().getId());
 
@@ -347,7 +348,7 @@ private static Map<Integer, Object[]> getYearLines(EntityResult entityResult) {
 			}
 
 			// Since we know the dates are always aligned we need to only respect their starts.
-			final LocalDate date = CDate.toLocalDate(((List<Integer>) line[AbsoluteFormQuery.TIME_INDEX]).get(0));
+			final LocalDate date = CDate.toLocalDate(((List<Integer>) line[AbsoluteFormQuery.TIME_INDEX]).getFirst());
 
 			final int year = date.getYear();
 
@@ -369,7 +370,7 @@ private static Map<Integer, Map<Integer, Object[]>> getQuarterLines(EntityResult
 			}
 
 			// Since we know the dates are always aligned we need to only respect their starts.
-			final LocalDate date = CDate.toLocalDate(((List<Integer>) line[AbsoluteFormQuery.TIME_INDEX]).get(0));
+			final LocalDate date = CDate.toLocalDate(((List<Integer>) line[AbsoluteFormQuery.TIME_INDEX]).getFirst());
 
 			final int year = date.getYear();
 			final int quarter = QuarterUtils.getQuarter(date);
@@ -386,8 +387,8 @@ protected void setAdditionalFieldsForStatusWithSource(Subject subject, FullExecu
 	}
 
 	@Override
-	public List<ResultInfo> getResultInfos() {
-		return getValuesQuery().getResultInfos();
+	public List<ResultInfo> collectResultInfos() {
+		return getValuesQuery().collectResultInfos();
 	}
 
 	@Override
diff --git a/backend/src/main/java/com/bakdata/conquery/sql/conquery/SqlExecutionManager.java b/backend/src/main/java/com/bakdata/conquery/sql/conquery/SqlExecutionManager.java
@@ -72,7 +72,7 @@ private CompletableFuture<Void> executeAsync(ManagedQuery managedQuery) {
 									SqlExecutionExecutionInfo startResult = getExecutionInfo(id);
 									SqlExecutionExecutionInfo
 											finishResult =
-											new SqlExecutionExecutionInfo(ExecutionState.DONE, result.getColumnNames(), result.getTable(), startResult.getExecutingLock());
+											new SqlExecutionExecutionInfo(ExecutionState.DONE, result.getColumnNames(), result.getTable(), result.getResultInfos(), startResult.getExecutingLock());
 									addState(id, finishResult);
 
 									managedQuery.finish(ExecutionState.DONE);
diff --git a/backend/src/main/java/com/bakdata/conquery/sql/execution/SqlExecutionExecutionInfo.java b/backend/src/main/java/com/bakdata/conquery/sql/execution/SqlExecutionExecutionInfo.java
@@ -6,6 +6,7 @@
 
 import com.bakdata.conquery.models.execution.ExecutionState;
 import com.bakdata.conquery.models.query.ExecutionManager;
+import com.bakdata.conquery.models.query.resultinfo.ResultInfo;
 import com.bakdata.conquery.models.query.results.EntityResult;
 import lombok.Data;
 import lombok.Setter;
@@ -17,6 +18,7 @@ public class SqlExecutionExecutionInfo implements ExecutionManager.InternalExecu
 	ExecutionState executionState;
 	List<String> columnNames;
 	List<EntityResult> table;
+	private List<ResultInfo> resultInfos;
 	int rowCount;
 	CountDownLatch executingLock;
 
@@ -28,9 +30,10 @@ public SqlExecutionExecutionInfo() {
 		rowCount = 0;
 	}
 
-	public SqlExecutionExecutionInfo(ExecutionState executionState, List<String> columnNames, List<EntityResult> table, CountDownLatch executingLock) {
+	public SqlExecutionExecutionInfo(ExecutionState executionState, List<String> columnNames, List<EntityResult> table, List<ResultInfo> resultInfos, CountDownLatch executingLock) {
 		this.executionState = executionState;
 		this.columnNames = columnNames;
+		this.resultInfos = resultInfos;
 		this.table = table;
 		this.executingLock = executingLock;
 		rowCount = table.size();
diff --git a/backend/src/main/java/com/bakdata/conquery/sql/execution/SqlExecutionService.java b/backend/src/main/java/com/bakdata/conquery/sql/execution/SqlExecutionService.java
@@ -50,7 +50,8 @@ public SqlExecutionExecutionInfo execute(SqlQuery sqlQuery) {
 	private SqlExecutionExecutionInfo createStatementAndExecute(SqlQuery sqlQuery, Connection connection) {
 
 		final String sqlString = sqlQuery.getSql();
-		final List<ResultType> resultTypes = sqlQuery.getResultInfos().stream().map(ResultInfo::getType).collect(Collectors.toList());
+		List<ResultInfo> resultInfos = sqlQuery.getResultInfos();
+		final List<ResultType> resultTypes = resultInfos.stream().map(ResultInfo::getType).collect(Collectors.toList());
 
 		log.info("Executing query: \n{}", sqlString);
 
@@ -60,7 +61,7 @@ private SqlExecutionExecutionInfo createStatementAndExecute(SqlQuery sqlQuery, C
 			final List<String> columnNames = getColumnNames(resultSet, columnCount);
 			final List<EntityResult> resultTable = createResultTable(resultSet, resultTypes, columnCount);
 
-			return new SqlExecutionExecutionInfo(ExecutionState.RUNNING, columnNames, resultTable, new CountDownLatch(1));
+			return new SqlExecutionExecutionInfo(ExecutionState.RUNNING, columnNames, resultTable, resultInfos, new CountDownLatch(1));
 		}
 		// not all DB vendors throw SQLExceptions
 		catch (SQLException | RuntimeException e) {
diff --git a/backend/src/test/java/com/bakdata/conquery/api/StoredQueriesProcessorTest.java b/backend/src/test/java/com/bakdata/conquery/api/StoredQueriesProcessorTest.java
@@ -152,7 +152,7 @@ public static void beforeAll() throws IOException {
 				mockManagedConceptQueryFrontEnd(USERS[0], QUERY_ID_5, FAILED, DATASET_0, 100L),        // not included: wrong state
 				mockManagedQuery(new AbsoluteFormQuery(null, null, null, null), USERS[0], QUERY_ID_6, NEW, DATASET_0, 100L),                                                    // not included: wrong query structure
 				mockManagedSecondaryIdQueryFrontEnd(USERS[1], QUERY_ID_7, DONE, new CQAnd() {{
-					setChildren(List.of(new CQConcept()));
+					setChildren(List.of(new CQConcept(){{setLabel("User Concept Label");}}));
 				}}, DATASET_0),    // included, but secondaryId-Query
 				mockManagedSecondaryIdQueryFrontEnd(USERS[1], QUERY_ID_8, DONE, new CQConcept(), DATASET_0),    // not-included, wrong structure
 				mockManagedQuery(new ConceptQuery(new CQExternal(new ArrayList<>(), new String[0][0], false)), USERS[1], QUERY_ID_9, DONE, DATASET_0, 100L),        // included
@@ -163,7 +163,7 @@ public static void beforeAll() throws IOException {
 
 	private static void setState(ExecutionState execState, ManagedExecutionId id) {
 		if (execState != NEW) {
-			DistributedExecutionManager.DistributedExecutionInfo state = new DistributedExecutionManager.DistributedExecutionInfo();
+			DistributedExecutionManager.DistributedExecutionInfo state = new DistributedExecutionManager.DistributedExecutionInfo(Collections.emptyList());
 			state.setExecutionState(execState);
 			state.getExecutingLock().countDown();
 
@@ -182,8 +182,9 @@ private static ManagedQuery mockManagedConceptQueryFrontEnd(User user, ManagedEx
 		return mockManagedQuery(
 				new ConceptQuery(
 						new CQAnd() {{
-							// short hand class initializer block to support visiting of CQAnd Children
-							setChildren(List.of(new CQConcept()));
+							// Shorthand class initializer block to support visiting of CQAnd Children
+							// We set a user label here, so that no ConceptId needs to be resolved
+							setChildren(List.of(new CQConcept() {{ setLabel("User Concept Label");}}));
 						}}
 				),
 				user,
@@ -212,7 +213,7 @@ private static ManagedQuery mockManagedQuery(Query queryDescription, User user,
 			}
 
 			@Override
-			public List<ResultInfo> getResultInfos() {
+			public List<ResultInfo> collectResultInfos() {
 				// With method is mocked because the ExcelResultProvider needs some info to check dimensions,
 				// but actually resolving the query here requires much more setup
 				return Collections.emptyList();
@@ -263,7 +264,7 @@ private static ExecutionStatus makeState(ManagedExecutionId id, User owner, User
 			}
 
 			@Override
-			public List<ResultInfo> getResultInfos() {
+			public List<ResultInfo> collectResultInfos() {
 				return Collections.emptyList();
 			}
 		};
diff --git a/backend/src/test/java/com/bakdata/conquery/integration/DownloadLinkGeneration.java b/backend/src/test/java/com/bakdata/conquery/integration/DownloadLinkGeneration.java
@@ -3,6 +3,7 @@
 import static org.assertj.core.api.Assertions.assertThat;
 
 import java.net.URI;
+import java.util.Collections;
 import java.util.Set;
 
 import com.bakdata.conquery.apiv1.execution.FullExecutionStatus;
@@ -22,9 +23,7 @@
 import com.bakdata.conquery.models.query.DistributedExecutionManager;
 import com.bakdata.conquery.models.query.ManagedQuery;
 import com.bakdata.conquery.util.support.StandaloneSupport;
-import io.github.classgraph.Resource;
 import lombok.extern.slf4j.Slf4j;
-import org.apache.commons.io.IOUtils;
 
 @Slf4j
 public class DownloadLinkGeneration extends IntegrationTest.Simple implements ProgrammaticIntegrationTest {
@@ -62,7 +61,7 @@ public void execute(StandaloneSupport conquery) throws Exception {
 
 		{
 			// Tinker the state of the execution and try again: still not possible because of missing permissions
-			DistributedExecutionManager.DistributedExecutionInfo distributedState = new DistributedExecutionManager.DistributedExecutionInfo();
+			DistributedExecutionManager.DistributedExecutionInfo distributedState = new DistributedExecutionManager.DistributedExecutionInfo(Collections.emptyList());
 			distributedState.setExecutionState(ExecutionState.DONE);
 			distributedState.getExecutingLock().countDown();
 			conquery.getNamespace().getExecutionManager().addState(exec.getId(), distributedState);
diff --git a/backend/src/test/java/com/bakdata/conquery/integration/json/AbstractQueryEngineTest.java b/backend/src/test/java/com/bakdata/conquery/integration/json/AbstractQueryEngineTest.java
@@ -52,7 +52,7 @@ public void executeTest(StandaloneSupport standaloneSupport) throws IOException
 		execution.initExecutable();
 		SingleTableResult executionResult = (SingleTableResult) execution;
 
-		List<ResultInfo> resultInfos = executionResult.getResultInfos();
+		List<ResultInfo> resultInfos = executionResult.collectResultInfos();
 
 		assertThat(executionResult.streamResults(OptionalLong.empty()).flatMap(EntityResult::streamValues))
 				.as("Should have same size as result infos")
diff --git a/backend/src/test/java/com/bakdata/conquery/integration/json/FormTest.java b/backend/src/test/java/com/bakdata/conquery/integration/json/FormTest.java
diff --git a/backend/src/test/java/com/bakdata/conquery/io/result/ResultTestUtil.java b/backend/src/test/java/com/bakdata/conquery/io/result/ResultTestUtil.java
diff --git a/backend/src/test/java/com/bakdata/conquery/io/result/arrow/ArrowResultGenerationTest.java b/backend/src/test/java/com/bakdata/conquery/io/result/arrow/ArrowResultGenerationTest.java
diff --git a/backend/src/test/java/com/bakdata/conquery/io/result/csv/CsvResultGenerationTest.java b/backend/src/test/java/com/bakdata/conquery/io/result/csv/CsvResultGenerationTest.java
diff --git a/backend/src/test/java/com/bakdata/conquery/io/result/parquet/ParquetResultGenerationTest.java b/backend/src/test/java/com/bakdata/conquery/io/result/parquet/ParquetResultGenerationTest.java

Original file line number	Diff line number	Diff line change
`@@ -63,7 +63,7 @@ public <E extends ManagedExecution & SingleTableResult> Response createResult(E`
`63`	`63`	`final StreamingOutput out = os -> {`
`64`	`64`	`try (BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(os, charset))) {`
`65`	`65`	`final CsvRenderer renderer = new CsvRenderer(config.getCsv().createWriter(writer), settings);`
`66`		`- renderer.toCSV(config.getIdColumns().getIdResultInfos(), exec.getResultInfos(), exec.streamResults(limit), settings, charset);`
	`66`	`+ renderer.toCSV(config.getIdColumns().getIdResultInfos(), exec.collectResultInfos(), exec.streamResults(limit), settings, charset);`
`67`	`67`	`}`
`68`	`68`	`catch (EofException e) {`
`69`	`69`	`log.trace("User canceled download");`