石权infinite
石权infinite_个人页
石权infinite
文章
0
问答
8
视频
0
个人介绍
暂无个人介绍
擅长的技术
暂无更多信息
暂无更多信息
-
回答了问题
2019-07-17
flink如何计算设备离网
问题很久远了，因为做过类似的设备监控的事情，简单说下我的做法：不靠flink本身来做，而是通过redis的timeout来做的。赞0 踩0 评论0 -
提交了问题
2019-04-17
Flink 源码 中OneInputstreamoperator和SingleOutputStreamOperator什么关系？
-
回答了问题
2019-07-17
Flink keyby问题
keyby后，数据会根据key值发往下游的operator。建议你看下graph中哪个task产生了反压，是不是和IO相关。赞0 踩0 评论0 -
回答了问题
2019-07-17
经常遇到 major GC 花了半分钟才完成，但一两秒以后又启动了，如此往复。这种情况下 Flink 很不稳定，随时可能挂掉，checkpoint 也完不成了，Flink 还在默默地往身上扛数据
这个问题能再拿出聊一下么？heap statebackend也不是完全驻留在内存，会扇出到磁盘的吧？阿里自己的statebackend大概怎么实现的？赞0 踩0 评论0 -
回答了问题
2019-07-17
请问各位大大，如果是独立的Flink集群，Standalone Cluster好还是On Yarn比较好? 个人觉得通过zk做主备job manager好像没什么大的缺陷.不知道有哪位运维过Flink集群的大大能出来指点一下
个人理解是管理和监控上的事情，这两点对生产环境尤为重要。standalone缺少系统层面的管理、缺少资源隔离、缺少进程级异常恢复。另外如果想做高可用，还要依赖hdfs，所以不如yarn和hdfs一起上。赞0 踩0 评论0 -
回答了问题
2019-07-17
这种报错有人知道怎么回事么
关键栈信息是不能发送到kafka。。。。赞0 踩0 评论0 -
回答了问题
2019-07-17
请问下各位大佬，在flink官网上讲解join的一章里，有这样一张图，在这张图中不太理解的是，为什么0,1 和1,0 也会作为join的结果输出呢？
join实现方式是nested-loop join ， 得出的是笛卡儿积。具体到0,1 和1,0。对应的就是第一个窗口内的，。官方文档可以参考这个： https://flink.apache.org/news/2015/03/13/peeking-into-Apache-Flinks-Engine-Room.html赞1 踩0 评论0 -
回答了问题
2019-07-17
请问大家遇到过这个错误吗：Checkpoint expired before completing
老哥，给点上下文，cp写哪啊，需要写这么长时间。赞0 踩0 评论0
滑动查看更多
暂无更多信息