（无主题）

[黄志高]

各位大佬，在做远程提交任务到flink的standalone模式，抛以下异常
Caused by: java.lang.RuntimeException: java.lang.InterruptedException
at org.apache.flink.util.ExceptionUtils.rethrow(ExceptionUtils.java:277)
at org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:981)
at cn.encdata.cloud.dataengine.core.RemoteEnvironment.execute(RemoteEnvironment.java:145)
at cn.encdata.cloud.dataengine.core.builder.BatchJobBuilder.execute(BatchJobBuilder.java:89)
... 25 common frames omitted
Caused by: java.lang.InterruptedException: null
at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:347)
at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895)
at org.apache.flink.api.java.ExecutionEnvironment.executeAsync(ExecutionEnvironment.java:976)

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




[hidden email]