You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@nifi.apache.org by ma...@apache.org on 2022/06/21 20:53:39 UTC
[nifi] branch main updated: NIFI-10141: Fix WriteJsonResult logging to show writer's schema (#6142)
This is an automated email from the ASF dual-hosted git repository.
markap14 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 b60b9b8e29 NIFI-10141: Fix WriteJsonResult logging to show writer's schema (#6142)
b60b9b8e29 is described below
commit b60b9b8e29be4839b93c4baeacdd63802a693c29
Author: Matt Burgess <ma...@apache.org>
AuthorDate: Tue Jun 21 16:53:30 2022 -0400
NIFI-10141: Fix WriteJsonResult logging to show writer's schema (#6142)
* NIFI-10141: Fix WriteJsonResult logging to show writer's schema
---
.../src/main/java/org/apache/nifi/json/WriteJsonResult.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/WriteJsonResult.java b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/WriteJsonResult.java
index 5989618591..6348337b4d 100644
--- a/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/WriteJsonResult.java
+++ b/nifi-nar-bundles/nifi-standard-services/nifi-record-serialization-services-bundle/nifi-record-serialization-services/src/main/java/org/apache/nifi/json/WriteJsonResult.java
@@ -218,7 +218,7 @@ public class WriteJsonResult extends AbstractRecordSetWriter implements RecordSe
endTask.apply(generator);
} catch (final Exception e) {
- logger.error("Failed to write {} with schema {} as a JSON Object due to {}", new Object[] {record, record.getSchema(), e.toString(), e});
+ logger.error("Failed to write {} with reader schema {} and writer schema {} as a JSON Object due to {}", record, record.getSchema(), writeSchema, e.toString(), e);
throw e;
}
}