Repository: sqoop Updated Branches: refs/heads/trunk 159e924d4 -> 28f5aa03b
SQOOP-1400: Failed to import data using mysql-connector-java-5.1.17.jar (Richard via Jarek Jarcec Cecho) Project: http://git-wip-us.apache.org/repos/asf/sqoop/repo Commit: http://git-wip-us.apache.org/repos/asf/sqoop/commit/28f5aa03 Tree: http://git-wip-us.apache.org/repos/asf/sqoop/tree/28f5aa03 Diff: http://git-wip-us.apache.org/repos/asf/sqoop/diff/28f5aa03 Branch: refs/heads/trunk Commit: 28f5aa03ba182a40e1609a02f389d490f9108147 Parents: 159e924 Author: Jarek Jarcec Cecho <[email protected]> Authored: Thu Jul 24 20:12:41 2014 -0700 Committer: Jarek Jarcec Cecho <[email protected]> Committed: Thu Jul 24 20:12:41 2014 -0700 ---------------------------------------------------------------------- src/java/org/apache/sqoop/manager/MySQLManager.java | 16 ---------------- 1 file changed, 16 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/sqoop/blob/28f5aa03/src/java/org/apache/sqoop/manager/MySQLManager.java ---------------------------------------------------------------------- diff --git a/src/java/org/apache/sqoop/manager/MySQLManager.java b/src/java/org/apache/sqoop/manager/MySQLManager.java index e1d5a36..b9c9d36 100644 --- a/src/java/org/apache/sqoop/manager/MySQLManager.java +++ b/src/java/org/apache/sqoop/manager/MySQLManager.java @@ -64,22 +64,6 @@ public class MySQLManager } @Override - protected void initOptionDefaults() { - if (options.getFetchSize() == null) { - LOG.info("Preparing to use a MySQL streaming resultset."); - options.setFetchSize(Integer.MIN_VALUE); - } else if ( - !options.getFetchSize().equals(Integer.MIN_VALUE) - && !options.getFetchSize().equals(0)) { - LOG.info("Argument '--fetch-size " + options.getFetchSize() - + "' will probably get ignored by MySQL JDBC driver."); - // see also - // http://dev.mysql.com/doc/refman/5.5/en - // /connector-j-reference-implementation-notes.html - } - } - - @Override protected String getPrimaryKeyQuery(String tableName) { return "SELECT column_name FROM INFORMATION_SCHEMA.COLUMNS " + "WHERE TABLE_SCHEMA = (" + getSchemaQuery() + ") "
