Java integration with Sqoop1 is always a bit tricky. Have you tried Sqoop2 for the Sqoop2 client?
-Abe On Tue, Jun 16, 2015 at 10:11 AM, Moiz Arafat <[email protected]> wrote: > Hello Everyone, > > Any thoughts on this ? > > Thanks, > Moiz > > On 12-Jun-2015, at 4:18 pm, Moiz Arafat <[email protected]> wrote: > > Hi , > > I have a java program to run export command. While executing the export it > tries to look for the export directory in my local machine instead of Hdfs > . The same program works fine for import . > > the file exists on hdfs. > > Please help. > > Thanks, > Moiz > > public void executeSqoopLoad() throws UnsupportedEncodingException{ > SqoopOptions options = new SqoopOptions(); > > String driver = "oracle.jdbc.driver.OracleDriver"; > //options.setDriverClassName(driver); > options.setUsername(“user"); > options.setPassword(“pass"); > options.setConnectString("jdbc:oracle:thin:@host:1522:rptdev"); > > Configuration configuration = new Configuration(false); > Resource configResource; > try { > configResource = FileUtils.getFileResource( > "/Users/Moiz/git/jef/hadoop/hdfs-site.xml"); > configuration.addResource(configResource.getInputStream()); > configResource = FileUtils.getFileResource( > "/Users/Moiz/git/jef/hadoop/core-site.xml"); > configuration.addResource(configResource.getInputStream()); > FileSystem dfs = FileSystem.get(configuration); > > String[] uriSplit = dfs.getUri().toString().split(":"); > String newUri = uriSplit[0]+":"+uriSplit[1]; > dfs.setWorkingDirectory(new Path(newUri+"/tmp")); > System.out.println(dfs.getWorkingDirectory()); > > System.out.println("Exists = " + dfs.exists(dfs.getWorkingDirectory())); > > DateTime dt = new DateTime(); > options.setCodeOutputDir("/tmp"); > options.setClassName("SqoopLoad_"+null+dt.getYear()+dt.getMonthOfYear()+dt > .getDayOfMonth()+dt.getMillisOfDay()); > options.setVerbose(true); > // HDFS options > options.setExportDir(dfs.getWorkingDirectory()+"/TestDirectory"); > > System.out.println("Exists = " + dfs.exists(new Path(options > .getExportDir()))); > options.setInputFieldsTerminatedBy('\u0005'); > options.setTableName(“SCHEMA.TEST_SQP"); > options.setNumMappers(1); > options.setDirectMode(true); > System.setProperty(Sqoop.SQOOP_RETHROW_PROPERTY, "rethrow"); > > } catch (FileNotFoundException e) { > e.printStackTrace(); > } catch (IOException e) { > e.printStackTrace(); > } > > int ret = 100; > try{ > ret = new ExportTool().run(options); > }catch (Exception e) { > System.out.println("Debug"); > e.printStackTrace(); > } > System.out.println("return code "+ ret); > } > > java.lang.RuntimeException: java.io.FileNotFoundException: File > /tmp/TestDirectory/part-m-00000 does not exist > > >
