需要在flink工作中读写Mysql

Question

我正在尝试使用API表，但得到一个错误

TableEnvironment fbTableEnv=BatchTableEnvironment.create(fbEnv(；[错误]^^^^^^[错误]接口BatchTableEnvironment的此静态方法只能作为BatchTableEnvironment.create访问[ERROR]1个问题(1个错误([错误]

ExecutionEnvironment fbEnv = ExecutionEnvironment.getExecutionEnvironment();TableEnvironment fbTableEnv = BatchTableEnvironment.create(fbEnv);

Answer 1

BatchTableEnvironment仅因遗留原因而存在。对于常规SQL和批处理作业，我们建议使用TableEnvironment.create，它是统一的，可以处理批处理和流式数据。