AI 助理
备案控制台

flink小助手_个人页

个人头像照片 flink小助手
文章
0
问答
377
视频
0

个人介绍

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

擅长的技术

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

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

云产品技术能力：

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

阿里云技能认证

详细说明
  • 提交了问题 2018-11-23

    我发现flink会先取到之前计算的状态,然后计算新的状态, 但是之前的结果状态同样会进sink函数插一次库, 怎样才能避免中间状态的入库啊

  • 提交了问题 2018-11-22

    有一个需求, 希望实时读取HBase的insert和update数据做处理, flink能实现吗

  • 提交了问题 2018-11-22

    flink operator 的概念是steam graph的一个node还是，job graph的一个Vertex呢

  • 提交了问题 2018-11-22

    Flink提交任务到yarn-cluster模式时，flink list执行超时，获取不到JobManager信息。定位到问题原因与HA有关，有没有哪位大神遇到过类似问题

  • 提交了问题 2018-11-22

    提个跟Flink有关有个问题

  • 提交了问题 2018-11-22

    Flink的State使用时。如果应用在更新时，修改了POJO类，或者算子之间传递的POJO发生变更，需要怎样去迁移呢？只能通过自定义其他的序列化方式么？

  • 提交了问题 2018-11-22

    一般是用flink处理完后数据写入hbase或者es等存储，然后前台实时展示吗？

  • 提交了问题 2018-11-22

    k8s与docker 是啥关系吗？

  • 提交了问题 2018-11-22

    大佬们 过了一下join源码 请教一个问题?

  • 提交了问题 2018-11-22

    有人用vscode写java吗？

  • 提交了问题 2018-11-22

    flink用于风控场景下如何在线对接各种外部数据源而不用重新部署流处理？

  • 提交了问题 2018-11-22

    问下map里面过滤，和在foreach里面实现过滤和处理的话，哪个性能好？

  • 提交了问题 2018-11-22

    用Flink的yarn模式 在flink-conf.yaml配置文件设置slot数量为10 启动./yarn-session.sh -n 2 -s 10 报错 只有8个solt可用 机器配置两个CPU每个都是10个slot 在yarn中配置yarn.containers.vcores=10没用

  • 提交了问题 2018-11-22

    有哪些模型需要用Flink?

  • 提交了问题 2018-11-22

    求问一下大佬，partitionCustom后，如何为在partition上单独执行Window，keyby id的话太碎了，windowAll并发又上不去……

  • 提交了问题 2018-11-22

    请教一下 flink stream API 代码里面怎么获取window 的起始时间 和结束时间？

暂无更多信息
正在加载, 请稍后...
暂无更多信息
  • 提交了问题 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就报错么

  • 提交了问题 2019-01-10

    请问一下 storm topology转换为flink任务之后，可以支持on yarn模式运行吗？

正在加载, 请稍后...
滑动查看更多
正在加载, 请稍后...
暂无更多信息