flink-cdc-connectors: java.lang.NoSuchMethodError: 'org.apache.flink.table.catalog.CatalogTable org.apache.flink.table.factories.DynamicTableFactory$Context.getCatalogTable()'

https://www.bilibili.com/video/BV1zt4y1D7kt/ 按照步骤最后错误

Flink. 1.13.1

问题一

Flink SQL> INSERT INTO enriched_orders
> SELECT o.*, p.name, p.description, s.shipment_id, s.origin, s.destination, s.is_arrived
> FROM orders AS o
> LEFT JOIN products AS p ON o.product_id = p.id
> LEFT JOIN shipments AS s ON o.order_id = s.order_id;
[ERROR] Could not execute SQL statement. Reason:
java.lang.NoSuchMethodError: 'org.apache.flink.table.catalog.CatalogTable org.apache.flink.table.factories.DynamicTableFactory$Context.getCatalogTable()'

发现和java的版本好像有关系,但是无论怎么样,最后进入的命令永远跑步起来

About this issue

  • Original URL
  • State: closed
  • Created 3 years ago
  • Comments: 16

Most upvoted comments

最后咋解决的呀,能否提供下方法,我几个jar包都试过了,还是这个错误

sql es 的jar包需要升级到 1.13版本,升级了试下?

最后咋解决的呀,能否提供下方法,我几个jar包都试过了,还是这个错误

https://ververica.github.io/flink-cdc-connectors/master/content/about.html#supported-flink-versions

cdc的版本要合flink的版本匹配

我也碰到了,应该是和jar有关系,主要错误是期望的是方法 getCatalogTable()返回CatalogTable,但是实际返回了 ResolvedCatalogTable

有没有解决方法😭,徘徊了一天