diff --git a/dbrepo-data-service/services/src/main/java/at/ac/tuwien/ifs/dbrepo/service/impl/StorageServiceS3Impl.java b/dbrepo-data-service/services/src/main/java/at/ac/tuwien/ifs/dbrepo/service/impl/StorageServiceS3Impl.java
index d29f5e2a2dc8c864402c4d0d66c4ab7de336461b..2e3b892757f54b260ed787ea8068269fca185639 100644
--- a/dbrepo-data-service/services/src/main/java/at/ac/tuwien/ifs/dbrepo/service/impl/StorageServiceS3Impl.java
+++ b/dbrepo-data-service/services/src/main/java/at/ac/tuwien/ifs/dbrepo/service/impl/StorageServiceS3Impl.java
@@ -167,7 +167,8 @@ public class StorageServiceS3Impl implements StorageService {
             dataset = sparkSession.read()
                     .option("delimiter", delimiter)
                     .option("header", withHeader)
-                    .csv(path);
+                    .csv(path)
+                    .toDF(columns.toArray(new String[0]));
         } catch (Exception e) {
             if (e instanceof AnalysisException) {
                 final AnalysisException exception = (AnalysisException) e;