【Could we support distribute by For FlinkSql】

2022-05-08 文章 lpengdr...@163.com
; lpengdr...@163.com

【Log4j.properties使用AsyncAppender】

2021-12-16 文章 lpengdr...@163.com
Hi: flink使用log4j.properties配置,.properties配置似乎没有办法配置AsyncAppender,所以在flink的日志没有办法使用AsyncAppender了吗?是否有其他的办法可以绕行 lpengdr...@163.com

Flink OperatorChain AsyncWaitOperator

2021-09-02 文章 lpengdr...@163.com
Hi: 请教下Flink的operator-chain的机制, 我看AsyncWaitOperator的chainingStrategy是ALWAYS,但是实际使用发现在所有算子并行度都设置为1的情况下这个operator没有办法和上游算子chain串起来只能跟下游的算子slot共享,这里边是还有什么其他规则吗?

Re: flink1.12.2 sql session窗口间隔时间段内没有新数据窗口不关闭

2021-06-18 文章 lpengdr...@163.com
你用EventTimeSession窗口的超时也是按照你的事件时间来判断的,要有超过超时时间边界的数据输入了才能触发 lpengdr...@163.com 发件人: raofang 发送时间: 2021-06-18 12:20 收件人: user-zh 主题: flink1.12.2 sql session窗口间隔时间段内没有新数据窗口不关闭 hi,请教大家一个问题: flink1.12.2 sql BlinkPlanner 使用基于routime的session窗口时,在设置的间隔时间10分钟内没有接收到新数据,窗口没有关闭输出计算结果;但是接收到10分钟之后的新数据时