Re: Flink sql 中 无法通过 TableEnvironment 调出 createTemporaryTable()方法 以及.TableException: findAndCreateTableSource failed 异常

2020-06-09 文章 Px New
Hi *Benchao Li* Thanks ,你说的很对 我现在已经走在了sql的实践道路上(还好有你指出) Benchao Li 于2020年6月9日周二 上午10:05写道: > Hi, > 我看你用的是1.9.1版本,但是createTemporaryTable应该是在1.10之后才引入的。不知道你参考的是哪一版的文档呢? > > Px New <15701181132mr@gmail.com> 于2020年6月8日周一 下午10:00写道: > > > Hi 社区: 关于flink sql 使用上的一个问题以及一个sql异常 > > --

Re: Flink sql 中 无法通过 TableEnvironment 调出 createTemporaryTable()方法 以及.TableException: findAndCreateTableSource failed 异常

2020-06-08 文章 Benchao Li
Hi, 我看你用的是1.9.1版本,但是createTemporaryTable应该是在1.10之后才引入的。不知道你参考的是哪一版的文档呢? Px New <15701181132mr@gmail.com> 于2020年6月8日周一 下午10:00写道: > Hi 社区: 关于flink sql 使用上的一个问题以及一个sql异常 > > 我通过官网给出的结构编写代码时发现注册临时表方法无法被调用?[图1, 图 2, 图 3] > 通过 tableEnvironment 调用createTemporar

Flink sql 中 无法通过 TableEnvironment 调出 createTemporaryTable()方法 以及.TableException: findAndCreateTableSource failed 异常

2020-06-08 文章 Px New
Hi 社区: 关于flink sql 使用上的一个问题以及一个sql异常 我通过官网给出的结构编写代码时发现注册临时表方法无法被调用?[图1, 图 2, 图 3] 通过 tableEnvironment 调用createTemporaryTable 方法 我排查过。 但还是没能解决 1:包倒入的是官网所声明的包。 2:类倒入的是 flink.table.api.TableEnvironment/以及.java.StreamTableEnvironment 两个类 图 1 (依赖导入): https://img