好滴呀 谢谢各位老师指导
| |
小昌同学
|
|
ccc0606fight...@163.com
|
回复的原邮件
| 发件人 | Yanfei Lei |
| 发送日期 | 2023年8月10日 11:50 |
| 收件人 | |
| 主题 | Re: Flink 窗口触发条件 |
hi,
Hi Flink users,
When using Flink operator, how to restart jobs from a checkpoint. I am used to
the Flink Kubernetes native deployment, where I can run
flink run -s
How to achieve that in Flink operator
Thanks
Ivan
hi,
感觉和[1]的问题比较像，事件时间的window在onElement和onEventTime时会触发，这两个方法又会根据watermark判断，可以看看o.a.f.table.runtime.operators.window.triggers包和o.a.f.table.runtime.operators.wmassigners包。
[1] https://juejin.cn/post/6850418110010179597
小昌同学 于2023年8月10日周四 10:52写道：
>
>
各位老师好，我这边在使用Flink的事件时间窗口的时候，关于窗口触发的条件我有一点疑问想咨询一下各位老师
我是开了一个2分钟的事件时间的窗口，但是等到两分钟后窗口并没有主动触发，等我后面再发一条数据的时候，窗口再进行了触发
所以我想请问一下窗口的触发机制不是时间点嘛，而是非要等到下一条数据发送，依赖于下一条数据携带的时间戳大于窗口的结束时间，上一个窗口才会真正的触发嘛
请各位老师指导一下
| |
小昌同学
|
|
ccc0606fight...@163.com
|
退订
好的 谢谢各位老师的指导
| |
小昌同学
|
|
ccc0606fight...@163.com
|
回复的原邮件
| 发件人 | ron |
| 发送日期 | 2023年8月10日 00:51 |
| 收件人 | |
| 主题 | Re: 回复： Flink消费MySQL |
Hi,
建议通过CDC实时读，然后用Flink的双流Join进行关联。
-原始邮件-
发件人: "小昌同学"
发送时间: 2023-08-08 11:10:19 (星期二)
收件人: user-zh
抄送: user-zh
主题: 回复：
Hi,
这个报错看起来确实很奇怪，你可以给一个完整的使用SQL吗，这样可以方便去复现一下。
> -原始邮件-
> 发件人: "junjie.m...@goupwith.com"
> 发送时间: 2023-08-03 17:05:03 (星期四)
> 收件人: user-zh
> 抄送:
> 主题: 自定义ScalarFunction函数运行报错
>
> public static class MatrixToRowFunction extends ScalarFunction {
> @DataTypeHint("ROW>")
> public
Hi,
建议通过CDC实时读，然后用Flink的双流Join进行关联。
> -原始邮件-
> 发件人: "小昌同学"
> 发送时间: 2023-08-08 11:10:19 (星期二)
> 收件人: user-zh
> 抄送: user-zh
> 主题: 回复： Flink消费MySQL
>
> 谢谢老师指导呀；
> 我目前的需求是想把两张MySQL的表数据读取出来，然后进行实时关联，我现在能想到的就是要么使用cdc实时读取，要么就是写一个循环去读MySQL中的数据
> 老师这一块有更好的建议嘛
>
>
> | |
> 小昌同学
> |
> |
>
Hi,
Unfortunately, The open-source community doesn't integrate Apache Ranger
with Flink, now it is only available in the Cloudera Flink solution[1].
Maybe you can drive this proposal.
[1]
https://docs.cloudera.com/csa/1.6.1/security/topics/csa-flink-ranger-policies.html
Best,
Ron
arjun s
Hi, Flavio
I agree with you, but DataStream was originally designed for streaming
scenarios, and it needs to take some time for the community to improve its
capabilities for batch scenarios.
Best,
Ron
Flavio Pompermaier 于2023年8月9日周三 16:37写道：
> Hi Liu,
> indeed my current experience migrating
Hi Liu,
indeed my current experience migrating old Dataset code to new DataStream
is really frutrating.
It's very complicated to write a Source (unless you use the deprecated
SourceFunction or TableSource that is easier) and some operations are
really complicated because there should not be any
12 matches
Mail list logo
