@歌唱祖国 :+1: 但是 感觉这个太不安全了

@shishuai19910217 我理解错了 我以为你说的是读取数据那个numPartition，write这个action操作可以指定partition数量，这个数量会决定reduce的数量从而影响bucket的数量

Mapper会根据Reducer的数量创建出相应的bucket，bucket的数量是M×R，其中M是Map的个数，R是Reduce的个数，并不是按照numPartition计算的

企业中不会吧hue地址暴露在公网上的 一般是员工在非公司网络下先连接vpn登入公司内网 再访问hue

@sparksun007 Select a.month,a.day,sum(a.pv)/count(a.) from (Select month,day, remote_addr,count(1) as pv from ods_weblog_detail group by remote_addr,month,day) as a group by a.month,a.day

用sum或是count这种聚合函数最后一定跟group by

XXX.map(scala.math.BigDecimal(_))

现在单机模式下写程序，然后在集群上用spark-submit方式运行

mvn -v命令执行报错吗

@shishuai19910217 自己实现一个exeBatch吧