- 主题:请教一个flink的问题
主线程和sink在不同线程，你可以试试在main函数设置一个其他类的静态变量，在sink里是取不到的
【 在 guestking 的大作中提到: 】
: 想了想，应该是同步的
: 要做成异步的，估计还得借助外部队列之类的东西来搞
:
--
FROM 124.202.207.*
用滑动窗口啊。
【 在 guestking 的大作中提到: 】
: 那在这个window结束之前，结果就不可见了？
: 如果我一个window是一天的话，那岂不是要一天结束了才能知道统计结果
:
--
FROM 58.37.62.*
我不是说和主线程是不是同步
我是说在每个slot里面应该是同步的
比如我并行设置为8，这8个线程被sink阻塞的话，那么就没法再处理后面的数据了，要
等sink完成才行
【 在 emirbobo (骑白马的) 的大作中提到: 】
: 主线程和sink在不同线程，你可以试试在main函数设置一个其他类的静态变量，在sink里是取不到的
--
FROM 101.86.19.*
滑动窗口，你也是要等窗口结束了才能得到数据
【 在 ilovecpp (cpp) 的大作中提到: 】
: 用滑动窗口啊。
--
FROM 101.86.19.*
你要的是纯粹的流式处理，当然不用Window
--
FROM 223.104.3.*