Github user patricker commented on a diff in the pull request:
https://github.com/apache/nifi/pull/2868#discussion_r201466437
--- 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 --
Unit test is passing now (thanks again for that). Tried to avoid the word
`save` in the updated code, so as not to imply that state is being saved at
that point in time.
---
