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 黄志高 <hu...@163.com> on 2021/03/16 07:27:53 UTC

（无主题）

各位大佬，在做远程提交任务到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)

FlinkSql 的一些疑问

Posted by "songzhongshun@kedacom.com" <so...@kedacom.com>.

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




songzhongshun@kedacom.com