【原创】大数据基础之Flume（2）应用之kafka-kudu
应用一：kafka数据同步到kudu 1 准备kafka topic 2 准备kudu表 impala-shell 3 准备flume kudu支持 3.1 下载jar 3.2 开发 代码库：https://github.com ...
原文：【原创】大数据基础之Flume（2）kudu sink
kudu中的flume sink代码路径： https: github.com apache kudu tree master java kudu flume sink kudu flume sink默认使用的producer是 org.apache.kudu.flume.sink.SimpleKuduOperationsProducer 是将消息直接存放到一个payload列中 如果想要支持js ...
2019-03-21 17:39 2 841 推荐指数：
相关推荐
【原创】大数据基础之Kudu（4）spark读写kudu
spark2.4.3+kudu1.9 1 批量读 2 批量写 3 单个读/条件读 4 单个写 其他：newInsert/newUpdate/newDelete/newUpsert 5 错误定位 如果apply之后发现修改 ...
【原创】大数据基础之Kudu（2）移除dead tsever
当kudu有tserver下线或者迁移或者修改hostname之后，旧的tserver会一直以dead状态出现，并且tserver日志中会有大量的连接重试日志，一天的错误日志会有几个G， W0322 22:13:59.202749 16927 tablet_service.cc:290 ...
【原创】大数据基础之Kudu（1）简介、安装、使用
kudu 1.7 官方：https://kudu.apache.org/ 一 简介 kudu有很多概念，有分布式文件系统（HDFS），有一致性算法（Zookeeper），有Table（Hive Table），有Tablet（Hive Table Partition），有列式存储 ...
【原创】大数据基础之Kudu（3）primary key
关于kudu的primary key The primary key may not be changed after the table is created. You must drop and recreate a table to select a new primary key. ...
【原创】大数据基础之Kudu（5）kudu增加或删除目录/数据盘
kudu加减数据盘不能直接修改配置fs_data_dirs后重启，否则会报错： Check failed: _s.ok() Bad status: Already present: FS layout already exists; not overwriting existing ...
【原创】大数据基础之Kudu（6）kudu tserver内存占用统计分析
kudu tserver占用内存过高后会拒绝部分写请求，日志如下： 19/06/01 13:34:12 INFO AsyncKuduClient: Invalidating location 34b1c13d04664cc8bae6689d39b08b77($kudu ...
大数据基础---Flink_Data_Sink
一、Data Sinks 在使用 Flink 进行数据处理时，数据经 Data Source 流入，然后通过系列 Transformations 的转化，最终可以通过 Sink 将计算结果进行输出，Flink Data Sinks 就是用于定义数据流最终的输出位置。Flink 提供了几个较为简单 ...