
简介
该用户还未填写简介
擅长的技术栈
可提供的服务
暂无可提供的服务
任务一直报错 现象比较奇怪,部分任务可以正常跑,部分问题报错 报错信息如下:Ended Job = job_1527476268558_132947 with exception 'java.io.IOException(java.net.ConnectException: Call From xxx/xxx to xxx:10020 failed on conn...
接上篇:Hadoop3集群搭建之——虚拟机安装 下篇:Hadoop3集群搭建之——配置ntp服务 Hadoop3集群搭建之——hive安装 Hadoop3集群搭建之——hbase安装及简单操作上篇已经安装好了虚拟机了,现在开始配置环境,安装hadoop注:hadoop集群最少需要三台机,因为hdfs副本数最少为3,单机不算 我搭了三台机...
https与http不同的是,https加密,需要验证证书,而http不需要。在连接的代码中加上:static {disableSslVerification();}private static void disableSslVerification() {try{...
先上代码:table = tablexx.select('*).tablexx.groupBy('x).select('x, xx.count )tableEnvironment// declare the external system to connect to.connect(new Kafka().version("...
Flink统计当日的UV、PV 测试环境: flink 1.7.2 1、数据流程 a.模拟数据生成,发送到kafka(json格式) b.flink读取数据,count c.输出数据到kafka(为了方便查看,输出了一份到控制台) 2、模拟数据生成器 数据格式如下 :{"id" : 1, "...