Repository: nifi Updated Branches: refs/heads/master f0f75e748 -> 2b6d6c25d
NIFI-2866 The Initial Max Value of QueryDatabaseTable won't be case-sensitive Signed-off-by: Matt Burgess <[email protected]> This closes #1212 Project: http://git-wip-us.apache.org/repos/asf/nifi/repo Commit: http://git-wip-us.apache.org/repos/asf/nifi/commit/2b6d6c25 Tree: http://git-wip-us.apache.org/repos/asf/nifi/tree/2b6d6c25 Diff: http://git-wip-us.apache.org/repos/asf/nifi/diff/2b6d6c25 Branch: refs/heads/master Commit: 2b6d6c25d8a35625697d98b4827a6badfb8e2f69 Parents: f0f75e7 Author: Byunghwa Yun <[email protected]> Authored: Sun Nov 13 12:21:14 2016 +0900 Committer: Matt Burgess <[email protected]> Committed: Mon Dec 5 12:50:43 2016 -0500 ---------------------------------------------------------------------- .../org/apache/nifi/processors/standard/QueryDatabaseTable.java | 4 ++-- .../apache/nifi/processors/standard/QueryDatabaseTableTest.java | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/nifi/blob/2b6d6c25/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryDatabaseTable.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryDatabaseTable.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryDatabaseTable.java index 278cc30..da3d496 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryDatabaseTable.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/main/java/org/apache/nifi/processors/standard/QueryDatabaseTable.java @@ -200,8 +200,8 @@ public class QueryDatabaseTable extends AbstractDatabaseFetchProcessor { //If an initial max value for column(s) has been specified using properties, and this column is not in the state manager, sync them to the state property map for(final Map.Entry<String,String> maxProp : maxValueProperties.entrySet()){ - if(!statePropertyMap.containsKey(maxProp.getKey())){ - statePropertyMap.put(maxProp.getKey(), maxProp.getValue()); + if (!statePropertyMap.containsKey(maxProp.getKey().toLowerCase())) { + statePropertyMap.put(maxProp.getKey().toLowerCase(), maxProp.getValue()); } } http://git-wip-us.apache.org/repos/asf/nifi/blob/2b6d6c25/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/QueryDatabaseTableTest.java ---------------------------------------------------------------------- diff --git a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/QueryDatabaseTableTest.java b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/QueryDatabaseTableTest.java index f3904ef..8a6d0b1 100644 --- a/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/QueryDatabaseTableTest.java +++ b/nifi-nar-bundles/nifi-standard-bundle/nifi-standard-processors/src/test/java/org/apache/nifi/processors/standard/QueryDatabaseTableTest.java @@ -635,7 +635,7 @@ public class QueryDatabaseTableTest { cal.setTimeInMillis(0); cal.add(Calendar.MINUTE, 5); - runner.setProperty("initial.maxvalue.created_on", dateFormat.format(cal.getTime().getTime())); + runner.setProperty("initial.maxvalue.CREATED_ON", dateFormat.format(cal.getTime().getTime())); // Initial run with no previous state. Should get only last 4 records runner.run(); runner.assertAllFlowFilesTransferred(QueryDatabaseTable.REL_SUCCESS, 1);
