1.org.apache.flink.table.api.TableException: Table sink does not implement a table schema. 问题：在RedisTableSink中没有重写getTableSchema方法 解决：增加重写getTableSchema @Override public ...
