用户组:游客
我只有一个master和一个slavehbase.zookeeper.quorum怎么配置?配置zookeeper集群我看文档,要求这个参数必须是奇书,我只有一个 ...
最近,很多小伙伴问我,如何才能自学成为 Python 高手?根据自己多年大厂工作经验和带领数千朋友的学习,信盈达小编总结了几点小 ...
问题描述:datanode web服务器状态告警,分析日志没明显报错,那位大佬给下思路啊 Service Monitor日志查看有延迟情况: ...
[mw_shl_code=scala,true]tableEnv.connect(new Kafka() .version("universal") ...
[mw_shl_code=xml,true] org.apache.flink flink-connector-kafka_2.11 1.10.0 [/mw_shl_code] ...
[mw_shl_code=scala,true]tableEnv.connect(new Kafka().topic(topic) .properties(properties) ...
我将hadoop设为高可用以后,datanode节点看不全 我做了两个namenode,一共4个datanode 为什么active的namenode能看到两个data ...
看了好多帖子说 实际中我发现,TotalWriteTime总是小于WriteBlockOpAvgTime, 我很疑惑,为什么会这样 我想计算datanode的读 ...
有人在ARM 服务器上安装过Ambari 吗,我最近试着安装了以下,但是在编译源码的时候报下面的错误:
job.setOutputKeyClass(Text.class); job.setOutputValueClass(LongWritable.class); 输出结果,默认是按照key,升序排序 ...
用的hadoop-3.1.2,hbase-2.1.4,zookeeper-3.4.14。参照其他人的配置:https://blog.csdn.net/wx2007xing/article/details/8871 ...
前言: 在Centos7安装CDH5后,都是运行正常。jps可查询到角色。各节点也都正常。之后重启了一次服务器就出现了很多问题 1.CDH5页 ...
hive执行的时候会打印日志,请问Cumulative CPU 256.11 sec,打印的这个是什么意思呢?我百度了一下,没有什么资料,大神们,求 ...
使用zeppelin查询mysql数据,不管是字符串类型还是整型,长一点的数据末尾两位被四舍五入了。比如.....55832 成了 ...55800 可 ...
类似下边两级队列: root --pro ----on ----off 目标: 在提交任务是必须指定队列名称 不允许创建新的队列 我采用如下 ...
用java8 写spark程序, 在最后一步,为何报错需要序列化 List list = Arrays.asList(1,2,3,4,5); JavaRDD rd ...
Error: org.apache.hadoop.hdfs.BlockMissingException: Could not obtain block: BP-1131094675-127.0.0.1-1535960494583:blk_1 ...
1. 编写Morphline配置文件,将解析为: (比如grep:amd64 3.1-2对应grep名字,amd64平台 4.8.4版本)。解析后的数据以带有Schem ...
各位表哥好:装CDH的时候出现这个问题,这个问题困惑了我两天了,网上的方法都试了一遍还是没解决。论坛发帖实属无奈了。 ...
怎么把hadoop 里面wordcount 这个工程用source insight 查看
想实现row_number()功能 ,如 data01,data02字段 a,7 a,2 a,3 b,2 b,3 c,9 实现按ID分组加1 a1,7 a2,2 a3,3 b1,2 b2 ...
机器16core(32 超线程) 64G yarn.nodemanager.resource.cpu-vcores=32 mapreduce.reduce.cpu.vcores=1 mapreduce.reduce ...
各位好,开始没有往HDFS上传文件,上传40000个小文件后,那么这些小文件占用的内存是怎么测出来呢?
我最近有个实现,rdd存的是一个多边形的边界,通过WKT来进行判断这个边界是否与另外一个多边形边界数组存在相交的状态,然后在集群 ...
地址:https://github.com/databps/chiwen 各位表哥,我按照上面的说明已经都编译好了。如下: jar包也已经按照上面说的两个 ...
Stream-dataset joins这在种操作在前面解释DStream.transform操作时已经进行了展示。下面的例子是另一个join窗口流与数据集的例 ...
[mw_shl_code=java,true]import java.util.ArrayList; import java.util.List; public class Torment { public stati ...
hdfs get 或者put的时候是blocks的读写并行还是串行的?写得时候文件是切分成几个block文件还是通过index来方式,读的时候文件 ...
spark-sql在使用mysql存储元数据,创建的表都存储在hdfs的情况下,是否可以不安装hive? 我现在hive,spark都装了,每次启动spark ...
大数据一般解决哪些问题比较好?
本版积分规则 发表帖子
查看 »