Re: regular join每条流单独设置ttl

2023-02-14 文章 Jane Chan
你好,

目前 Flink SQL 还不支持为每条流单独设置 state TTL, 不过社区计划支持这个功能, 最近就会有 FLIP 提出, 也欢迎参与讨论.

Best regards,
Jane

On Wed, Feb 15, 2023 at 11:13 AM Jason_H  wrote:

> 大家好,
> 我遇到一个问题,在使用flinksql做双流join时,我用的是常规的regular
> join,分别是一条数据流,一条维表流,现在我想单独给数据流设置ttl,请教一下可以怎么做,flink版本是1.15.2
>
>
> | |
> Jason_H
> |
> |
> hyb_he...@163.com
> |


regular join每条流单独设置ttl

2023-02-14 文章 Jason_H
大家好,
我遇到一个问题,在使用flinksql做双流join时,我用的是常规的regular 
join,分别是一条数据流,一条维表流,现在我想单独给数据流设置ttl,请教一下可以怎么做,flink版本是1.15.2


| |
Jason_H
|
|
hyb_he...@163.com
|

Re: 运行中的作业状态清除操作

2023-02-14 文章 Shammon FY
Hi

这个是无法办到的,建议还是重启

On Mon, Feb 13, 2023 at 4:33 PM Jason_H  wrote:

> 遇到的问题:在flink中,使用状态的地方已经设置了ttl, 但是上下游把数据清空了,然后想重新测试发现,
> flink计算的结果不是从0开始累计的,是基于之前的结果继续累计的,这种情况在不重启作业的情况下 有什么办法处理吗?
>
>
> 具体来说就是,在不停止flink作业的情况下,怎么清楚运行中的flink作业的状态数据,以达到计算结果归0开始累计。
>
>
> 在不重启作业的情况下,清空状态数据是不是和重启作业运行是一样的效果,避免状态累计数据对结果产生影响呢。
> | |
> Jason_H
> |
> |
> hyb_he...@163.com
> |