水木社区手机版
首页
|版面-Java技术(Java)|
新版wap站已上线
展开
|
楼主
|
同主题展开
|
溯源
|
返回
上一篇
|
下一篇
|
同主题上篇
|
同主题下篇
主题:Re: 请教一个flink的问题
guestking
|
2021-01-17 10:26:29
|
我不是说和主线程是不是同步
我是说在每个slot里面应该是同步的
比如我并行设置为8,这8个线程被sink阻塞的话,那么就没法再处理后面的数据了,要
等sink完成才行
【 在 emirbobo (骑白马的) 的大作中提到: 】
: 主线程和sink在不同线程,你可以试试在main函数设置一个其他类的静态变量,在sink里是取不到的
--
FROM 101.86.19.*
上一篇
|
下一篇
|
同主题上篇
|
同主题下篇
选择讨论区
首页
|
分区
|
热推
BYR-Team
©
2010.
KBS Dev-Team
©
2011
登录完整版