如何配置hdfs和pig

xnifntxz  于 2021-06-04  发布在  Hadoop
关注(0)|答案(0)|浏览(145)

我有一个用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?

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题