我有一个用java嵌入pig的程序。我在本地模式下执行pig服务器。但是当我执行我的代码时,我有一个执行错误。我不知道¡我不知道这意味着这个错误。
java代码是:
try {
System.out.println("principio de carga estadisticas");
Properties props = new Properties();
props.setProperty("fs.default.name","hdfs://localhost.localdomain:8020");
//System.out.println("cargar estadisticas paso1");
props.setProperty("mapred.job.tracker","localhost.localdomain:8021");
System.out.println("cargar estadisticas paso 11 jjjj");
PigServer pigServer = new PigServer("local");
错误的句子是
PigServer pigServer = new PigServer("local");
例外情况是:
principio de carga estadisticas
cargar estadisticas paso 11 jjjj
14/07/21 15:25:50 WARN conf.Configuration: fs.default.name is deprecated. Instead, use fs.defaultFS
14/07/21 15:25:50 WARN conf.Configuration: mapred.job.tracker is deprecated. Instead, use mapreduce.jobtracker.address
14/07/21 15:25:50 INFO executionengine.HExecutionEngine: Connecting to hadoop file system at: file:///
java.lang.UnsupportedOperationException: Not implemented by the DistributedFileSystem FileSystem implementation
at org.apache.hadoop.fs.FileSystem.getScheme(FileSystem.java:207)
at org.apache.hadoop.fs.FileSystem.loadFileSystems(FileSystem.java:2276)
at org.apache.hadoop.fs.FileSystem.getFileSystemClass(FileSystem.java:2286)
at org.apache.hadoop.fs.FileSystem.createFileSystem(FileSystem.java:2303)
at org.apache.hadoop.fs.FileSystem.access$200(FileSystem.java:87)
at org.apache.hadoop.fs.FileSystem$Cache.getInternal(FileSystem.java:2342)
at org.apache.hadoop.fs.FileSystem$Cache.get(FileSystem.java:2324)
at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:351)
at org.apache.hadoop.fs.FileSystem.get(FileSystem.java:163)
at org.apache.pig.backend.hadoop.datastorage.HDataStorage.init(HDataStorage.java:72)
at org.apache.pig.backend.hadoop.datastorage.HDataStorage.<init>(HDataStorage.java:58)
at org.apache.pig.backend.hadoop.executionengine.HExecutionEngine.init(HExecutionEngine.java:204)
at org.apache.pig.backend.hadoop.executionengine.HExecutionEngine.init(HExecutionEngine.java:117)
at org.apache.pig.impl.PigContext.connect(PigContext.java:240)
at org.apache.pig.PigServer.<init>(PigServer.java:215)
at org.apache.pig.PigServer.<init>(PigServer.java:200)
at org.apache.pig.PigServer.<init>(PigServer.java:196)
at org.apache.pig.PigServer.<init>(PigServer.java:192)
at org.apache.pig.PigServer.<init>(PigServer.java:182)
at bicing.pig.PigEstadisticas.cargarEstadisticas(PigEstadisticas.java:72)
at bicing.hbase.Generadortabla.cargarXML(Generadortabla.java:238)
at bicing.hbase.Generadortabla.main(Generadortabla.java:398)
我拿错jar了吗?。如何配置hdfs或pig?
暂无答案!
目前还没有任何答案,快来回答吧!