在python中嵌入hadoop的pigattributeerror:SimpleStats对象没有“issuccessfull”属性

2ic8powd  于 2021-06-03  发布在  Hadoop
关注(0)|答案(0)|浏览(162)

在运行嵌入python脚本的pig时遇到python错误。解决了问题,但想知道是否有其他人遇到此错误。
场景:a)使用pig的python脚本如下所示。

pigRun = Pig.compileFromFile(self.settingsReader.getScriptsDir() + "/" + script.name)
params = { 'datefrom': '2012-08-04 00:00:00', 'dateto': '2012-12-05 00:00:00', 
       'parallelism':self.settingsReader.getParallelism(), 
       'input' : script.input, 'output':script.output}
        bound = pigRun.bind(params)
        stats=bound.runSingle()
        if not stats.isSuccessfull():
          raise 'failed'

b) 清管器版本为0.10。Python2.7、Jython2.5在行上出错

if not stats.isSuccessfull():
          raise 'failed'

c) 错误如下attributeerror:'org.apache.pig.tools.pigstats.simplepigstats'对象没有属性'issuccessfull'
在查看了ApachePig0.10的源代码之后,simplepigstats似乎在其中实现了issueccessfull()。但运行时错误表明不是这样。
临时解决方案:更改故障检查代码如下

bound = pigRun.bind(params)
stats= bound.runSingle()
     if stats.getReturnCode() != 0:
        raise 'failed'

这似乎很管用。

暂无答案!

目前还没有任何答案,快来回答吧!

相关问题