Skip to content
Snippets Groups Projects
Verified Commit 1d792c2e authored by Martin Weise's avatar Martin Weise
Browse files

Applied fix #518

parent b39985de
No related branches found
No related tags found
No related merge requests found
...@@ -167,7 +167,8 @@ public class StorageServiceS3Impl implements StorageService { ...@@ -167,7 +167,8 @@ public class StorageServiceS3Impl implements StorageService {
dataset = sparkSession.read() dataset = sparkSession.read()
.option("delimiter", delimiter) .option("delimiter", delimiter)
.option("header", withHeader) .option("header", withHeader)
.csv(path); .csv(path)
.toDF(columns.toArray(new String[0]));
} catch (Exception e) { } catch (Exception e) {
if (e instanceof AnalysisException) { if (e instanceof AnalysisException) {
final AnalysisException exception = (AnalysisException) e; final AnalysisException exception = (AnalysisException) e;
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment