在将旧版本升级至1.12版本中,需要支持proctime和eventime时发现 
DefinedProctimeAttribute该方法已过期,但是查看官方文档https://ci.apache.org/projects/flink/flink-docs-release-1.12/zh/dev/table/streaming/time_attributes.html#%E4%BD%BF%E7%94%A8-tablesource-%E5%AE%9A%E4%B9%89-1
  实例仍然使用 DefinedProctimeAttribute该方法 且并没有说明替换方法?


guaishushu1...@163.com

回复