This is an automated email from the ASF dual-hosted git repository.
exceptionfactory pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/nifi.git
The following commit(s) were added to refs/heads/main by this push:
new 576046b79dc NIFI-16141 Aligned validation message formatting of
JSLTTransformJSON with JoltTransformJSON (#11472)
576046b79dc is described below
commit 576046b79dc5b88433c990f4df6bebea08917b46
Author: dan-s1 <[email protected]>
AuthorDate: Fri Jul 24 21:12:54 2026 -0400
NIFI-16141 Aligned validation message formatting of JSLTTransformJSON with
JoltTransformJSON (#11472)
Signed-off-by: David Handermann <[email protected]>
---
.../org/apache/nifi/processors/jslt/JSLTTransformJSON.java | 11 +++++++++--
.../apache/nifi/processors/jslt/TestJSLTTransformJSON.java | 2 +-
2 files changed, 10 insertions(+), 3 deletions(-)
diff --git
a/nifi-extension-bundles/nifi-jslt-bundle/nifi-jslt-processors/src/main/java/org/apache/nifi/processors/jslt/JSLTTransformJSON.java
b/nifi-extension-bundles/nifi-jslt-bundle/nifi-jslt-processors/src/main/java/org/apache/nifi/processors/jslt/JSLTTransformJSON.java
index e7f152fcc4d..42b3fa63483 100644
---
a/nifi-extension-bundles/nifi-jslt-bundle/nifi-jslt-processors/src/main/java/org/apache/nifi/processors/jslt/JSLTTransformJSON.java
+++
b/nifi-extension-bundles/nifi-jslt-bundle/nifi-jslt-processors/src/main/java/org/apache/nifi/processors/jslt/JSLTTransformJSON.java
@@ -272,7 +272,14 @@ public class JSLTTransformJSON extends AbstractProcessor {
getJstlExpression(transform, null);
builder.valid(true);
} catch (final RuntimeException e) {
- builder.valid(false).explanation(e.getMessage());
+ final String reason;
+ final Throwable cause = e.getCause();
+ if (cause == null) {
+ reason = e.getMessage();
+ } else {
+ reason = "%s [%s]".formatted(cause.getMessage(),
e.getMessage());
+ }
+ builder.valid(false).explanation(reason);
}
return builder.build();
}
@@ -431,7 +438,7 @@ public class JSLTTransformJSON extends AbstractProcessor {
try (final BufferedReader reader = new BufferedReader(new
InputStreamReader(resourceReference.read()))) {
return
reader.lines().collect(Collectors.joining(System.lineSeparator()));
} catch (final IOException e) {
- throw new UncheckedIOException(String.format("Read JSLT Transform
failed, reason: %s", e.getMessage()), e);
+ throw new UncheckedIOException("Read JSLT Transform failed", e);
}
}
diff --git
a/nifi-extension-bundles/nifi-jslt-bundle/nifi-jslt-processors/src/test/java/org/apache/nifi/processors/jslt/TestJSLTTransformJSON.java
b/nifi-extension-bundles/nifi-jslt-bundle/nifi-jslt-processors/src/test/java/org/apache/nifi/processors/jslt/TestJSLTTransformJSON.java
index 4e7561a08d0..c0c10280dd2 100644
---
a/nifi-extension-bundles/nifi-jslt-bundle/nifi-jslt-processors/src/test/java/org/apache/nifi/processors/jslt/TestJSLTTransformJSON.java
+++
b/nifi-extension-bundles/nifi-jslt-bundle/nifi-jslt-processors/src/test/java/org/apache/nifi/processors/jslt/TestJSLTTransformJSON.java
@@ -123,7 +123,7 @@ public class TestJSLTTransformJSON {
runner.enqueue(json);
final AssertionFailedError assertionFailedError =
assertThrows(AssertionFailedError.class, () -> runner.run());
- assertTrue(assertionFailedError.getMessage().contains("'JSLT
Transformation' is invalid because Read JSLT Transform failed, reason:"));
+ assertTrue(assertionFailedError.getMessage().contains("'JSLT
Transformation' is invalid because") &&
assertionFailedError.getMessage().contains("file"));
}
@ParameterizedTest