Repository: nifi Updated Branches: refs/heads/master 0222bf8ef -> 9736cb9d3
NIFI-4663 This closes #2317. Change log for document not found from warn to debug as we have a NOT_FOUND relationship Signed-off-by: joewitt <[email protected]> Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/9736cb9d Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/9736cb9d Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/9736cb9d Branch: refs/heads/master Commit: 9736cb9d338b611ff3a096d97fd439cf8b8bbac3 Parents: 0222bf8 Author: William Griffiths <[email protected]> Authored: Tue Dec 5 16:40:00 2017 +0000 Committer: joewitt <[email protected]> Committed: Tue Dec 5 12:44:54 2017 -0500 ---------------------------------------------------------------------- .../apache/nifi/processors/elasticsearch/FetchElasticsearch5.java | 2 +- .../apache/nifi/processors/elasticsearch/FetchElasticsearch.java | 2 +- .../nifi/processors/elasticsearch/FetchElasticsearchHttp.java | 2 +- 3 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/9736cb9d/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-5-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearch5.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-5-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearch5.java b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-5-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearch5.java index ee8674e..9041038 100644 --- a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-5-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearch5.java +++ b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-5-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearch5.java @@ -176,7 +176,7 @@ public class FetchElasticsearch5 extends AbstractElasticsearch5TransportClientPr final GetResponse getResponse = getRequestBuilder.execute().actionGet(); if (getResponse == null || !getResponse.isExists()) { - logger.warn("Failed to read {}/{}/{} from Elasticsearch: Document not found", + logger.debug("Failed to read {}/{}/{} from Elasticsearch: Document not found", new Object[]{index, docType, docId}); // We couldn't find the document, so penalize it and send it to "not found" http://git-wip-us.apache.org/repos/asf/nifi/blob/9736cb9d/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearch.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearch.java b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearch.java index 84f31b7..9edd3f9 100644 --- a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearch.java +++ b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearch.java @@ -176,7 +176,7 @@ public class FetchElasticsearch extends AbstractElasticsearchTransportClientProc final GetResponse getResponse = getRequestBuilder.execute().actionGet(); if (getResponse == null || !getResponse.isExists()) { - logger.warn("Failed to read {}/{}/{} from Elasticsearch: Document not found", + logger.debug("Failed to read {}/{}/{} from Elasticsearch: Document not found", new Object[]{index, docType, docId}); // We couldn't find the document, so penalize it and send it to "not found" http://git-wip-us.apache.org/repos/asf/nifi/blob/9736cb9d/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearchHttp.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearchHttp.java b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearchHttp.java index bb68f7b7..63163e4 100644 --- a/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearchHttp.java +++ b/nifi-nar-bundles/nifi-elasticsearch-bundle/nifi-elasticsearch-processors/src/main/java/org/apache/nifi/processors/elasticsearch/FetchElasticsearchHttp.java @@ -253,7 +253,7 @@ public class FetchElasticsearchHttp extends AbstractElasticsearchHttpProcessor { } session.transfer(flowFile, REL_SUCCESS); } else { - logger.warn("Failed to read {}/{}/{} from Elasticsearch: Document not found", + logger.debug("Failed to read {}/{}/{} from Elasticsearch: Document not found", new Object[]{index, docType, docId}); // We couldn't find the document, so send it to "not found"
