Github user patricker commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2868#discussion_r201461138
--- Diff:
nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryDatabaseTable.java
---
@@ -543,5 +550,10 @@ public void processRow(ResultSet resultSet) throws
IOException {
throw new IOException(e);
}
}
+
+ @Override
+ public void rollbackStateChanges() {
+ this.newColMap = this.originalState;
--- End diff --
Yeah... forgot that state wasn't being retrieved from the Max Value
tracker. Thanks for the unit test, this demonstrates the error well. Will
include it in my next update.
---
