我也有同样的问题,用 virtualenv怎么部署? 实验了下两台服务器基于 mesos + dpark + virtualenv ,在slave virtualenv 环境下执行如下测试代码无法运行:
b = dpark.parallelize([(1, 11), (1, 12), (2, 22)])
r1 = b.map(lambda x: (x[0], x)).groupByKey().collect()
print r1
slave 日志报错:
E0306 11:02:17.247473 10494 slave.cpp:1356] Failed to handle status update acknowledgement (UUID: 332e4233-9627-7b1a-17d2-cc1d5c283ac6) for task 1:1:1 of framework 201403061047-689246218-5050-31705-0002: Cannot find the status update stream for task 1:1:1 of framework 201403061047-689246218-5050-31705-0002
在 2014年1月7日星期二UTC+8下午5时11分14秒,muxueqz写道: