Index: ql/src/java/org/apache/hadoop/hive/ql/stats/jdbc/JDBCStatsPublisher.java =================================================================== --- ql/src/java/org/apache/hadoop/hive/ql/stats/jdbc/JDBCStatsPublisher.java (revision 233053) +++ ql/src/java/org/apache/hadoop/hive/ql/stats/jdbc/JDBCStatsPublisher.java (working copy) @@ -143,8 +143,10 @@ for (int failures = 0;; failures++) { try { insStmt.setString(1, fileID); for (int i = 0; i < JDBCStatsUtils.getSupportedStatistics().size(); i++) { - insStmt.setString(i + 2, stats.get(supportedStatistics.get(i))); +// insStmt.setString(i + 2, stats.get(supportedStatistics.get(i))); + insStmt.setLong(i + 2, Long.valueOf(stats.get(supportedStatistics.get(i)))); } Utilities.executeWithRetry(execUpdate, insStmt, waitWindow, maxRetries); return true; @@ -159,12 +161,12 @@ try { int i; for (i = 0; i < JDBCStatsUtils.getSupportedStatistics().size(); i++) { - updStmt.setString(i + 1, stats.get(supportedStatistics.get(i))); + updStmt.setLong(i + 1, Long.valueOf(stats.get(supportedStatistics.get(i)))); } - updStmt.setString(supportedStatistics.size() + 1, fileID); - updStmt.setString(supportedStatistics.size() + 2, - stats.get(JDBCStatsUtils.getBasicStat())); - updStmt.setString(supportedStatistics.size() + 3, fileID); + updStmt.setLong(supportedStatistics.size() + 1, Long.valueOf(fileID)); + updStmt.setLong(supportedStatistics.size() + 2, + Long.valueOf(stats.get(JDBCStatsUtils.getBasicStat()))); + updStmt.setLong(supportedStatistics.size() + 3, Long.valueOf(fileID)); Utilities.executeWithRetry(execUpdate, updStmt, waitWindow, maxRetries); return true; } catch (SQLRecoverableException ue) {