diff --git a/src/java/com/cloudera/sqoop/tool/ImportTool.java b/src/java/com/cloudera/sqoop/tool/ImportTool.java index 8d45fa83..48a8947c 100644 --- a/src/java/com/cloudera/sqoop/tool/ImportTool.java +++ b/src/java/com/cloudera/sqoop/tool/ImportTool.java @@ -822,6 +822,13 @@ protected void validateImportOptions(SqoopOptions options) throw new InvalidOptionsException( "When importing query results in parallel, you must specify --" + SPLIT_BY_ARG + "." + HELP_STR); + } else if (options.isDirect() + && options.getFileLayout() != SqoopOptions.FileLayout.TextFile + && options.getConnectString().contains("jdbc:mysql://")) { + throw new InvalidOptionsException( + "MySQL direct export currently supports only text output format." + + "Parameters --as-sequencefile and --as-avrodatafile are not " + + "supported with --direct params in MySQL case."); } }