sqoop-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jar...@apache.org
Subject git commit: SQOOP-1400: Failed to import data using mysql-connector-java-5.1.17.jar
Date Fri, 25 Jul 2014 03:13:15 GMT
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 <jarcec@apache.org>
Authored: Thu Jul 24 20:12:41 2014 -0700
Committer: Jarek Jarcec Cecho <jarcec@apache.org>
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() + ") "


Mime
View raw message