flink小助手
flink小助手_个人页
flink小助手
文章
0
问答
377
视频
0
个人介绍
flink小助手会定期更新直播回顾等资料和文章干货，还整合了大家在钉群提出的有关flink的问题及回答。
擅长的技术
暂无更多信息
暂无更多信息
-
回答了问题
2019-07-17
假如一个类比如: FlinkKafkaConsumerBase 继承了 RichParallelSourceFunction 和CheckpointedFunction，并且重写了RichParallelSourceFunction 的open方法和CheckpointedFunction initializeState方法，那么是先执行open呢还是initializeState呢？这个怎么判断的呀/
先调用 initializeState
社区不建议使用这个类了，已经 deprecated 了，如果你用 ListCheckpointed 的话，注释里写的比较清楚赞0 踩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就报错么
滑动查看更多
暂无更多信息
