You are viewing a plain text version of this content. The canonical link for it is here.

Posted to user-zh@flink.apache.org by "songzhongshun@kedacom.com" <so...@kedacom.com> on 2021/03/17 03:12:27 UTC

FlinkSql 的一些疑问

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




songzhongshun@kedacom.com