All Products
Search
Document Center

Lindorm:Use Flink to connect to and use LindormTable

Last Updated:Mar 21, 2025

You can use open source Apache Flink or Alibaba Cloud Realtime Compute for Apache Flink to connect to LindormTable. The method described in this topic to access LindormTable is applicable to both open source Apache Flink and Alibaba Cloud Realtime Compute for Apache Flink.

Background information

You can specify a Lindorm table as a Flink dimension table or result table, and then use Flink SQL or Flink DataStream to access the Flink dimension table or result table.

Prerequisites

  • If you use open source Apache Flink to connect to LindormTable, the version of LindormTable must be 2.4.3 or later. If you use Alibaba Cloud Realtime Compute for Apache Flink to connect to Lindorm table, the version of LindormTable is not limited. For more information about how to view or upgrade the version of LindormTable, see Release notes of LindormTable and Upgrade the minor engine version of a Lindorm instance.

  • The IP address of your client is added to the whitelist of your Lindorm instance. For more information, see Configure whitelists.

Usage notes

  • To connect to a Lindorm instance over the Internet or the Lindorm instance that you want to access is a single-node Lindorm instance, you must upgrade your SDK and change the configurations before you perform the operations described in this topic. For more information, see Step 1 in Use the ApsaraDB for HBase API for Java to connect to and use LindormTable.

  • If your application is deployed on an Elastic Compute Service (ECS) instance, make sure that your Lindorm instance and the ECS instance meet the following requirements in advance to ensure network connectivity:

    • Your Lindorm instance and ECS instance are deployed in the same region. We recommend that you also deploy the two instances in the same zone to reduce network latency.

    • Your Lindorm instance and ECS instance are deployed in the same VPC.

  • If you use open source Apache Flink to access Lindorm tables, you can access only HBase-like tables. SQL tables that are created by using lindorm-cli cannot be specified as dimension tables or result tables in open source Apache Flink. You can specify only HBase-like tables that are created by using the Hbaseue Shell as dimension tables or result tables in open source Flink. If you use Alibaba Cloud Realtime Compute for Apache Flink, you can access all Lindorm tables.

  • If you use Realtime Compute for Apache Flink together with Flink SQL to access Lindorm tables, you can use the Lindorm connector without the need to make modifications.

View endpoints

LindormTable endpoints for HBase APIs are used if you use Flink to access Lindorm tables. You can view the endpoints of LindormTable in the Lindorm console.

Important

If you access Lindorm tables by using a newly created account, make sure that the account has read and write permissions on the Flink tables. For more information about how to grant read and write permissions, see Grant permissions to a user.

image

Create a dimension table

Create a result table

  • If you want to use open source Flink to access Lindorm tables, follow the steps described in Create a result table.

  • If you want to use Realtime Compute for Apache Flink to access Lindorm tables, follow the steps described in Create a Lindorm result table.