我在1.1快照版本上使用Apache的Table来评估流上的SQL查询。,它会抛出以下异常:
Exception in thread "main" org.apache.flink.api.table.TableException: Alias on field referenceat org.apache.flink.api.table.TableEnvironment$$an
我试图在scala中使用Flink表API。编译时间没有错误,但是我正在flink集群中运行作业:flink.api.table.TableException: Type is not supported:<GenericType<java.lang.Object><dependency>
<groupId>org.apache.<e
我想使用flink sql client创建一个配置单元表。我可以成功创建表t2,但是当我查询t2时,它会报错 Table options do not contain an option key 'connector' for discovering a connector我已经在conf/sql-client-defaults.yaml文件中设置执行类型为batch。 我会问这里有什么问题。谢谢!Flink SQL> use te