Flink1.13.1??????Catalog????????

Flink1.13.1??Catalog?? ?? JdbcCatalogFactory implements CatalogFactory ?? public Map

Re: 回复：flink怎么读kafka offset

我理解的是这样，虽然不是从savepoint里恢复，但kafka consumer_topic有了我们之前保存的groupid,那么默认的是flink是这样设置： setStartFromGroupOffsets()：默认值，从当前消费组记录的偏移量开始，接着上次的偏移量消费 这样可以理解还是从上次提交的offset开始继续消费对吧？ -- Sent from: http://apache-flink.147419.n8.nabble.com/

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

@chengyanan1...@foxmail.com 你那里也遇过吗，这个要是bug，也不会修复呀 -- Sent from: http://apache-flink.147419.n8.nabble.com/

Flinksql????phoenix????????????Caused by: org.apache.calcite.avatica.NoSuchStatementException

flinksqlkafka, connector phoenix 2020-11-24 00:52:38,534 ERROR com.custom.jdbc.table.JdbcRowDataLookupFunction[] - JDBC executeBatch error, retry times = 2 java.sql.SQLException: null at