?????????????????????????? flink????v1.11????phoneix 1.14.1???????? CREATE TABLE pe_login_kafka ( id INT, region_id INT, ts TIMESTAMP(3), proc_time AS PROCTIME() ) WITH ( 'connector' = 'kafka', 'topic' = 't-region, 'properties.bootstrap.servers' = 'xxxx', 'properties.group.id' = gid');
CREATE TABLE region_dim( id INT, region_name STRING ) WITH ( 'connector' = 'jdbc', 'url' = 'jdbc:phoenix:thin:url=http://172.168.1.15:8765;serialization=PROTOBUF', 'table-name' = ph_region', 'lookup.cache.max-rows' = '5000', 'lookup.cache.ttl' = '600s', 'lookup.max-retries' = '3'); --sink INSERT INTO xxxx FROM pe_login_kafka k LEFT JOIN region_dim FOR SYSTEM_TIME AS OF k.proc_time AS u ON k.region_id = u.id; ??????????,???????????????????????????? Caused by: java.sql.SQLException at org.apache.calcite.avatica.Helper.createException(Helper.java:56) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.calcite.avatica.Helper.createException(Helper.java:41) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.calcite.avatica.AvaticaConnection.executeQueryInternal(AvaticaConnection.java:557) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.calcite.avatica.AvaticaPreparedStatement.executeQuery(AvaticaPreparedStatement.java:137) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.flink.connector.jdbc.table.JdbcRowDataLookupFunction.eval(JdbcRowDataLookupFunction.java:152) ~[flink-connector-jdbc_2.11-1.11.1.jar:1.11.1] ... 18 more Caused by: org.apache.calcite.avatica.NoSuchStatementException at org.apache.calcite.avatica.remote.RemoteMeta$15.call(RemoteMeta.java:349) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.calcite.avatica.remote.RemoteMeta$15.call(RemoteMeta.java:343) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.calcite.avatica.AvaticaConnection.invokeWithRetries(AvaticaConnection.java:793) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.calcite.avatica.remote.RemoteMeta.execute(RemoteMeta.java:342) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.calcite.avatica.AvaticaConnection.executeQueryInternal(AvaticaConnection.java:548) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] ... 20 more 2021-01-05 19:40:07,469 ERROR org.apache.flink.connector.jdbc.table.JdbcRowDataLookupFunction [] - JDBC executeBatch error, retry times = 2 java.sql.SQLException: null at org.apache.calcite.avatica.Helper.createException(Helper.java:56) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.calcite.avatica.Helper.createException(Helper.java:41) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.calcite.avatica.AvaticaConnection.executeQueryInternal(AvaticaConnection.java:557) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.calcite.avatica.AvaticaPreparedStatement.executeQuery(AvaticaPreparedStatement.java:137) ~[flink-table-blink_2.11-1.11.1.jar:1.11.1] at org.apache.flink.connector.jdbc.table.JdbcRowDataLookupFunction.eval(JdbcRowDataLookupFunction.java:152) [flink-connector-jdbc_2.11-1.11.1.jar:1.11.1] ??????????jdbc??????????????????org.apache.calcite.avatica.AvaticaConnection??connection??????Statement ?????????????????????????????????????????????????? ????????????????????????????
