You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user-zh@flink.apache.org by 黑色 <xi...@qq.com> on 2021/01/05 12:20:14 UTC

flinksql1.11 查询phoenix维表报错Caused by: org.apache.calcite.avatica.NoSuchStatementException

各位大佬们，请教上面的问题
flink版本v1.11查询phoneix 1.14.1做为维表
CREATE TABLE pe_login_kafka (
&nbsp;id INT,
region_id INT,
&nbsp;ts TIMESTAMP(3),
&nbsp;proc_time AS PROCTIME()
) WITH (
&nbsp;'connector' = 'kafka',
&nbsp;'topic' = 't-region,
&nbsp;'properties.bootstrap.servers' = 'xxxx',
&nbsp;'properties.group.id' = gid');



CREATE TABLE region_dim(
&nbsp; id INT,
&nbsp; region_name STRING
&nbsp;) WITH (
&nbsp;'connector' = 'jdbc',
&nbsp; 'url' = 'jdbc:phoenix:thin:url=http://172.168.1.15:8765;serialization=PROTOBUF',
&nbsp; 'table-name' = ph_region',
&nbsp; 'lookup.cache.max-rows' = '5000',
&nbsp; 'lookup.cache.ttl' = '600s',
&nbsp; 'lookup.max-retries' = '3');

--sink
INSERT INTO xxxx
FROM pe_login_kafka&nbsp; k LEFT JOIN region_dim&nbsp; 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
错误不是一直出现，偶尔半天一次，有时候一天好几次。


各位大佬们帮我看看哪的问题。

回复: flinksql1.11 查询phoenix维表报错Caused by: org.apache.calcite.avatica.NoSuchStatementException

Posted by Evan <ch...@foxmail.com>.
这个问题不止你一个人遇到，这应该是一个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&nbsp; k LEFT JOIN region_dim&nbsp; 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
错误不是一直出现，偶尔半天一次，有时候一天好几次。
 
 
各位大佬们帮我看看哪的问题。

Re: 回复: flinksql1.11 查询phoenix维表报错Caused by: org.apache.calcite.avatica.NoSuchStatementException

Posted by hoose <30...@qq.com>.
@chengyanan1008@foxmail.com 你那里也遇过吗，这个要是bug，也不会修复呀



--
Sent from: http://apache-flink.147419.n8.nabble.com/