flink小助手个人页面-阿里云开发者社区

个人头像照片 flink小助手 TA的个人档案

个人介绍

flink小助手会定期更新直播回顾等资料和文章干货,还整合了大家在钉群提出的有关flink的问题及回答。

擅长的技术

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

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

云产品技术能力:

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

阿里云技能认证

详细说明
  • 高分内容
  • 最新动态
  • 文章
  • 问答
  • 提交了问题 2019-01-10

    假如一个类比如: FlinkKafkaConsumerBase 继承了 RichParallelSourceFunction 和CheckpointedFunction,并且重写了RichParallelSourceFunction 的open方法和CheckpointedFunction initializeState方法,那么是先执行open呢还是initializeState呢?这个怎么判断的呀/

  • 提交了问题 2019-01-10

    flink on yarn 如果某个taskmanager出现故障,程序失败后,恢复流程是怎样的

  • 提交了问题 2019-01-10

    如果是从最新的checkpoint恢复,那这个是自动去重置到最新的一次状态继续计算吗,那恢复checkpoint产生的延迟高吗

  • 提交了问题 2019-01-10

    异常流程是怎么处理的,恢复机制有没有讲解啊

  • 提交了问题 2019-01-10

    请问如何看详细network 官网上说配置network.detail 但是不知道怎么配

正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息
正在加载, 请稍后...
暂无更多信息
  • 回答了问题 2019-07-17

    假如一个类比如: FlinkKafkaConsumerBase 继承了 RichParallelSourceFunction 和CheckpointedFunction,并且重写了RichParallelSourceFunction 的open方法和CheckpointedFunction initializeState方法,那么是先执行open呢还是initializeState呢?这个怎么判断的呀/

    先调用 initializeState
    社区不建议使用这个类了,已经 deprecated 了,如果你用 ListCheckpointed 的话,注释里写的比较清楚

    踩0 评论0
  • 提交了问题 2019-01-10

    假如一个类比如: FlinkKafkaConsumerBase 继承了 RichParallelSourceFunction 和CheckpointedFunction,并且重写了RichParallelSourceFunction 的open方法和CheckpointedFunction initializeState方法,那么是先执行open呢还是initializeState呢?这个怎么判断的呀/

  • 提交了问题 2019-01-10

    flink on yarn 如果某个taskmanager出现故障,程序失败后,恢复流程是怎样的

  • 提交了问题 2019-01-10

    如果是从最新的checkpoint恢复,那这个是自动去重置到最新的一次状态继续计算吗,那恢复checkpoint产生的延迟高吗

  • 提交了问题 2019-01-10

    异常流程是怎么处理的,恢复机制有没有讲解啊

  • 提交了问题 2019-01-10

    请问如何看详细network 官网上说配置network.detail 但是不知道怎么配

  • 提交了问题 2019-01-10

    taskmanager.net.detailed-metrics 有人知道怎么配置吗?

  • 提交了问题 2019-01-10

    请问下,Flink怎么样加载resources下的配置文件

  • 提交了问题 2019-01-10

    有人tune过taskmanager.net参数 提高throughput吗?求指点 谢谢!

  • 提交了问题 2019-01-10

    DataSet的partitionByHash 和DataStream的Keyby是类似的含义么?

  • 提交了问题 2019-01-10

    partitionByRank 和ByHash 在使用上有区别么,or 只是内部实现上的区别?

  • 提交了问题 2019-01-10

    flink 从kafka消费,savepoint后,重启拓扑,kafka topic对应的offset值不是存到zookeeper了?

  • 提交了问题 2019-01-10

    双流做join的时候。想实现主表滑动窗口,从表滚动窗口,思路是怎么样的呀? select ... from a join b on... where b.rowtime BETWEEN a.rowtime AND a.rowtime + INTERVAL '1' HOUR 可否? 如果可行的话,这个滑动窗口是多少?

  • 提交了问题 2019-01-10

    我本地ide接入kafka数据源,source的并行度一直是4(和我电脑核数一样)怎么控制

  • 提交了问题 2019-01-10

    各位大神,麻烦问下,用了RichFlatMapFunction,在里面的open 和close分别用作打开关闭第三方的kv存储链接,现在跑的时候报错说 Buffer pool is destroyed,这个问题 有人有遇到麼,怎么解

  • 提交了问题 2019-01-10

    这张图谁能给解释吗

  • 提交了问题 2019-01-10

    这个问题有大神遇到过么[疑问]

  • 提交了问题 2019-01-10

    怎么确定flink该设置多少并行度?怎么优化,有人了解吗

  • 提交了问题 2019-01-10

    提交作业时配置运行参数,taskmanager个数越多越好,还是slot个数多好

  • 提交了问题 2019-01-10

    请问为什么加上limit就报错么

正在加载, 请稍后...
滑动查看更多