logo
publist
写文章

简介

该用户还未填写简介

擅长的技术栈

可提供的服务

暂无可提供的服务

hadoop报错:java.io.IOException(java.net.ConnectException: Call From xxx/xxx to xxx:10020 failed on con...

  任务一直报错  现象比较奇怪,部分任务可以正常跑,部分问题报错  报错信息如下:Ended Job = job_1527476268558_132947 with exception 'java.io.IOException(java.net.ConnectException: Call From xxx/xxx to xxx:10020 failed on conn...

#java#大数据#运维
Hadoop3集群搭建之——安装hadoop,配置环境

  接上篇:Hadoop3集群搭建之——虚拟机安装  下篇:Hadoop3集群搭建之——配置ntp服务    Hadoop3集群搭建之——hive安装    Hadoop3集群搭建之——hbase安装及简单操作上篇已经安装好了虚拟机了,现在开始配置环境,安装hadoop注:hadoop集群最少需要三台机,因为hdfs副本数最少为3,单机不算  我搭了三台机...

#运维#操作系统#开发工具
java.security.cert.CertificateException: No subject alternative names matching IP address xxx.xxx.xx...

https与http不同的是,https加密,需要验证证书,而http不需要。在连接的代码中加上:static {disableSslVerification();}private static void disableSslVerification() {try{...

#java#移动开发
Flink 报错 "Could not find a suitable table factory for 'org.apache.flink.table.factories.StreamTableS...

先上代码:table = tablexx.select('*).tablexx.groupBy('x).select('x, xx.count )tableEnvironment// declare the external system to connect to.connect(new Kafka().version("...

#大数据#java#scala
Flink统计当日的UV、PV

  Flink统计当日的UV、PV  测试环境:    flink 1.7.2  1、数据流程        a.模拟数据生成,发送到kafka(json格式)      b.flink读取数据,count    c.输出数据到kafka(为了方便查看,输出了一份到控制台)  2、模拟数据生成器    数据格式如下 :{"id" : 1, "...

#大数据#scala#java
到底了