diff --git a/c2/c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/operation/DebugOperationHandler.java b/c2/c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/operation/DebugOperationHandler.java index 33ec839c31..22b9cd18b4 100644 --- a/c2/c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/operation/DebugOperationHandler.java +++ b/c2/c2-client-bundle/c2-client-service/src/main/java/org/apache/nifi/c2/client/service/operation/DebugOperationHandler.java @@ -34,6 +34,7 @@ import java.io.ByteArrayOutputStream; import java.io.File; import java.io.IOException; import java.io.UncheckedIOException; +import java.nio.charset.Charset; import java.nio.file.Files; import java.nio.file.Path; import java.nio.file.Paths; @@ -156,12 +157,13 @@ public class DebugOperationHandler implements C2OperationHandler { List contentFilteredFilePaths = new ArrayList<>(); for (Path path : bundleFilePaths) { String fileName = path.getFileName().toString(); - try (Stream fileStream = lines(path)) { + try (Stream fileStream = lines(path, Charset.defaultCharset())) { Path tempDirectory = createTempDirectory(operationId); Path tempFile = Paths.get(tempDirectory.toAbsolutePath().toString(), fileName); Files.write(tempFile, (Iterable) fileStream.filter(contentFilter)::iterator); contentFilteredFilePaths.add(tempFile); } catch (IOException e) { + LOG.error("Error during filtering file content: " + path.toAbsolutePath(), e); throw new UncheckedIOException(e); } }