Revision 28594
Added by Eri Katsari about 10 years ago
| SqoopDriver.java | ||
|---|---|---|
| 69 | 69 |
"--verbose", "--username", dbUser, "--password", dbPass, "--batch", "--mapreduce-job-name", "Sqoop Stats Import", "-m", sqoopReducersCount }; |
| 70 | 70 |
|
| 71 | 71 |
try {
|
| 72 |
Sqoop.runTool(str); |
|
| 72 |
Sqoop.runTool(str,conf); |
|
| 73 |
|
|
| 73 | 74 |
} catch (Exception ex) {
|
| 74 | 75 |
log.error("Could not run Sqoop Tool " + ex.getMessage());
|
| 75 | 76 |
throw new Exception("Could not run Sqoop Tool ", ex);
|
Also available in: Unified diff