AI 助理
备案控制台

flink小助手_个人页

flink小助手
文章
0
问答
375
视频
0

个人介绍

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-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模式运行吗？

  • 提交了问题 2019-01-10

    有没有人用过1.7 state schema evolution 吗？ 不太明白怎么用

  • 提交了问题 2019-01-10

    想请教个问题，我watermark后，发现时间少了8个小时，时区问题，大家是怎么解决的啊？

  • 提交了问题 2019-01-10

    请教个问题，有没有测试FLink性能的基准测试工具呢？ 我的flink版本是1.6.2

  • 提交了问题 2019-01-07

    flink有没有这方面优化我用habse存储了每小时的统计结果，然后想统计一天的

  • 提交了问题 2019-01-07

    flink有没有更好的方式从hbase拿数据？

  • 提交了问题 2019-01-03

    Flink用于Spring boot项目下会有什么问题嘛

  • 提交了问题 2019-01-03

    想问下 Flink 1.6.2 with Hadoop® 2.8 这个版本里的 Hadoop 用户名是绑定了的么？

  • 提交了问题 2019-01-03

    本地运行多个flink任务时，分析占的cpu、内存、时延情况，一般用什么方法或工具呀

  • 提交了问题 2019-01-03

    flink用于实时指标统计，现在业务要新加指标，怎样把之前该指标对应的状态捞回来？

  • 提交了问题 2019-01-03

    Flink SQL中的DATE_FORMAT（）函数中，如何将bigint转换为timestamp类型？

  • 提交了问题 2019-01-03

    Flink 1.6.2经常会出现slot container被移除导致程序崩掉的问题

  • 提交了问题 2018-12-14

    Apache Flink：自定义触发器意外行为

  • 提交了问题 2018-12-14

    Flink键控状态清理增量rocksdb检查点

  • 提交了问题 2018-12-13

    Apache Flink - 启用连接排序

  • 提交了问题 2018-12-13

    当yarn崩溃时恢复Flink

  • 提交了问题 2018-12-13

    我可以使用KSQL生成处理时间超时吗？

  • 提交了问题 2018-12-13

    Flink：如何通过flink代码设置任务管理器属性

  • 提交了问题 2018-12-13

    有什么方法增加任务管理器的数量而不是每个任务管理器的任务槽？

  • 提交了问题 2018-12-13

    Apache Flink：有没有办法在可查询状态返回到客户端之前进行转换？

  • 提交了问题 2018-12-13

    Apache Flink：使用filter（）或split（）来分割流？

  • 提交了问题 2018-12-13

    在Apache Flink中手动更新状态的最佳方法是什么？

  • 提交了问题 2018-12-13

    OrcTableSource是否支持S3文件系统？

  • 提交了问题 2018-12-13

    使用Flink为DateStreamSource <List <T >>分配水印的正确方法

  • 提交了问题 2018-12-13

    将Apache Flink中的关系数据存储为状态并通过属性查询

  • 提交了问题 2018-12-13

    启动新的Flink作业时“无法分配内存”

  • 提交了问题 2018-12-13

    Flink和恢复中的事件处理顺序

  • 提交了问题 2018-12-13

    Flink：Jobmanager UI中设置的并行性如何与任务槽相关？

  • 提交了问题 2018-12-13

    对于HIVE查询，OR是否比IN具有更好的性能

  • 提交了问题 2018-12-13

    如何使用其他值之间的值连接数据集？

  • 提交了问题 2018-12-13

    Spark UDF找不到参数num的隐含值：Numeric [Nothing]

暂无更多信息
正在加载, 请稍后...
暂无更多信息
  • 提交了问题 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模式运行吗？

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