Flink Table Store Trino

Because Trino's dependency is JDK 11, it is not possible to include the trino connector in flink-table-store.

Please use JDK 11, currently only the Trino version with JDK 11 is supported

Deploy Table Store Trino Connector

Building Table Store Trino Bundled Jar is by running (JDK 11 required):

• Trino 388: mvn clean install -DskipTests
• Trino 358: mvn clean install -DskipTests -Ptrino-358

Then, copy target/flink-table-store-trino-*.jar and flink-shaded-hadoop-2-uber-2.8.3-10.0.jar to plugin/tablestore.

Configure Table Store Catalog

Catalogs are registered by creating a catalog properties file in the etc/catalog directory. For example, create etc/catalog/tablestore.properties with the following contents to mount the tablestore connector as the tablestore catalog:

connector.name=tablestore
warehouse=file:/tmp/warehouse

If you are using HDFS, choose one of the following ways to configure your HDFS:

• set environment variable HADOOP_HOME.
• set environment variable HADOOP_CONF_DIR.
• configure fs.hdfs.hadoopconf in the properties.

You can configure kerberos keytag file when using KERBEROS authentication in the properties.

security.kerberos.login.principal=hadoop-user
security.kerberos.login.keytab=/etc/trino/hdfs.keytab

Keytab files must be distributed to every node in the cluster that runs Trino.

Query

SELECT * FROM tablestore.default.MyTable