spark调优总结

  1.sparkseaming     从图上能够看到,Batch Interval的间隔是5s,也就是说每通过5s,SparkStreaming会将这5s内的信息封装成一个DStream,而后提交到Spark集群进行计算html   1.1执行流程java     第一个 DStream 里面是 0-5s 的数据,在第6s的时候会触发 DStream 的job执行,这时会另启动一个线程执行这个
相关文章
相关标签/搜索