hadoop-streaming

0зной

1ответ

В потоковом режиме Hadoop был китайский, искаженный с -files python

Я не уверен, что «искаженный» является правильным словом для моей проблемы. Моя проблема такая. Я использую hasoop-streaming-0.20.2-cdh3u6.jar и python для создания mapreduce. Команда, как показано ни

0зной

1ответ

Hadoop streaming C++ getTaskId

Я пытался найти способ получить (или передать) taskId моему картографу в C++. Я использую потоки хаопов. До сих пор я просто получил, как получить его на Java. Мне нужен идентификатор задачи, потому ч

1зной

1ответ

Использование Hadoop Partitioner и Comparator Class Together

У меня есть файл с двумя столбцами id и timestamp. Я подсчитываю количество сеансов, каждое из которых имеет значение - определяется бездействием более 30 минут. Однако у меня возникают проблемы с пот

0зной

1ответ

java.lang.NullPointerException at org.apache.hadoop.mapreduce.lib.input.SequenceFileRecordReader.close

Я запускаю две пары с уменьшением пары. Результат первого уменьшения карты используется как вход для следующего уменьшения карты. Для этого я дал job.setOutputFormatClass (SequenceFileOutputFormat.cla

3зной

1ответ

Как пропустить неудачные задачи карты в потоке hadoop

Я запускаю работу по перенастройке транзакции hadoop, которая содержит 26895 задач карты. Тем не менее, одна задача, которая обрабатывает определенный вход, всегда терпит неудачу. Поэтому я установил