Flink自定义Sink
Flink 自定义Sink,把socket数据流数据转换成对象写入到mysql存储。
#创建Student类
public class Student {
private int id;
private String name;
private int age;
@Overri...
1.org.apache.flink.table.api.TableException: Table sink does not implement a table schema.
问题:在RedisTableSink中没有重写getTableSchema方法
解决:增加重写getTableSchema
@Override
public ...