AI 助理
备案控制台

flink小助手_个人页

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

个人介绍

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

擅长的技术

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

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

云产品技术能力：

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

阿里云技能认证

详细说明
  • 提交了问题 2018-12-10

    Beam jar无法在远程flink群集上运行

  • 提交了问题 2018-12-10

    在YARN群集中提交作业之前，Flink TaskManagers不会启动

  • 提交了问题 2018-12-10

    Flink DataStream - 如何从输入元素启动源？

  • 提交了问题 2018-12-10

    窗口操作员行为澄清后的Apache Flink KeyedStream

  • 提交了问题 2018-12-10

    如何在Flink减少计算期间获取当前窗口之前的最后一个值

  • 提交了问题 2018-12-10

    我试图在Flink程序中将excel加载到POI工作簿中。有这样的错误。

  • 提交了问题 2018-12-10

    处理时间窗口不适用于Apache Flink中的有限数据源

  • 提交了问题 2018-12-10

    Flink：SocketWindowCount示例的结果不是我的预期

  • 提交了问题 2018-12-10

    工作节点 - 与Apache Flink的文件系统关联

  • 提交了问题 2018-12-10

    适用于所有输入

  • 提交了问题 2018-12-10

    通过flink保存点读取重复的消息

  • 提交了问题 2018-12-10

    flink更新hbase时的数据一致性问题

  • 提交了问题 2018-12-10

    Flink：如何持久化并恢复ValueState

  • 提交了问题 2018-12-10

    如何在时间窗口内获取最新值

  • 提交了问题 2018-12-10

    Flink Connection拒绝：localhost / 127.0.0.1:8081

  • 提交了问题 2018-12-10

    Flink：找不到合适的方法

  • 提交了问题 2018-12-10

    Flink：如何使用thin jar而不是fat jar？

  • 提交了问题 2018-12-10

    使用Flink在键控窗口中获取计数

  • 提交了问题 2018-12-10

    流媒体到parquet文件不匹配flink 1.6.1

  • 提交了问题 2018-12-10

    Flink 1.5.4没有在Kubernetes中注册Google云端存储（GCS）文件系统，尽管它在docker容器中有效

  • 提交了问题 2018-12-06

    Apache Flink：不会触发流加入窗口

  • 提交了问题 2018-12-06

    如何使用Flink CEP创建批处理或幻灯片窗口？

  • 提交了问题 2018-12-06

    试图将Fuple写入Flink Kafka接收器

  • 提交了问题 2018-12-06

    Flink - 事件时间滑动窗口，由于时间间隔，窗口中缺少数据

  • 提交了问题 2018-12-06

    在AWS EMR中部署Flink自定义JAR文件时出错

  • 提交了问题 2018-12-06

    Apache Flink Kubernetes Job Arguments

  • 提交了问题 2018-12-06

    Flink：如何在csv中实现没有实际列数的TypeInformation

  • 提交了问题 2018-12-06

    Flink SQL：用于连接表的内存不足

  • 提交了问题 2018-12-06

    Apache Flink：Python流API中的Kafka连接器，“无法加载用户类”

  • 提交了问题 2018-12-06

    JpaRepository不在自定义RichSinkFunction中自动装配

  • 提交了问题 2018-12-06

    flink1.6流非窗口LEFT OUTER JOIN乱序

  • 提交了问题 2018-12-06

    我可以使用group by的自定义分区程序吗？

  • 提交了问题 2018-12-06

    Flink Table / SQL API：在会话窗口聚合后修改rowtime属性

  • 提交了问题 2018-12-06

    当BucketingSink存在时，为什么我们需要StreamingFileSink？

  • 提交了问题 2018-12-06

    Flink KeyedProcessFunction不会在进程时逻辑上调用

  • 提交了问题 2018-12-06

    Apache Flink - 每小时聚合数据的每日汇总

  • 提交了问题 2018-12-06

    Flink join和connect有什么区别？

  • 提交了问题 2018-12-06

    RichParallelSourceFunction中的水印

  • 提交了问题 2018-12-06

    Flink 1.6 bucketing sink HDFS文件卡在.in-progress中

  • 提交了问题 2018-11-28

    如何使用flink和spark，以及spark只是为了转换？

  • 提交了问题 2018-11-28

    Apache flink是否有与Spark HiveContext相同的api？

  • 提交了问题 2018-11-28

    flink on yarn错误“Yarn只有-1个虚拟核心可用”

  • 提交了问题 2018-11-28

    如何使用Apache Flink读取HDFS中的parquet文件？

  • 提交了问题 2018-11-28

    如何使用maven仅重建Apache Flink中的更改

  • 提交了问题 2018-11-28

    Apache Flink：如何使用SourceFunction以指定的时间间隔执行任务？

  • 提交了问题 2018-11-28

    如何获取一分钟处理窗口的最新记录

  • 提交了问题 2018-11-28

    flink表api异常

  • 提交了问题 2018-11-28

    如何在Scala的Flink中定义KeySelector？

  • 提交了问题 2018-11-28

    使用flink的kafka到opentsdb：java.lang.NoClassDefFoundError：无法初始化类org.apache.http.conn.ssl.SSLConnectionSocketFactory

  • 提交了问题 2018-11-28

    Flink CEP事件加入了后台数据流

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

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