RE: Working with HBase inside RichMapFunction

2021-11-23 Thread Anton
Weng [mailto:tsreape...@gmail.com] Sent: Wednesday, November 24, 2021 4:47 AM To: Anton Cc: user Subject: Re: Working with HBase inside RichMapFunction Hi! Which Flink version are you using? Are you putting data into HBase inside RichMapFunction, instead of using an HBase sink? If yes coul

Re: Working with HBase inside RichMapFunction

2021-11-23 Thread Caizhi Weng
Hi! Which Flink version are you using? Are you putting data into HBase inside RichMapFunction, instead of using an HBase sink? If yes could you share your user code? Actually using an HBase sink is recommended because it will check if any error occurs during the operation and will fail the job (an

Working with HBase inside RichMapFunction

2021-11-23 Thread Anton
Hi, I'm using RichMapFunction to enrich data from stream generated from Kafka topic and put rich data again to HBase. And when there is a failure on HBase side I'm seeing in Flink's log that HBase client attempts several times to get necessary data from HBase - I believe it makes it `hbase.client.r