From 28f5aa03ba182a40e1609a02f389d490f9108147 Mon Sep 17 00:00:00 2001 From: Jarek Jarcec Cecho Date: Thu, 24 Jul 2014 20:12:41 -0700 Subject: [PATCH] SQOOP-1400: Failed to import data using mysql-connector-java-5.1.17.jar (Richard via Jarek Jarcec Cecho) --- .../org/apache/sqoop/manager/MySQLManager.java | 16 ---------------- 1 file changed, 16 deletions(-) diff --git a/src/java/org/apache/sqoop/manager/MySQLManager.java b/src/java/org/apache/sqoop/manager/MySQLManager.java index e1d5a36e..b9c9d366 100644 --- a/src/java/org/apache/sqoop/manager/MySQLManager.java +++ b/src/java/org/apache/sqoop/manager/MySQLManager.java @@ -63,22 +63,6 @@ public MySQLManager(final SqoopOptions opts) { super(DRIVER_CLASS, opts); } - @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 "