在我的减速器类中，获取错误需要多个值

Question

我知道这是一个类似的问题。我已经看过一些答案，但没有一个有效。事情是这样的，我正在为我的MapReduce程序编写一个mapper和reducer，我得到以下错误

回溯（最近一次调用最后一次）：文件“/usr/local/hadoop//reducer.py”，第10行，在desc中，count=line。拆分（“\t”，1）值错误：需要多个值才能解包

我无法调试错误，因为我不知道是什么导致了这个问题。请在下面找到我的映射器和缩减器类的代码。

映射器代码:

#!/usr/bin/env python
import sys
for line in sys.stdin:
    line = line.strip('')
    bYear = line.split(',')
    for birthYear in bYear:
        print '%s\t%s' % (bYear[6],1)

减速机代码：

#!/usr/bin/env python
import sys

current_desc = None
current_count = 0
desc = None

for line in sys.stdin:
    line = line.strip()
    **desc, count = line.split('\t', 1)** . ---> This is where I'm getting an error.
    try:
        count = int(count)
    except ValueError:
        continue

    if current_desc == desc:
        current_count += count
    else:
        if current_desc:
            # write result to STDOUT
            print '%s\t%s' % (current_desc, current_count)
        current_count = count
        current_desc = desc

if current_desc == desc:
    print '%s\t%s' % (current_desc, current_count)

请帮帮忙。

Answer 1

该特定行中似乎没有“\t”字符，因此行.split（“\t”，1）仅返回1个元素，不能分配给desc，计数