search

douban / dpark

Python clone of Spark, a MapReduce alike framework in Python
BSD 3-Clause "New" or "Revised" License
2.69k stars 534 forks source link

pymesos 0.1.6 VS mesosphere 1.1.0, 取不到 slave id #66

Closed cntaogong closed 7 years ago

cntaogong commented 7 years ago

环境: pymesos 0.1.6, mesosphere 1.1.0 , dpark 0.3.5 文件: executor.py 函数: reply_status 问题: mesos_pb2.TaskStatus()返回的status对象的slave_id属性是空

def reply_status(driver, task_id, state, data=None): status = mesos_pb2.TaskStatus() status.task_id.MergeFrom(task_id) status.state = state status.timestamp = time.time() if data is not None: status.data = data driver.sendStatusUpdate(status)

windreamer commented 7 years ago

fixed https://github.com/douban/pymesos/pull/45