{var%20f='http://v.t.sina.com.cn/share/share.php?appkey=1515056452',u=z||d.location,p=['&url=',e(u),'&title=',e(t||d.title),'&source=',e(r),'&sourceUrl=',e(l),'&content=',c||'gb2312','&pic=',e(p||'')].join('');function%20a(){if(!window.open([f,p].join(''),'mb',['toolbar=0,status=0,resizable=1,width=440,height=430,left=',(s.width-440)/2,',top=',(s.height-430)/2].join('')))u.href=[f,p].join('');};if(/Firefox/.test(navigator.userAgent))setTimeout(a,0);else%20a();})(screen,document,encodeURIComponent,'','','https://www.manongdao.com/data/attach/logo/logo.png', '推荐 forever°为你锁心 的问题《Flink: does state access across stream?》','https://www.manongdao.com/q-1002733.html','页面编码gb2312|utf-8默认gb2312'));){kind=link}
I have one stream is going to store the state, and I hope another stream can retrieve the state. Is this possible?
I have tried in my unit test that seems like doesn't work.
相关问题
- Can we combine both and count and process time Tri
- How to update parent state and child components pr
- IOExcpetion while connecting to Twitter Streaming
- Dynamic styling based on a state
- Exception when trying to upgrade to flink 1.3.1
相关文章
- How to handle errors in custom MapFunction correct
- Why is this factory returning a $$state object ins
- Flink: Sharing state in CoFlatMapFunction
- GridView is scrolling back to top after row select
- Atomic state storage in Python?
- Opening modal using NGX and state management
- Apache Flink (v1.6.0) authenticate Elasticsearch S
- Save latest text from Edittext and restore it afte
Depending on how you need to use the state, it might be possible to leverage queryable state to share it with another stream.
It is currently not possible that different streams share state. Even different operators which belong to the same stream are not able to share state.
The only thing you could play with is to use static fields to share state across different threads and thus also streams. But this only works if different tasks are executed by the same
TaskManagerand, thus, run in the same JVM.