. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 12 1.1.2.1 QuickStart: Table API . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 12 1.1.2.2 QuickStart: DataStream 26 1.3.4.1 O1: Could not find any factory for identifier ‘xxx’ that implements ‘org.apache.flink.table.factories.DynamicTableFactory’ in the classpath . . . . . . . 26 1.3.4.2 O2: ClassNotFoundException: . . . 29 1.3.4.3 O3: NoSuchMethodError: org.apache.flink.table.factories.DynamicTableFactory$Context.getCatalogTable()Lorg/apache/flink/table/catalog/CatalogTable 30 1.3.5 Runtime issues . . . . . .

. . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 12 1.1.2.1 QuickStart: Table API . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . . 12 1.1.2.2 QuickStart: DataStream 26 1.3.4.1 O1: Could not find any factory for identifier ‘xxx’ that implements ‘org.apache.flink.table.factories.DynamicTableFactory’ in the classpath . . . . . . . 26 1.3.4.2 O2: ClassNotFoundException: . . . 29 1.3.4.3 O3: NoSuchMethodError: org.apache.flink.table.factories.DynamicTableFactory$Context.getCatalogTable()Lorg/apache/flink/table/catalog/CatalogTable 30 1.3.5 Runtime issues . . . . . .

cloud storage or an on-prem HDFS cluster. Lakehouse formation and analytics Easily build an ACID table storage layer via Hudi, Iceberg, or/and Delta Lake. Logical data warehouse Provide a relational beeline console. For instance, > SHOW DATABASES; You will see a wall of operation logs, and a result table in the beeline console. omitted logs +------------+ | namespace | +------------+ | default | method name: 'get_table_req' at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:79) at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_ge t_table_req(ThriftHiveMetastore

cloud storage or an on-prem HDFS cluster. Lakehouse formation and analytics Easily build an ACID table storage layer via Hudi, Iceberg, or/and Delta Lake. Logical data warehouse Provide a relational beeline console. For instance, > SHOW DATABASES; You will see a wall of operation logs, and a result table in the beeline console. omitted logs +------------+ | namespace | +------------+ | default | method name: 'get_table_req' at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:79) at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_ge t_table_req(ThriftHiveMetastore

cloud storage or an on-prem HDFS cluster. Lakehouse formation and analytics Easily build an ACID table storage layer via Hudi, Iceberg, or/and Delta Lake. Logical data warehouse Provide a relational beeline console. For instance, > SHOW DATABASES; You will see a wall of operation logs, and a result table in the beeline console. omitted logs +------------+ | namespace | +------------+ | default | method name: 'get_table_req' at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:79) at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_ge t_table_req(ThriftHiveMetastore

storage or an on-prem HDFS cluster. • Lakehouse formation and analytics – Easily build an ACID table storage layer via Hudi, Iceberg, or/and Delta Lake. • Logical data warehouse – Provide a relational beeline console. For instance, > SHOW DATABASES; You will see a wall of operation logs, and a result table in the beeline console. omitted logs +------------+ | namespace | +------------+ | default | +------------+ method name: 'get_table_req' at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:79) at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_get_ ˓→table_req(ThriftHiveMetastore

storage or an on-prem HDFS cluster. • Lakehouse formation and analytics – Easily build an ACID table storage layer via Hudi, Iceberg, or/and Delta Lake. • Logical data warehouse – Provide a relational beeline console. For instance, > SHOW DATABASES; You will see a wall of operation logs, and a result table in the beeline console. omitted logs +------------+ | namespace | +------------+ | default | +------------+ method name: 'get_table_req' at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:79) at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_get_ ˓→table_req(ThriftHiveMetastore

storage or an on-prem HDFS cluster. • Lakehouse formation and analytics – Easily build an ACID table storage layer via Hudi, Iceberg, or/and Delta Lake. • Logical data warehouse – Provide a relational beeline console. For instance, > SHOW DATABASES; You will see a wall of operation logs, and a result table in the beeline console. omitted logs +------------+ | namespace | +------------+ | default | +------------+ method name: 'get_table_req' at org.apache.thrift.TServiceClient.receiveBase(TServiceClient.java:79) at org.apache.hadoop.hive.metastore.api.ThriftHiveMetastore$Client.recv_get_ ˓→table_req(ThriftHiveMetastore

e.t.c... Or, you can manipulate data from different data sources with the Spark Datasource/Flink Table API, e.g. Delta Lake, Apache Hudi, Apache Iceberg, Apache Kudu and e.t.c... Installation To install any query supported by Flink SQL now. For example, 0: jdbc:hive2://127.0.0.1:10009/default> CREATE TABLE T ( . . . . . . . . . . . . . . . . . . . . . . > a INT, . . . . . . . . . . . . . . . . . . . . ˓→query[22a73e39-d9d7-479b-a118-33f9d2a5ad3f]: INITIALIZED_STATE -> PENDING_STATE,␣ ˓→statement: CREATE TABLE T( a INT, b VARCHAR(10) ) WITH ( 'connector.type' = 'filesystem', 'connector.path' = 'file:///tmp/T

Mesos, e.t.c… Or, you can manipulate data from different data sources with the Spark Datasource/Flink Table API, e.g. Delta Lake, Apache Hudi, Apache Iceberg, Apache Kudu and e.t.c… Installation To install any query supported by Flink SQL now. For example, 0: jdbc:hive2://127.0.0.1:10009/default> CREATE TABLE T ( . . . . . . . . . . . . . . . . . . . . . . > a INT, . . . . . . . . . . . . . . . . . . query[22a73e39-d9d7-479b-a118-33f9d2a5ad3f]: INITIALIZED_STATE -> PENDING_STATE, statement: CREATE TABLE T( a INT, b VARCHAR(10) ) WITH ( 'connector.type' = 'filesystem', 'connector.path' = 'file:///tmp/T