AI 助理
备案控制台

flink小助手_个人页

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

个人介绍

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

擅长的技术

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

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

云产品技术能力：

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

阿里云技能认证

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

    如何通过livy Programmatic API提交批处理jar Spark作业

  • 提交了问题 2018-12-13

    什么是Mapreduce相当于Spark中的top（）函数？

  • 提交了问题 2018-12-11

    spark UDF结果可以做'show'，但不能做'filter''

  • 提交了问题 2018-12-11

    Spark Scala生成随机RDD（1和0）？

  • 提交了问题 2018-12-11

    如何使用scala解压缩和解压缩.gz.tar文件在文件夹中？

  • 提交了问题 2018-12-11

    Job-Manager无法恢复Zookeeper检查点

  • 提交了问题 2018-12-11

    Flink日志记录限制：如何将日志记录配置传递给flink作业

  • 提交了问题 2018-12-11

    Flink - 如何在多个任务槽中聚合和查询富接收器功能状态

  • 提交了问题 2018-12-11

    Apache Flink：ProcessWindowFunction实现

  • 提交了问题 2018-12-10

    修复“不正确使用releaseJob（）而没有匹配数量的createTmpFiles（）调用jobId”Flink

  • 提交了问题 2018-12-10

    Flink将任务分配给一个任务管理器，直到插槽已满

  • 提交了问题 2018-12-10

    Apche Flink - 活动时间

  • 提交了问题 2018-12-10

    优化Flink转换

  • 提交了问题 2018-12-10

    Flink中复杂的优化（多输入）集成测试

  • 提交了问题 2018-12-10

    取消失败的任务时，taskmanager会被终止

  • 提交了问题 2018-12-10

    将DataSet数据发送到elasticsearch

  • 提交了问题 2018-12-10

    数据工匠如何流式传输分类帐调度工作

  • 提交了问题 2018-12-10

    如何将自定义表源和自定义表接收器与SQL客户端集成？

  • 提交了问题 2018-12-10

    如何有效地计算来自一个源的多个flink流

  • 提交了问题 2018-12-10

    Flink是否支持键控水印？如果没有，是否有任何计划在未来版本中实施？我有什么选择？

  • 提交了问题 2018-12-10

    Flink和Beam SDK如何处理窗口 - 哪个更有效？

  • 提交了问题 2018-12-10

    maven没有下载依赖项，因为trustAnchors参数必须是非空的

  • 提交了问题 2018-12-10

    Flink批处理接收器

  • 提交了问题 2018-12-10

    流处理框架与数据库

  • 提交了问题 2018-12-10

    相当于Flink-SQL中的“from_unixtime（bigint unixtime）”

  • 提交了问题 2018-12-10

    在Amazon EMR上配置Flink Rest API

  • 提交了问题 2018-12-10

    使用单个JobManager进行恢复

  • 提交了问题 2018-12-10

    Apache flink 1.6 HA独立群集：群集入口点中的致命错误

  • 提交了问题 2018-12-10

    运行Apache Flink时出现java.lang.ClassNotFoundException：com.mongodb.hadoop.mapred.MongoInputFormat

  • 提交了问题 2018-12-10

    用于保持访问配置数据<10 GB的最佳分布式缓存，并从Flink流应用程序访问每条记录？

  • 提交了问题 2018-12-10

    flink在批量处理模式下会减少吗

  • 提交了问题 2018-12-10

    Flink HA JobManager集群无法选择leader

  • 提交了问题 2018-12-10

    在apache flink中运行生成的jar文件

  • 提交了问题 2018-12-10

    Apache Flink（v1.6.0）验证Elasticsearch Sink（v6.4）

  • 提交了问题 2018-12-10

    kafka作为消息调度程序进行flink - 分区

  • 提交了问题 2018-12-10

    Apache Flink：如何处理Kafka接收器中的异常？

  • 提交了问题 2018-12-10

    Flink在yarn上是否使用yarn会议？

  • 提交了问题 2018-12-10

    使用Table AggregateFunction和ResultTypeQueryable时的ValidationException

  • 提交了问题 2018-12-10

    beam管道部署到Flink失败了404

  • 提交了问题 2018-12-10

    管理器的数量是否与yarn上的nodeManager数量相关

  • 提交了问题 2018-12-10

    在Eclipse中创建Flink项目

  • 提交了问题 2018-12-10

    如何在Flink中为Google Cloud Storage创建RecoverableWriter

  • 提交了问题 2018-12-10

    Apache flink 1.52 Rowtime时间戳为空

  • 提交了问题 2018-12-10

    url http：// localhost：8081 / jars /：jarid / run的错误404

  • 提交了问题 2018-12-10

    自定义AllWindowFunction类数字

  • 提交了问题 2018-12-10

    在Apach Flink中为每个已处理的输入文件生成单个输出文件

  • 提交了问题 2018-12-10

    了解Flink - 任务不可序列化

  • 提交了问题 2018-12-10

    Apache Flink：map vs flatMap

  • 提交了问题 2018-12-10

    Flink：处理Flink工作中的异常的最佳方法是什么

  • 提交了问题 2018-12-10

    无法从JAR文件构建程序

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

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