Thanks!

还是决定暂时用两个job执行吧

一个job执行流处理生成数据

另一个job(使用flink的hive功能)执行批处理。

主要验证一下第二个job的使用相比MapReduce节省了多少资源



-----
Thanks!
Jacob
--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复