flink??flink-on-yarn??jobTimeStampcurrent_dateenv.setStateBackend(new
?? flink
sql??cdccdc??state??
state??
val config: TableConfig = tabEnv.getConfig
想了解一下flink sql state里的东西，是否可以用datastream里的queryable api 查询 ？ 怎么查询呢，是需要知道key
才可以查询么。
诉求就是想知道state里到底存的啥
Hi,
??
----
??:"Benchao Li"https://issues.apache.org/jira/browse/FLINK-17942
LakeShen
Hi,
这应该是个bug，之前也有人跟我提过，我没在意。现在看来应该的确是bug，我在本地复现了一下。我建了一个issue[1] 来跟踪和修复。
[1] https://issues.apache.org/jira/browse/FLINK-17942
LakeShen 于2020年5月26日周二 下午8:14写道：
> Hi,
>
> 看下是否存在热点问题，我看你根据 server,reason 这两个字段来进行 group by
>
> Best,
> LakeShen
>
> Benchao Li 于2020年5月26日周二 下午6:50写道：
>
> > Hi，
> >
Hi,
看下是否存在热点问题，我看你根据 server,reason 这两个字段来进行 group by
Best,
LakeShen
Benchao Li 于2020年5月26日周二 下午6:50写道：
> Hi，
>
> 看起来你的写法应该没有太大问题。可能有两个问题需要确认一下：
> 1. 你的watermark生成的正确吗？也就是说window的结果有正常输出么？如果watermark延迟很高，是会导致有多个window同时存在的
> 2. 你是怎么判断state上升呢？通过checkpoint看出来的？还是看到heap一直上升？
>
> 瓜牛
Hi，
看起来你的写法应该没有太大问题。可能有两个问题需要确认一下：
1. 你的watermark生成的正确吗？也就是说window的结果有正常输出么？如果watermark延迟很高，是会导致有多个window同时存在的
2. 你是怎么判断state上升呢？通过checkpoint看出来的？还是看到heap一直上升？
瓜牛 于2020年5月26日周二 下午6:07写道：
> hi，大家好!
>
> 现象：在用纯 Flink SQL 来运行滚动窗口的 job 时，state 的大小一直在增加
>
> SQL：source 和 sink 都是 kafka
hi!
Flink SQL job state
SQL??source ?? sink kafka ??5
server,reason role_id
state
Hi,
AFAIK, whether a timer will fire is irrelevant to checkpoint success or not.
Best,
Congxian
LakeShen 于2020年1月16日周四 下午8:53写道：
> Hi community， now I am using Flink sql , and I set the retention time, As
> I all know is that Flink will set the timer for per key to clear their
> state, if
Hi community， now I am using Flink sql , and I set the retention time, As I
all know is that Flink will set the timer for per key to clear their state,
if Flink task always checkpoint failure, are the key state cleared by
timer?
Thanks to your replay.
10 matches
Mail list logo
