亚洲av成人无遮挡网站在线观看,少妇性bbb搡bbb爽爽爽,亚洲av日韩精品久久久久久,兔费看少妇性l交大片免费,无码少妇一区二区三区

<bdo id="q27hw"></bdo>

Chinaunix

標(biāo)題: 看看python寫的map哪里錯了？ [打印本頁]

作者: loler_zuan 時間: 2013-03-22 08:03
標(biāo)題: 看看python寫的map哪里錯了？
我剛開始學(xué)這個，map和reduce在linux下用管道模擬沒有問題。
map不需要輸入的文件，實(shí)在里面直接打開的，這樣可以么？
幫忙看看我的錯誤是map錯了還是執(zhí)行的時候把沒有把需要的文件拷到hdfs的原因��？

#!/usr/bin/env python
# usage: "train" or "submit"
import sys
id2indx = {}
tot_num = 0
indx_list = []
#print 'build index for items'
iprof = open('item.txt')
for line in iprof:
iid = int(line.split()[0])
if not iid in id2indx:
      id2indx[iid] = tot_num
      indx_list.append((iid, tot_num))
      print '%s\t%d' % (id2indx[iid],iid)
      tot_num += 1
#for (k, v) in self.indx_list:
      #print '------- %d -> %d\n' % (k, v)
iprof.close()
#print 'build index for users'
uprof = open('user_profile.txt')
for line in uprof:
uid = int(line.split()[0])
if not uid in id2indx:
      id2indx[uid] = tot_num
      indx_list.append((uid, tot_num))
      tot_num += 1
      print '%s\t%d' % (id2indx[uid],uid)
uprof.close()

每次提交都失敗因?yàn)椴恍枰斎牒洼敵龅奈募�，我隨便建了個空文件hello。
hadoop jar \$HADOOP_HOME/contrib/streaming/hadoop-0.20.2-streaming.jar -mapper ./python/map.py -reducer ./python/reduce.py

歡迎光臨 Chinaunix (http://www.72891.cn/)