ERROR scheduler.ReceiverTracker: Deregistered receiver for stream 0: Error starting receiver 0 - org.I0Itec.zkclient.exception.ZkTimeoutException: Unable to connect to zookeeper server within timeout: 10000 at org.I0Itec.zkclient.ZkClient.connect(ZkClient.java…

2020年06月16日 0条评论 927点热度 0人点赞 阅读全文

在安装完毕mysql 5.7 之后,设置登录权限时,报错,错误代码如下。 错误代码:ERROR 1045 (28000): Access denied for user 'root'@'localhost' (using password: YES) 原因是:mysql在设置登录的时候没有给root用户在localhost下登录的权限 因为这个时候我们登录到mysql时,总会报错,所以我们需要设置成无密码登录。 设置无密码登录参考:centos中mysql忘记root密码详细解决方法 中的第1-5步。 此时,查看用…

2020年06月16日 0条评论 949点热度 1人点赞 阅读全文

Flume是一个分布式、可靠、和高可用的海量日志采集、日志聚和  和 传输 的系统。 支持在日志系统中定制各类数据发送方,用于收集数据。 同时,Flume提供对数据进行简单处理,并具有写到各种数据接收方(HDFS、Hbase等)的功能。 其核心为Agent,是flume中最小的独立运行单位(JVM)。 核心组件为:source、channel、sink http://mirror.bit.edu.cn/apache/flume/ Master 192.168.71.10 Slave1 192.168.71.11 S…

2020年06月15日 0条评论 488点热度 0人点赞 阅读全文

Python 三元表达式 三目运算符 一般支持三目运算符的语言(如C语言)的语法格式一般是这样的: 判断条件(返回布尔值)?为真时的结果:为假时的结果 比如: x = x%2==1 ? x+1:x; python并不支持? :这种符号所表达的先判断再选择的含义,但仍然有相应的语法支持: 1. Python 的语法支持 为真时的结果 if 判断条件 else 为假时的结果(注意,没有冒号) 顺序略有不同, x = x+1 if x%2==1 else x 在比如我们欲实现一个基础版本(递归版本)的斐波那契数列: de…

2020年06月09日 0条评论 881点热度 1人点赞 阅读全文

Kafka是使用scala编写的运行与jvm虚拟机上的程序,虽然也可以在windows上使用,但是kafka基本上是运行在linux服务器上,因此我们这里也使用centos7来实战。 首先确保你的机器上安装了jdk,kafka需要java运行环境,以前的kafka还需要zookeeper,新版的kafka已经内置了一个zookeeper环境,所以我们可以直接使用,但还是建议使用自己安装的zookeeper ApacheKafka是一个分布式流媒体平台,它主要有3种功能 1、发布和订阅消息流,这个功能类似于消息队列,…

2020年06月08日 0条评论 611点热度 0人点赞 阅读全文
1234510