CREATE TABLE test (phone STRING,open_station_code STRING,open_station_name STRING,open_area_code STRING,open_area_name STRING,open_province_code STRING,open_province_name STRING,create_time STRING) WITH ( ‘connector’=‘starrocks’, ‘scan-url’=‘192.168.81.113:8030,192.168.81.114:8030,192.168.81.115:8030,192.168.81.116:8030,192.168.81.117:8030’, ‘jdbc-url’=‘jdbc:mysql://192.168.81.113:9030’, ‘username’=‘root’, ‘password’=‘OT7^mTtqZ$QA’, ‘database-name’=‘falcon’, ‘table-name’=‘portrait_rfm_detail_day_to_es’ );
select phone , open_station_code, open_station_name,open_province_code,open_province_name from test;
flink报错
[ERROR] Could not execute SQL statement. Reason:
java.lang.RuntimeException: Request of get query plan failed with code 400 {“exception”:“Unknown column ‘open_province_code’ in ‘table list’”,“status”:400}
表结构
