FlinkSql 的一些疑问

Tue, 16 Mar 2021 20:12:57 -0700 

请教如下问题：
   1.  TableEnvironment 的 Checkpoint 以及 RestartStrategy 如何设置？ 是仅有通过设置 
StreamTableEnvironment ，再 create TableEnv 的方式吗？
   2.  使用catalog 时, 对于已经存在的物理表，如何指定 表字段为EventTime 以及Watermark 
如何设置。还需要CreateTable 吗？




songzhongs...@kedacom.com

回复