Repository: apex-malhar Updated Branches: refs/heads/master 1683e6e94 -> 243dceb56
APEXMALHAR-2330 JdbcPOJOPollInputOperator fails with NullPointerException when PostgreSQL driver. Using similar case for hashmap and column names irrespective of any database used for JdbcPOJOPollInputOperator. Project: http://git-wip-us.apache.org/repos/asf/apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-malhar/commit/243dceb5 Tree: http://git-wip-us.apache.org/repos/asf/apex-malhar/tree/243dceb5 Diff: http://git-wip-us.apache.org/repos/asf/apex-malhar/diff/243dceb5 Branch: refs/heads/master Commit: 243dceb56447afa0fa6528bcf96a63706652b582 Parents: 1683e6e Author: deepak-narkhede <[email protected]> Authored: Wed Nov 9 19:07:10 2016 +0530 Committer: deepak-narkhede <[email protected]> Committed: Tue Nov 29 13:25:13 2016 +0530 ---------------------------------------------------------------------- .../com/datatorrent/lib/db/jdbc/JdbcPOJOPollInputOperator.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-malhar/blob/243dceb5/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOPollInputOperator.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOPollInputOperator.java b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOPollInputOperator.java index 40919a2..62618de 100644 --- a/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOPollInputOperator.java +++ b/library/src/main/java/com/datatorrent/lib/db/jdbc/JdbcPOJOPollInputOperator.java @@ -195,11 +195,11 @@ public class JdbcPOJOPollInputOperator extends AbstractJdbcPollInputOperator<Obj int type = rsMetaData.getColumnType(i); String name = rsMetaData.getColumnName(i); LOG.debug("column name {} type {}", name, type); - nameToType.put(name, type); + nameToType.put(name.toUpperCase(), type); } for (FieldInfo fieldInfo : fieldInfos) { - columnDataTypes.add(nameToType.get(fieldInfo.getColumnName())); + columnDataTypes.add(nameToType.get(fieldInfo.getColumnName().toUpperCase())); } } }
