search

gaogao110 / flink-sql-connector-phoenix

8 stars 5 forks source link

flink sql client 执行select 查询报错Could not execute SQL statement. #6

Open mht14208 opened 2 years ago

mht14208 commented 2 years ago

Flink SQL> CREATE TABLE pv (

id VARCHAR,
name VARCHAR,
addr VARCHAR,

PRIMARY KEY (id) NOT ENFORCED ) WITH ( 'connector.type' = 'phoenix', 'connector.url' = 'jdbc:phoenix:node01:2181', 'connector.table' = 'student',
'connector.driver' = 'org.apache.phoenix.jdbc.PhoenixDriver', 'connector.username' = '', 'connector.password' = '', 'phoenix.schema.isnamespacemappingenabled' = 'true', 'phoenix.schema.mapsystemtablestonamespace' = 'true', 'connector.write.flush.max-rows' = '1' ); [INFO] Execute statement succeed.

Flink SQL> select * from pv; [ERROR] Could not execute SQL statement. Reason: org.apache.flink.table.client.gateway.SqlExecutionException: Could not execute SQL statement.