Hi 社区: 关于flink sql 使用上的一个问题以及一个sql异常 ------------------------------------ 我通过官网给出的结构编写代码时发现注册临时表方法无法被调用？[图1, 图 2, 图 3] 通过 tableEnvironment 调用createTemporaryTable 方法
我排查过。 但还是没能解决 1:包倒入的是官网所声明的包。 2:类倒入的是 flink.table.api.TableEnvironment/以及.java.StreamTableEnvironment 两个类 图 1 (依赖导入): https://imgkr.cn-bj.ufileos.com/941dbd86-34f4-4579-a53d-f7c04439d6f0.PNG 图 2 (import *): https://imgkr.cn-bj.ufileos.com/e19b90f7-ef60-42d8-a93e-d65c4269e053.png 图 3 (无法调用?): https://imgkr.cn-bj.ufileos.com/579e5336-503c-490f-83b9-ebb46bd1b568.png 图 4 (官网格式): https://imgkr.cn-bj.ufileos.com/fcc7365e-aecf-49a3-94e1-ae64ee67122e.png 图5 (TableException: findAndCreateTableSource failed 异常) https://imgkr.cn-bj.ufileos.com/386a783a-a42e-4466-97f8-540adb524be0.PNG 以及: https://imgkr.cn-bj.ufileos.com/9cac88cc-7601-4b03-ade1-f2432c84adac.PNG
