From 16b75f58ceb14598b98011808bbad4cccc1abf00 Mon Sep 17 00:00:00 2001 From: John Pickard Date: Thu, 21 May 2015 11:38:42 -0400 Subject: [PATCH] use correct mysqlimport parameter for escaped by character --- src/java/org/apache/sqoop/mapreduce/MySQLExportMapper.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/java/org/apache/sqoop/mapreduce/MySQLExportMapper.java b/src/java/org/apache/sqoop/mapreduce/MySQLExportMapper.java index 5a695ca80..0cfb0b349 100644 --- a/src/java/org/apache/sqoop/mapreduce/MySQLExportMapper.java +++ b/src/java/org/apache/sqoop/mapreduce/MySQLExportMapper.java @@ -201,7 +201,7 @@ private void initMySQLImportProcess() throws IOException { } if (0 != escapedBy) { - args.add("--escaped-by=0x" + Integer.toString(escapedBy, 16)); + args.add("--fields-escaped-by=0x" + Integer.toString(escapedBy, 16)); } // These two arguments are positional and must be last.