mirror of
https://github.com/apache/sqoop.git
synced 2025-05-08 01:11:29 +08:00
SQOOP-636: ExportJobTestCase.runExport method does not reuse the existing Configuration and SqoopOptions
(Venkatesh Seetharam via Jarek Jarcec Cecho)
This commit is contained in:
parent
97f272a4ba
commit
695666acdb
@ -26,8 +26,10 @@
|
|||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
|
import com.cloudera.sqoop.SqoopOptions;
|
||||||
import org.apache.commons.logging.Log;
|
import org.apache.commons.logging.Log;
|
||||||
import org.apache.commons.logging.LogFactory;
|
import org.apache.commons.logging.LogFactory;
|
||||||
|
import org.apache.hadoop.conf.Configuration;
|
||||||
import org.apache.hadoop.util.StringUtils;
|
import org.apache.hadoop.util.StringUtils;
|
||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
|
|
||||||
@ -302,7 +304,9 @@ protected List<String> runExport(String [] argv) throws IOException {
|
|||||||
List<String> generatedJars = null;
|
List<String> generatedJars = null;
|
||||||
try {
|
try {
|
||||||
ExportTool exporter = new ExportTool();
|
ExportTool exporter = new ExportTool();
|
||||||
Sqoop sqoop = new Sqoop(exporter);
|
Configuration conf = getConf();
|
||||||
|
SqoopOptions opts = getSqoopOptions(conf);
|
||||||
|
Sqoop sqoop = new Sqoop(exporter, conf, opts);
|
||||||
ret = Sqoop.runSqoop(sqoop, argv);
|
ret = Sqoop.runSqoop(sqoop, argv);
|
||||||
generatedJars = exporter.getGeneratedJarFiles();
|
generatedJars = exporter.getGeneratedJarFiles();
|
||||||
} catch (Exception e) {
|
} catch (Exception e) {
|
||||||
|
Loading…
Reference in New Issue
Block a user