可以理解为如果在使用cogroup时给的partitioner与cogroup里的rdd使用的parttioner不同时就需要划分stage重新进行parttion运算，然后进行再次进行shuffle按新的partitioner算法汇总相同的key，如果给的partitioner与rdd的partitioner是相同的那就不用再次shuffle了，因为在完成cogroup所使用的rdd运算时相同key的数据已经跑到同一个executor中了。

这里看不出来具体啥毛病，你不妨去看一下ExecMapper.java的179行代码，看看报错原因。
从异常来看是hive和Elasticsearch的元信息不匹配，但具体原因建议看一下原代码吧。

Kudu对比hive性能要高很多且支持数据更新，还有一个好处是c++开发的相比java没有了GC延迟时间。在上层，可以用 Impala 查询，也可以使用其他的 SQL on Hadoop 进行查询，SparkSQL 之类的，能很好地融入 Hadoop 生态。而且接口和hbase很像也有scan等。如果你需要对实时数据做查询，如果需要快速地查询，那么 Kudu 无疑是一个好的选择。
Impala只是操作Kudu的一个终端吧，能操作Kudu的有挺多比如刚才说的spark-sql。好处就是都是Cloudera开发的Impala与Kudu兼容性比较好吧

你图上的结果是result.show()的？

@luo6994658 你这种手动指定了相同的GID，老的组不也回收了吗，只是别一种方式覆盖了。还可以理解为老的组做为备份了，新的组删除了是不是这个GID就还给老的组了。所以你可以理解为存在的意义就是被当成备份了。

@luo6994658 是的，ly用户的组是1010，现在1010这个GID是ly1组的，所以不能删因为ly用户是在ly1组的，至于为什么又跑到ly1组了？而不是在原来的ly组了呢？你想想文件是不是从上往下读的，ly和ly1有相同的gid，那当然这个gid分给最后出现的了。也就是说虽然组ID在文件里能重复，但是最终一个组ID只能给一个组，给那个？给/etc/group中最后出现的那个。

@luo6994658 你可以看一下/etc/group和/etc/passwd这两个文件

@魏超 http://www.hainiubl.com/topics/124 你看一下这里面的pagefilter用法

:smile:

用scan方法啊，查出指定范围内的数据，或者查出多少条的

@BigTester 你可以参考一下这里 https://www.cloudera.com/documentation/enterprise/5-4-x/topics/admin_llama.html

@BigTester 可以啊，都是支持JDBC的

@BigTester hive是查询大量数据使用的。看你们的数据情况和业务需求了，如果mysql能存下当然mysql快了

@ruiqi 可以spark的streaming支持socket流streamgingContext.socketTextStream(IP，PORT)

@ruiqi 落成文件呗，存到集群上。或者那边写到kafka里，这边用流式处理，这样就不用攒太多数据一起算了