diff --git a/nifi/user-scripts/parse-es-db-result-for-nlp-request-bulk.py b/nifi/user-scripts/parse-es-db-result-for-nlp-request-bulk.py index 6d3eb944..77227779 100644 --- a/nifi/user-scripts/parse-es-db-result-for-nlp-request-bulk.py +++ b/nifi/user-scripts/parse-es-db-result-for-nlp-request-bulk.py @@ -71,7 +71,7 @@ def process(self, inputStream, outputStream): log.debug("Document id :" + str(record[DOCUMENT_ID_FIELD_NAME]) + " , has no field named " + DOCUMENT_TEXT_FIELD_NAME + ", document will not be added to the queue.") except KeyError: invalid_record_ids.append(record) - log.debug(str(record) + " , has no field named " + DOCUMENT_TEXT_FIELD_NAME + ", document will not be added to the queue.") + log.debug(str(record["_id"]) + " , has no field named " + DOCUMENT_TEXT_FIELD_NAME + ", document will not be added to the queue.") outputStream.write(json.dumps({"content": out_records}).encode("UTF-8"))