Elastic-Job的处理逻辑中关于DataflowJob的疑问?

wjm淼 发布于 2017/06/14 14:20
阅读 921
收藏 1

Elastic-Job的处理逻辑中,这里切分数据是将fetchData()返回的数据切分然后分片到不同的机器执行processData()吧,切分出的数据是平均的吗?比如9条数据,分为3片,每台机器执行3条数据?
因为根据本人实践,切分出的数据是不平均的,而且有一台机器是重复的全部数据。

加载中
0
亮_ShardingSphere
亮_ShardingSphere

不会切分数据,只会切分分片项。分片项和业务逻辑需要业务开发人员自己对应。分片策略是均分。也可以自己实现分片策略。详见:http://dangdangdotcom.github.io/elastic-job/elastic-job-lite/02-guide/job-sharding-strategy/

返回顶部
顶部