feat: use the new FileSerde.readAll() method that improve performance

kestra-io · Aug 13, 2024 · 7696eea · 7696eea
1 parent 2b861aa
commit 7696eea
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/plugin-script/src/main/java/io/kestra/plugin/scripts/jvm/FileTransform.java b/plugin-script/src/main/java/io/kestra/plugin/scripts/jvm/FileTransform.java
@@ -77,10 +77,10 @@ protected FileTransform.Output run(RunContext runContext, String engineName) thr
             OutputStream output = new FileOutputStream(tempFile);
         ) {
             if (from.startsWith("kestra://")) {
-                try (BufferedReader inputStream = new BufferedReader(new InputStreamReader(runContext.storage().getFile(URI.create(from))))) {
+                try (BufferedReader inputStream = new BufferedReader(new InputStreamReader(runContext.storage().getFile(URI.create(from))), FileSerde.BUFFER_SIZE)) {
                     this.finalize(
                         runContext,
-                        Flux.create(FileSerde.reader(inputStream), FluxSink.OverflowStrategy.BUFFER),
+                        FileSerde.readAll(inputStream),
                         scripts,
                         output
                     );