开始
执行器有3个节点,但是每次只会执行一个节点。
例如有100万的数据 分给3个节点分别去执行, 调度中心会决定怎么分给3个节点。 这就是分片任务的使用场景。
假设我们这里从数据去查数据
取模的操作,取模后等于当前分片的索引,那么这个任务就在这个节点去执行。
创建任务的时候一定要选择分片广播。
等执行器注册上来
执行分片任务
控制台的输出。当前只有一个节点 都是它在处理。
修改端口,又启动一个节点
第二台机器注册上来了。
再去执行分片任务
数据被分开处理了。
新注册的处理的就是1357
修改端口再加一台机器
再次执行分片任务。
第一个
第二个
100条数据被分布到3个节点上去执行。