dear all：
如题，我在调用RestClusterClient#cancel(JobID jobId)方法取消作业时，get不到结果，但作业能正常停止。
用future.get()会报错如下：
Number of retries has been exhausted.
用future.get(10, TimeUnit.SECONDS)会报错timeout.
调用#cancelWithSavepoint(...)和#stopWithSavepoint(...)就没问题，可以正常获取到结果，不报错。
目前发现，
1.10.0有问题，
1.14.0没有上述问题。
dear all：
如题，我在调用RestClusterClient#cancel(JobID jobId)方法取消作业时，get不到结果，但作业能正常停止。
用future.get()会报错如下：
Number of retries has been exhausted.
用future.get(10, TimeUnit.SECONDS)会报错timeout.
调用#cancelWithSavepoint(...)和#stopWithSavepoint(...)就没问题，可以正常获取到结果，不报错。
目前发现，
1.10.0有问题，
1.14.0没有上述问题。
Hi,
如果你们可以自己实现一套SQL语句到jobgraph的预编译转换IDE，然后在IDE中可以手动配置jobgraph每个算子的配置，应该是可以达到你们的目的
（可能还需要结合细粒度调度模式）。
祝好
唐云
From: gygz...@163.com
Sent: Thursday, December 9, 2021 16:14
To: user-zh
Subject: 回复: Re: flink sql支持细粒度的状态配置
Hi Yun Tang
Hi Yun Tang
感谢你的回复，我们在调研的过程中也发现，正如你所说的生成的plan可能差异很大
但是每个operator的TTL生效时间是在execNode转换成对应的Transformation时，通过传入的StreamPlanner带进去的，TableConfig属性中包含了全局的TTL时间
在每个ExecNode转换的过程translateToPlanInternal((PlannerBase)
planner)中使用这个TTL时间生成对应的operator
