github/sqoop
5
0
Fork 0
mirror of https://github.com/apache/sqoop.git synced 2025-05-03 04:11:44 +08:00
Code Issues Projects Releases Wiki Activity

Fix SQOOP-1946: This issue occurred when using --query, the ConnManager and InputFormat of ImportJobContext not set to Oracle ones.

Browse Source
This commit is contained in:
Michael Hsu 2019-11-12 11:16:45 +08:00
parent 875e431af1
commit 9ab23a7e27
1 changed files with 9 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/java/org/apache/sqoop/manager/OracleManager.java
View File

@ -455,6 +455,15 @@ public void importTable(
super.importTable(context);
}
@Override
public void importQuery(com.cloudera.sqoop.manager.ImportJobContext context)
throws IOException, ImportException {
context.setConnManager(this);
// Specify the Oracle-specific DBInputFormat for import.
context.setInputFormat(OracleDataDrivenDBInputFormat.class);
super.importQuery(context);
}
/**
* Export data stored in HDFS into a table in a database.
*/