??????????????????????????????????????bug
???????? ???? ?????????? 2021-01-05 20:20 ???????? user-zh ?????? flinksql1.11 ????phoenix????????Caused by: org.apache.calcite.avatica.NoSuchStatementException ?????????????????????????? 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 ?????????????????????????????????????????????????? ????????????????????????????
