Suchergebnisse für Anfrage "hadoop"
ClassNotFoundException: org.apache.hive.jdbc.HiveDriver
Ich bin ziemlich neu in Java. Ich versuche über Java eine Verbindung zum Hive-Server herzustellen und verwende Beispielcode ...
Hadoop:… auf 0 Knoten anstatt auf minReplication (= 1) repliziert werden. Es werden 1 Datenknoten ausgeführt, und in dieser Operation werden keine Knoten ausgeschlossen.
Ich erhalte die folgende Fehlermeldung, wenn ich versuche, im Rahmen meiner Multithread-Anwendung auf HDFS zu schreiben. could only be replicated to 0 nodes instead of minReplication (=1). There are 1 datanode(s) running and no node(s) are ...
Phoenix zeigt negative Ganzzahlen nicht korrekt an
Ich erstelle eine HBASE-Tabelle mit dem Wert "Ganzzahl -17678". Aber wenn ich es von Pheonix abrufe, gibt es mir einen anderen positiven Wert. RowKey ist ein zusammengesetzter Rowkey und es gibt kein Problem mit Rowkey. Hbase einfügen: public ...
Wie entpacke ich in HDFS gespeicherte Dateien mit Java, ohne sie zuerst in das lokale Dateisystem zu kopieren?
Wir speichern Zip-Dateien, die XML-Dateien enthalten, in HDFS. Wir müssen in der Lage sein, die Datei programmgesteuert zu entpacken und die enthaltenen XML-Dateien mit Java zu streamen. FileSystem.open gibt einen FSDataInputStream zurück, aber ...
Wie lese ich mehrere Zeilenelemente in Spark?
Wenn Sie eine Datei in Spark mit @ les sc.textfile gibt es Ihnen Elemente, wobei jedes Element eine separate Zeile ist. Ich möchte jedoch, dass jedes Element aus N Zeilen besteht. Ich kann auch keine Trennzeichen verwenden, da diese Datei keine ...
hadoop Benutzerdateiberechtigungen
Ich habe ein Problem beim Festlegen der Hadoop-Dateiberechtigungen in Hortonworks und Cloudera. Meine Anforderung lautet: 1. create a new user with new group 2. create user directory in hdfs ( ex. /user/myuser ) 3. Now this folder ( in this ...
Ist Spark-Streaming funktioniert sowohl mit "cp" als auch mit "mv"
Ich verwende Spark-Streaming Mein Programm liest ständig Streams aus einem Hadoop-Ordner. Das Problem ist, dass der Spark-Job gestartet wird, wenn ich ihn in meinen Hadoop-Ordner kopiere (Hadoop fs -copyFromLocal), aber wenn ich ihn verschiebe ...
OpenCV-Bibliothek in Hadoop geladen, funktioniert aber nicht
Ich versuche, OpenCV mit Hadoop zu verwenden. Unten ist mein Code. Ich teste gerade, ob OpenCV-Bibliotheken mit Hadoop einwandfrei funktionieren, d. H., Wenn ich OpenCV-Code in function @ ausführpublic int run(String[] args) von Hadoop. Ich ...
Große Datenmengen mit MapReduce / Hadoop sortieren
Ich lese gerade über MapReduce und das Folgende verwirrt mich. Angenommen, wir haben eine Datei mit 1 Million Einträgen (Ganzzahlen) und möchten sie mit MapReduce sortieren. Die Art und Weise, wie ich es verstanden habe, ist wie ...
IllegalAccessError to guava's StopWatch from org.apache.hadoop.mapreduce.lib.input.FileInputFormat.listStatus
Ich versuche, eine kleine Funkenanwendung auszuführen, und erhalte die folgende Ausnahme: Exception in thread "main" java.lang.IllegalAccessError: tried to access method com.google.common.base.Stopwatch.<init>()V from ...