diff --git a/core/src/main/java/io/kestra/core/serializers/FileSerde.java b/core/src/main/java/io/kestra/core/serializers/FileSerde.java index a7c3aac44fc..056f6e9801b 100644 --- a/core/src/main/java/io/kestra/core/serializers/FileSerde.java +++ b/core/src/main/java/io/kestra/core/serializers/FileSerde.java @@ -18,8 +18,10 @@ abstract public class FileSerde { private static final TypeReference TYPE_REFERENCE = new TypeReference<>(){}; public static void write(OutputStream output, Object row) throws IOException { - output.write(MAPPER.writeValueAsBytes(row)); - output.write("\n".getBytes()); + if (row != null) { // avoid writing "null" + output.write(MAPPER.writeValueAsBytes(row)); + output.write("\n".getBytes()); + } } public static FlowableOnSubscribe reader(BufferedReader input) { diff --git a/core/src/main/java/io/kestra/core/tasks/storages/Concat.java b/core/src/main/java/io/kestra/core/tasks/storages/Concat.java index 54ad463d933..9d6400f6a54 100644 --- a/core/src/main/java/io/kestra/core/tasks/storages/Concat.java +++ b/core/src/main/java/io/kestra/core/tasks/storages/Concat.java @@ -18,7 +18,6 @@ import java.io.FileOutputStream; import java.net.URI; import java.util.List; -import java.util.Map; import static io.kestra.core.utils.Rethrow.throwConsumer; diff --git a/ui/src/utils/utils.js b/ui/src/utils/utils.js index 938ba4a6fd9..79412b7e59d 100644 --- a/ui/src/utils/utils.js +++ b/ui/src/utils/utils.js @@ -84,6 +84,10 @@ export default class Utils { * @return Formatted string. */ static humanFileSize(bytes, si = false, dp = 1) { + if (bytes === undefined) { + // when the size is 0 it arrives as undefined here! + return "0B"; + } const thresh = si ? 1000 : 1024; if (Math.abs(bytes) < thresh) {