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 Px New <15...@gmail.com> on 2020/06/08 14:01:21 UTC

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

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

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

Posted by Px New <15...@gmail.com>.
Hi *Benchao Li*   Thanks ,你说的很对 我现在已经走在了sql的实践道路上(还好有你指出)

Benchao Li <li...@gmail.com> 于2020年6月9日周二 上午10:05写道：

> Hi,
> 我看你用的是1.9.1版本，但是createTemporaryTable应该是在1.10之后才引入的。不知道你参考的是哪一版的文档呢？
>
> Px New <15...@gmail.com> 于2020年6月8日周一 下午10:00写道：
>
> > 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
> >
>
>
> --
>
> Best,
> Benchao Li
>

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

Posted by Benchao Li <li...@gmail.com>.
Hi,
我看你用的是1.9.1版本，但是createTemporaryTable应该是在1.10之后才引入的。不知道你参考的是哪一版的文档呢？

Px New <15...@gmail.com> 于2020年6月8日周一 下午10:00写道：

> 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
>


-- 

Best,
Benchao Li