fix: do not match cr/nl only in line ending

some tools use \r that will appear multuple time in the same frame so we
should handle that otherwise logs are only flushed in the end.

plugin-script/src/main/java/io/kestra/plugin/scripts/exec/scripts/runners/DockerScriptRunner.java

@@ -45,7 +45,7 @@
 
 public class DockerScriptRunner {
     private static final ReadableBytesTypeConverter READABLE_BYTES_TYPE_CONVERTER = new ReadableBytesTypeConverter();
-    public static final Pattern NEWLINE_PATTERN = Pattern.compile("[\\r\\n]+$");
+    public static final Pattern NEWLINE_PATTERN = Pattern.compile("([^\\r\\n]+)[\\r\\n]+");
 
     private final RetryUtils retryUtils;
 
@@ -127,13 +127,21 @@ public void onNext(Frame frame) {
                             String frameStr = new String(frame.getPayload());
 
                             Matcher newLineMatcher = NEWLINE_PATTERN.matcher(frameStr);
-                            logBuffers.computeIfAbsent(frame.getStreamType(), streamType -> new StringBuilder())
-                                .append(newLineMatcher.replaceAll(""));
 
-                            if (newLineMatcher.reset().find()) {
+                            int lastIndex = 0;
+                            while (newLineMatcher.find()) {
+                                String fragment = newLineMatcher.group(1);
+                                logBuffers.computeIfAbsent(frame.getStreamType(), streamType -> new StringBuilder())
+                                    .append(fragment);
+
                                 StringBuilder logBuffer = logBuffers.get(frame.getStreamType());
                                 defaultLogConsumer.accept(logBuffer.toString(), frame.getStreamType() == StreamType.STDERR);
                                 logBuffer.setLength(0);
+                                lastIndex = newLineMatcher.end();
+                            }
+                            if (lastIndex < frameStr.length()) {
+                                logBuffers.computeIfAbsent(frame.getStreamType(), streamType -> new StringBuilder())
+                                    .append(frameStr.substring(lastIndex));
                             }
                         }
 

plugin-script/src/test/java/io/kestra/plugin/scripts/runners/LogConsumerTest.java

@@ -55,4 +55,37 @@ public String getType() {
         assertThat(run.getLogConsumer().getStdOutCount(), is(2));
         assertThat(run.getLogConsumer().getOutputs().get("someOutput"), is(outputValue));
     }
+
+    @Test
+    void carryreturn() throws Exception {
+        Task task = new Task() {
+            @Override
+            public String getId() {
+                return "id";
+            }
+
+            @Override
+            public String getType() {
+                return "type";
+            }
+        };
+        RunContext runContext = TestsUtils.mockRunContext(runContextFactory, task, ImmutableMap.of());
+        StringBuilder outputValue = new StringBuilder();
+        for (int i = 0; i < 3; i++) {
+            outputValue.append(Integer.toString(i).repeat(100)).append("\r")
+                    .append(Integer.toString(i).repeat(800)).append("\r")
+                .append(Integer.toString(i).repeat(2000)).append("\r");
+        }
+        RunnerResult run = new DockerScriptRunner(applicationContext).run(
+            new CommandsWrapper(runContext).withCommands(List.of(
+                "/bin/sh", "-c",
+                "echo " + outputValue +
+                    "echo -n another line"
+            )),
+            DockerOptions.builder().image("alpine").build()
+        );
+
+        Await.until(() -> run.getLogConsumer().getStdOutCount() == 10, null, Duration.ofSeconds(5));
+        assertThat(run.getLogConsumer().getStdOutCount(), is(10));
+    }
 }