Hi all, I started to learn Flink last week and Now...
# troubleshooting
f
Hi all, I started to learn Flink last week and Now Im trying to do simple write/upsert my Table to Hbase table . I couldn't find any updated sources on internet. in Stackoverflow Most links are not exist now. Im using Flink 1.15.1 , Java 11, Hbase 2.2.3 and hadoop 3.1.1 Have you got any samples or sources about flink to hbase ? Thanks, best regards.
s
There should be something in the connectors section. Check out the documentation.
f
I did but It doesnt give me a code sample. It just says dependency for pom.xml file. https://nightlies.apache.org/flink/flink-docs-release-1.15/docs/connectors/table/hbase/ this documentation is not enough to write code. 😞
What I need is " how can I send/write/upsert data from table api (Table object) to Hbase table" code example/sample.
s
You have to register the hbase table in the flink sql. It is mentioned in the docs.