石权infinite_个人页

个人头像照片 石权infinite
个人头像照片
0
8
0

个人介绍

暂无个人介绍

擅长的技术

获得更多能力
通用技术能力:

暂时未有相关通用技术能力~

云产品技术能力:

暂时未有相关云产品技术能力~

阿里云技能认证

详细说明
暂无更多信息
正在加载, 请稍后...
暂无更多信息
  • 回答了问题 2019-07-17

    flink如何计算设备离网

    问题很久远了,因为做过类似的设备监控的事情,简单说下我的做法:不靠flink本身来做,而是通过redis的timeout来做的。
    踩0 评论0
  • 提交了问题 2019-04-17

    Flink 源码 中OneInputstreamoperator和SingleOutputStreamOperator什么关系?

  • 回答了问题 2019-07-17

    Flink keyby问题

    keyby后,数据会根据key值发往下游的operator。建议你看下graph中哪个task产生了反压,是不是和IO相关。
    踩0 评论0
  • 回答了问题 2019-07-17

    经常遇到 major GC 花了半分钟才完成,但一两秒以后又启动了,如此往复。这种情况下 Flink 很不稳定,随时可能挂掉,checkpoint 也完不成了,Flink 还在默默地往身上扛数据

    这个问题能再拿出聊一下么?heap statebackend也不是完全驻留在内存,会扇出到磁盘的吧?阿里自己的statebackend大概怎么实现的?
    踩0 评论0
  • 回答了问题 2019-07-17

    请问各位大大,如果是独立的Flink集群,Standalone Cluster好还是On Yarn比较好? 个人觉得通过zk做主备job manager好像没什么大的缺陷.不知道有哪位运维过Flink集群的大大能出来指点一下

    个人理解是管理和监控上的事情,这两点对生产环境尤为重要。standalone缺少系统层面的管理、缺少资源隔离、缺少进程级异常恢复。另外如果想做高可用,还要依赖hdfs,所以不如yarn和hdfs一起上。
    踩0 评论0
  • 回答了问题 2019-07-17

    这种报错有人知道怎么回事么

    关键栈信息是不能发送到kafka。。。。
    踩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
    踩0 评论0
  • 回答了问题 2019-07-17

    请问大家遇到过这个错误吗:Checkpoint expired before completing

    老哥,给点上下文,cp写哪啊,需要写这么长时间。
    踩0 评论0
正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息