mapreduce

5calore

1risposta

La creazione del collegamento simbolico dai registri lavori a $ {hadoop.tmp.dir} non è riuscita nell'impostazione cluster haodoop multinode

Quando si esegue un esempio di parole semplici in hadoop con cluster a 3 nodi, ho ricevuto il seguente errore. Ho controllato tutti i permessi di scrittura/lettura delle cartelle necessarie. Questo er

5calore

2risposta

Il riduttore Hadoop non viene chiamato

all Ho una mappa semplice/ridurre l'implementazione. Il mapper viene chiamato e fa il suo lavoro ma il riduttore non viene mai chiamato. Ecco mapper: static public class InteractionMap extends Mapper<

5calore

4risposta

Come posso eseguire il debug della mappa di Hadoop ridurre

im cercando di costruire una mappa ridurre il lavoro. esegue fino alla fine ma presenta dati strani alla fine. quando si tenta di eseguire il debug utilizzando system.out.println ("dati di debug") non

6calore

2risposta

È possibile inviare parti del mapper messe in riduttore, mentre si scrive semplicemente l'altra parte su HDFS, in hadoop?

Desidero scrivere parti dell'output del mapping in una cartella, ad esempio la cartella A in HDFS. L'altra parte dell'output, voglio che venga elaborata dal riduttore. È possibile? Sono a conoscenza d

16calore

3risposta

Grande dimensione del blocco in HDFS! Come viene contabilizzato lo spazio inutilizzato?

Sappiamo tutti che la dimensione del blocco in HDFS è piuttosto grande (64 M o 128 M) rispetto alle dimensioni del blocco nei file system tradizionali. Questo viene fatto al fine di ridurre la percent

5calore

3risposta

Ignora il mapreduce di hadoop.fileoutputcommitter.marksuccessfuljobs in oozie

<property> <name>mapreduce.fileoutputcommitter.marksuccessfuljobs</name> <value>false</value> </property> Desidero sovrascrivere la proprietà precedente su true. La proprietà deve essere falsa pe

5calore

1risposta

AppEngine MapReduce NDB, ripetuta InternalError: errore interno

Stiamo cercando di utilizzare pesantemente MapReduce nel nostro progetto. Ora abbiamo questo problema, ci sono un sacco di 'InternalError: errore interno.' errori nel registro ... Un esempio di esso:

7calore

2risposta

NoSQL con funzioni analitiche

Sto cercando qualsiasi sistema NoSQL (preferibilmente open source) che supporta le funzioni analitiche (AF in breve) come fa Oracle/SQL Server/Postgres. Non ho trovato nessuno con funzioni built-in. H

5calore

1risposta

Qual è la prestazione di stale = aggiornamento_dopo CouchDB?

Sono curioso di sapere come funziona la funzione stale=update_after dell'API di visualizzazione CouchDB. posso vedere here che restituisca risultati stantii e poi aggiorna la vista: Se stantio = OK vi

6calore

3risposta

come accedere al valore del contatore del mapper in un riduttore?

Voglio acces il valore myCounter.my in riduttore: public static class Map extends Mapper<LongWritable, Text, ImmutableBytesWritable, ImmutableBytesWritable> { public static enum myCounter{my};