Merge pull request #2088 from bakdata/fix/import-column-check

adds table assertion for Import
ingef · Sep 20, 2021 · 292f4f5 · 292f4f5
2 parents 1f410d3 + 5c11a85
commit 292f4f5
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/backend/src/main/java/com/bakdata/conquery/models/jobs/ImportJob.java b/backend/src/main/java/com/bakdata/conquery/models/jobs/ImportJob.java
@@ -109,6 +109,9 @@ public static ImportJob create(
 				throw new BadRequestException(String.format("Table[%s] does not exist.", tableId));
 			}
 
+			// Ensure that Import and Table have the same schema
+			header.assertMatch(table);
+
 			final ImportId importId = new ImportId(table.getId(), header.getName());
 
 			if (namespace.getStorage().getImport(importId) != null) {