在线观看不卡亚洲电影_亚洲妓女99综合网_91青青青亚洲娱乐在线观看_日韩无码高清综合久久

鍍金池/ 問答/Java  網(wǎng)絡(luò)安全/ 使用flume ng寫數(shù)據(jù)到hbase 失敗

使用flume ng寫數(shù)據(jù)到hbase 失敗

使用flume ng 寫數(shù)據(jù)到hbase,使用org.apache.flume.sink.hbase.SimpleHbaseEventSerializer可以寫成功,只是寫到一個列里面,這不是我想要的。所以使用 org.apache.flume.sink.hbase.RegexHbaseEventSerializer,使用正則寫入。flume沒有錯誤日志,但是hbase中也沒有收到數(shù)據(jù)。

flume版本1.6.0 HBASE版本1.2.0

原始數(shù)據(jù):

one,two,three,four,five

tier1.sources.source1.channels = channel1
tier1.sinks.sink1.channel = channel1
tier1.sinks.sink1.type = hbase
tier1.sinks.sink1.table = host_table
tier1.sinks.sink1.columnFamily = host_info
tier1.sinks.sink1.serializer = org.apache.flume.sink.hbase.RegexHbaseEventSerializer
tier1.sinks.sink1.serializer.regex= ^(w+),(w+),(w+),(w+),(w+)$
tier1.sinks.sink1.serializer.rowKeyIndex = 0
tier1.sinks.sink1.serializer.colNames= ROW_KEY,o,z,w,d
tier1.sinks.sink1.batchSize = 50
tier1.sinks.sink1.zookeeperQuorum = 127.0.0.1:2181

回答
編輯回答
情皺

正則表達式不正確,匹配不了數(shù)據(jù),才導(dǎo)致hbase數(shù)據(jù)無法寫入

2018年1月14日 17:32