schema操作创建schemacreate schema "foo";切换schemause "foo";删除schemadrop schema if exists "foo";0: jdbc:phoenix:thin:url=http://hb-bp1ya00iwt> create schema "foo";No rows affected (0.234 seconds)0: jdbc:

org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: No operators defined in streaming topology. Cannot execute.The program finished with the following exceptio

升级flink1.14.3报错Caused by: org.apache.flink.table.api.ValidationException: Unable to create a source for reading table 'default_catalog.default_database.new_buyer_trade_order2'CAUSED BY: 2022-03-11 16: