kafka-flink-hbase icon indicating copy to clipboard operation
kafka-flink-hbase copied to clipboard

Published 20 hours ago • verified publisher icon duhanmin

map中使用Hbase连接池的问题

Open wangzhiwubigdata opened this issue 5 years ago • 2 comments

您好，我看了您的代码，有一个疑问。 transction.rebalance().map 请问在这里面用连接池的方式是否有问题，当kafka数据量很大的时候，会开大量的hbase connection，会不会把hbase连接池撑爆？这里可以用mapPartition 函数吗？

wangzhiwubigdata avatar Mar 05 '19 03:03 wangzhiwubigdata

您好 用了 ，跑不通啊

yangle9567 avatar May 19 '20 05:05 yangle9567

请问您这跑通时用的flink什么版本？ 为何不用datastream.addsink(new RichSinkFuction(){})

yangle9567 avatar May 19 '20 05:05 yangle9567