INFO BlockManagerMaster: Registered BlockManagerException in thread "main" java.lang.NoClassDefFoundError: org/apache/spark/streaming/kafka/KafkaUtils...
分类:
其他好文 时间:
2015-04-13 18:12:53
阅读次数:
252
事务管理: 单个工作单元称为事务,我们将若干条sql命令组合在一起,形成存储过程、触发器等,利用存储过程和触发器可以进行事务管理。 编程基础介绍:函数、程序设计语句等。 程序设计语句: 1、begin ......end 中间插入若干条sql语句,我们将其视为一个单元。 2、跳转语句(goto语句)...
分类:
数据库 时间:
2015-04-12 20:37:58
阅读次数:
206
事务管理: 单个工作单元称为事务,我们将若干条sql命令组合在一起,形成存储过程、触发器等,利用存储过程和触发器可以进行事务管理。 编程基础介绍:函数、程序设计语句等。 程序设计语句: 1、begin ......end 中间插入若干条sql语句,我们将其视为一个单元。 2、跳转语句(goto语句)...
分类:
数据库 时间:
2015-04-12 19:12:20
阅读次数:
214
Kafka——分布式消息系统架构ApacheKafka是2010年12月份开源的项目,采用scala语言编写,使用了多种效率优化机制,整体架构比较新颖(push/pull),更适合异构集群。设计目标:(1) 数据在磁盘上的存取代价为O(1)(2) 高吞吐率,在普通的服务器上每秒也能处理几十万条消息(...
分类:
其他好文 时间:
2015-04-11 13:01:35
阅读次数:
163
我在网上搜了很多资料 说是zookeeper的问题,修改更改server.properties下的host.name,zookeeper.connect的localhost 为ip地址? 怎么也不管用 后来就单独建了一个项目,发现没有问题。结论是jar包冲突,逐个删除...
分类:
其他好文 时间:
2015-04-10 18:13:04
阅读次数:
179
Kafka可以配置使用JMX进行运行状态的监控,既可以通过JDK自带Jconsole来观察结果,也可以通过Java API的方式来.
关于监控指标的描述,可以参考:http://kafka.apache.org/documentation.html#monitoring
开启JMX端口
修改bin/kafka-server-start.sh,添加JMX_PORT参数,添加后样...
分类:
其他好文 时间:
2015-04-10 18:07:24
阅读次数:
363
1、下载kafka? https://www.apache.org/dyn/closer.cgi?path=/kafka/0.8.2.0/kafka_2.10-0.8.2.0.tgz ? ?tar -xzf kafka_2.10-0.8.2.0.tgz ? cd kafka_2.10-0.8.2.0 2、启动服务 ? ? 启动zookeeper服务 启动...
分类:
其他好文 时间:
2015-04-09 17:56:44
阅读次数:
101
其实iLO就是HP服务器才有的内置功能,还要买序列号1000元左右,服务器后面有专门的iLO网卡,就算电脑不开机,也可以iLO进去设置,iLO是通过网页管理的,可以console,和在显示器前是一模一样的。版本目前最新的版本是iLO4。另外还有iLO3,iLO2,ILO1。简介iLO(IntegratedLights..
分类:
其他好文 时间:
2015-04-09 06:35:26
阅读次数:
1849
Kafka+Storm+HDFS整合实践本文导读:1 前言2 Kafka安装配置3 Storm安装配置4 整合Kafka+Storm5 整合Storm+HDFS6 整合Kafka+Storm+HDFS7 参考链接
分类:
其他好文 时间:
2015-04-08 16:21:02
阅读次数:
127
这个包主要是与Kafka度量相关的。一、KafkaTimer.scala对代码块的运行进行计时。仅提供一个方法: timer——在运行传入函数f的同时为期计时二、KafkaMetricsConfig.scala指定reporter类,以逗号分隔的reporter类,比如kafka.metrics.K...
分类:
其他好文 时间:
2015-04-08 10:38:22
阅读次数:
138