/ / Kann nicht auf Hadoop mit Pig eingebettet zugreifen - Java, Hadoop, Apache-Schwein

Kann nicht auf Hadoop mit Pig Embedded zugreifen - Java, Hadoop, Apache-Schwein

Ich benutze die Schwein api 0.12.0 um Schweine-Latein-Skripte auf einem Remote-Hadoop-Server auszuführen. Um dies zu tun, habe ich das gleiche platziert core-site.xml in meinem Klassenpfad (src / Haupt / Ressourcen).

Dies core-site.xml ist wirklich einfach:

<configuration>
<property>
<name>fs.defaultFS</name>
<value>hdfs://hadoopserver:9000</value>
</property>
</configuration>

Wenn ich jedoch mein Programm starte, sagt das Log

INFO executionengine.HExecutionEngine: Connecting to hadoop file system at: file:///

Warum verbindet es sich nicht mit hdfs://hadoopserver:9000 stattdessen ?

Antworten:

0 für die Antwort № 1

Dieses Problem wird durch die Tatsache verursacht, dass der neue Parameter fs.defaultFS Wird in dieser Version nicht unterstützt core-site.xml sollte die folgende Eigenschaft haben:

<configuration>
<property>
<name>fs.default.name</name>
<value>hdfs://hadoopserver:9000</value>
</property>
</configuration>

Sie müssen diesen Wert jedoch nicht in Ihrem Hadoop-Server ändern, nur in der Datei, die von der API angezeigt wird.