我最近在做把dubbo整合到spark里面,想用spark的分布式处理dubbo的高并发。里面不涉及到spark的其他操作,只是用spark的分布式,因为没有task执行,怎样吧请求分发到不同的executor执行?
我最近在做把dubbo整合到spark里面,想用spark的分布式处理dubbo的高并发。里面不涉及到spark的其他操作,只是用spark的分布式,因为没有task执行,怎样吧请求分发到不同的executor执行?
用kafka做两个的对接吧,让spark从kafka中拿数据,然后自己就会分发到不同的executor执行