flink小助手
flink小助手_个人页
flink小助手
文章
0
问答
376
视频
0
个人介绍
flink小助手会定期更新直播回顾等资料和文章干货，还整合了大家在钉群提出的有关flink的问题及回答。
擅长的技术
-
提交了问题
2018-11-28
Flink - 可序列化的类（不是POJO）
-
提交了问题
2018-11-28
无法使用Flink-nifi连接器从Nifi输出端口读取数据
-
提交了问题
2018-11-28
Azure Flink中的src文件系统上的资源已更改
-
提交了问题
2018-11-28
运行很多工作时，Flink的主要瓶颈是什么？
-
提交了问题
2018-11-28
Apache Flink：keyby和window运算符
-
提交了问题
2018-11-28
在Flink KeyedStream上暂停处理
-
提交了问题
2018-11-28
flink与scala api中的parseQuotedStrings相同
-
提交了问题
2018-11-28
错误没有指定Runner并且在类路径上找不到DirectRunner
-
提交了问题
2018-11-28
Flink Metrics名称冲突
-
提交了问题
2018-11-28
Apache Flink：窗口检查点
-
提交了问题
2018-11-28
Apache Flink：Wierd FlatMap行为
-
提交了问题
2018-11-28
如何为consumer设置Kafka抵消？
-
提交了问题
2018-11-28
在将Flink数据集写入hdfs时如何创建Job对象
-
提交了问题
2018-11-28
Apache Flink - 增量检查点 - CP的意外大小
-
提交了问题
2018-11-28
Apache Flink：运营商状态检查点
-
提交了问题
2018-11-28
使用Kafka作为Flink的输入源是性能瓶颈吗？
-
提交了问题
2018-11-28
在apache flink中拆分和加入流
-
提交了问题
2018-11-28
Kafka jaas在Flink集群上验证失败
-
提交了问题
2018-11-28
如何使用flink将增量数据写入配置单元
-
提交了问题
2018-11-28
带有并行性的有序时间戳
-
提交了问题
2018-11-28
无限允许Apache Flink Windows延迟
-
提交了问题
2018-11-28
" 清除DataStream中的Flink水印状态"
-
提交了问题
2018-11-28
Scala列表的唯一最大元素
-
提交了问题
2018-11-28
Apache Flink：如何处理三个流
-
提交了问题
2018-11-28
"Flink RocksDB性能问题 "
-
提交了问题
2018-11-28
在Apache Flink中将自定义类写入HDFS
-
提交了问题
2018-11-28
Apache Flink：当我修改存储对象时，MapState会自动更新吗？
-
提交了问题
2018-11-28
以超过1的并行度运行Flink
-
提交了问题
2018-11-28
使用Homebrew在Mac上安装Apache Flink 1.6.2
-
提交了问题
2018-11-28
在Scala中，如何从字符分隔的二进制文件中读取字节？
-
提交了问题
2018-11-28
Flink Web UI：如何从flink Web UI中删除“取消”按钮
-
提交了问题
2018-11-28
如何在Flink中获取Kafka时间戳记录？
-
提交了问题
2018-11-28
当我使用Flink SlidingEventTimeWindows时，“缓冲池被破坏”
-
提交了问题
2018-11-28
如何使用FlinkKafkaConsumer分别解析密钥<K，V>而不是<T>
-
提交了问题
2018-11-28
什么是Apache Flink的分离模式？
-
提交了问题
2018-11-28
Apache flink（稳定版本1.6.2）不起作用
-
提交了问题
2018-11-28
Apache Flink - 如何结合AssignerWithPeriodicWatermark和AssignerWithPunctuatedWatermark？
-
提交了问题
2018-11-28
在Apache Flink中手动更新状态的最佳方法是什么？
-
提交了问题
2018-11-23
如果要给给Row里加一个字符串数组String[]类型的元素怎么弄？
-
提交了问题
2018-11-23
java/scala 获取一个类继承父类的泛型所属类和类型后，怎么将这个类或者字符串转化成一个泛型
-
提交了问题
2018-11-23
想请教一个问题，，我禁用了flink的checkpoint，并指定了enable.auto.commit和auto.commit.interval.ms，并setStartFromSpecificOffsets，发现offset的自动提交不生效啊？
-
提交了问题
2018-11-23
各位高手，flink有没有像spark那样的启动命令，可以直接加载hdfs上的jar包
-
提交了问题
2018-11-23
大家好，有使用flink cep的用户吗，我们现在在用，如果有一些运行时异常，cep就会直接导致job停止，不知道有什么方法可以cep处理运行时异常
-
提交了问题
2018-11-23
各位大佬，flink state mapstate 保存数据100g 采用rocksdb增量更新 job 任务运行一段时间就死了。磁盘采用非ssd 。对于large state value 任务 有什么好的建议。
-
提交了问题
2018-11-23
请问下，CDH可以集成Flink吗？
-
提交了问题
2018-11-23
请问一条数据，计算后涉及多个结果，是继承RichMapFunction的类中，设置多个State么?
-
提交了问题
2018-11-23
请教大佬们一个问题，关于流式统计指标时，比如按分钟，按小时，甚至按天统计，怎么处理好边界问题
-
提交了问题
2018-11-23
大家flink的checkpoint的小文件合并是如何搞的？
-
提交了问题
2018-11-23
KeygroupRange是根据并行度以及subtask index来划分的 那么flink怎么保证对应的event key流到对应的operator呢？求大神解答
-
提交了问题
2018-11-23
我发现flink会先取到之前计算的状态,然后计算新的状态, 但是之前的结果状态同样会进sink函数插一次库, 怎样才能避免中间状态的入库啊
暂无更多信息
暂无更多信息
-
提交了问题
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模式运行吗？
滑动查看更多
暂无更多信息