Github user mattyb149 commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2243#discussion_r157099501
--- Diff:
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/ExecuteSQL.java
---
@@ -268,8 +278,23 @@ public void process(OutputStream out) throws
IOException {
}
});
+ fileToProcess = session.putAttribute(fileToProcess,
CoreAttributes.MIME_TYPE.key(), JdbcCommon.MIME_TYPE_AVRO_BINARY);
session.transfer(fileToProcess, REL_SUCCESS);
}
+ } else if(resultCount == 0){
+ //If we had no inbound FlowFile, no exceptions, and the
SQL generated no result sets (Insert/Update/Delete statements only)
--- End diff --
My memory fails me, did we used to output an empty flow file when the
result set was empty? Just making sure we're keeping consistent behavior :)
---
