From 1d792c2e2f41473948c60fdf2848620360b7fffb Mon Sep 17 00:00:00 2001
From: Martin Weise <martin.weise@tuwien.ac.at>
Date: Sun, 25 May 2025 08:21:49 +0200
Subject: [PATCH] Applied fix #518
Signed-off-by: Martin Weise <martin.weise@tuwien.ac.at>
---
.../tuwien/ifs/dbrepo/service/impl/StorageServiceS3Impl.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
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 d29f5e2a2d..2e3b892757 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;
--
GitLab