Hi Yun Tang
感谢你的回复,我们在调研的过程中也发现,正如你所说的生成的plan可能差异很大
但是每个operator的TTL生效时间是在execNode转换成对应的Transformation时,通过传入的StreamPlanner带进去的,TableConfig属性中包含了全局的TTL时间
在每个ExecNode转换的过程translateToPlanInternal((PlannerBase)
planner)中使用这个TTL时间生成对应的operator
所以我们在考虑是否可以在,每个Transformation生成阶段,先去修改一下TableConfig中TTL
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
感谢你的回复,我们在调研的过程中也发现,正如你所说的生成的pl
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没有上述问题。
作业