From cf6d3e4b1fd859d2baaf0ac0e7210bee93eae790 Mon Sep 17 00:00:00 2001 From: danielfeismann Date: Tue, 1 Oct 2024 11:12:01 +0200 Subject: [PATCH] fix ResultEventListener --- .../edu/ie3/simona/event/listener/ResultEventListener.scala | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/src/main/scala/edu/ie3/simona/event/listener/ResultEventListener.scala b/src/main/scala/edu/ie3/simona/event/listener/ResultEventListener.scala index 4d788b1d9c..8067bab917 100644 --- a/src/main/scala/edu/ie3/simona/event/listener/ResultEventListener.scala +++ b/src/main/scala/edu/ie3/simona/event/listener/ResultEventListener.scala @@ -89,9 +89,9 @@ object ResultEventListener extends Transformer3wResultSupport { filePathFuture.flatMap { fileName => val (finalFileName, _) = (enableCompression, fileName.endsWith(".gz")) match { - case (true, true) => (fileName, true) + case (true, true) => (fileName.replace(".gz",""), true) case (true, false) => - (fileName.replace(".csv", ".csv.gz"), true) + (fileName, true) case (false, true) => (fileName.replace(".gz", ""), false) case (false, false) if fileName.endsWith(".csv") => (fileName, false) @@ -107,7 +107,7 @@ object ResultEventListener extends Transformer3wResultSupport { ResultEntityCsvSink( finalFileName, new ResultEntityProcessor(resultClass), - finalFileName.endsWith(".gz"), + enableCompression, ), ) }