You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by pr...@apache.org on 2016/11/29 11:04:11 UTC
apex-malhar git commit: APEXMALHAR-2330 JdbcPOJOPollInputOperator
fails with NullPointerException when PostgreSQL driver.
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 <ma...@gmail.com>
Authored: Wed Nov 9 19:07:10 2016 +0530
Committer: deepak-narkhede <ma...@gmail.com>
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()));
}
}
}