adds table assertion for Import

ingef · Sep 20, 2021 · 5c11a85 · 5c11a85
1 parent 1f410d3
commit 5c11a85
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) {