赵慧@ApacheFlink中文社区
赵慧@ApacheFlink中文社区_个人页
赵慧@ApacheFlink中文社区
文章
16
问答
350
视频
0
个人介绍
暂无个人介绍
擅长的技术
-
提交了问题
2019-02-14
请问在where条件更改了以后，之前打的savepoint还能用吗？
-
提交了问题
2019-02-14
请问一下，设置了 BoundedOutOfOrdernessTimestampExtractor 的延迟时间，还有必要做 allowedLateness 操作吗？
-
提交了问题
2019-02-14
请问你们怎么测试flink的最大吞吐量
-
提交了问题
2019-02-14
2018的meetup北京站 视频有吗？有的话 分享一下，今天学习一下，谢谢哈
-
提交了问题
2019-02-14
生产环境 flink的高可用集群部署 有类似cdh这样的工具嘛
-
提交了问题
2019-02-14
blink文档有吗？
-
提交了问题
2019-02-14
咨询一下，大家使用的flink时对应 使用kafka的哪个版本？
-
提交了问题
2019-02-14
Apache Flink状态管理和容错机制介绍，对应视频和ppt有吗
-
提交了问题
2019-02-14
flink 人大行培训视频地址是？
-
提交了问题
2019-02-14
java能不能直接远程操作flink sql
-
提交了问题
2019-02-14
blink 的gitbub 地址是什么？
-
提交了问题
2019-02-14
当前开源的blink维表还不支持维表数据的定期刷新吧
-
提交了问题
2019-02-14
请教一下blink的这个读hive meta的catalog是只适用于读取batch数据的场景吧
-
提交了问题
2019-02-14
请教，关于watermark和window的关系这个前辈说的对吗？？
-
提交了问题
2019-02-14
Flink on yarn 模式下，yarn给 flink 指定的 web 页面的 ip 和 端口是随机指定的，可以固定下来吗。
-
提交了问题
2019-02-14
大家提交flink任务到yarn的时候 是在哪个节点提交的？ namenode还是 datanode？
-
提交了问题
2019-02-14
flink可以监听kafka, mq等。可以监听文件，或者zookeeper嘛？如果有新的消息，flink要可以读取到。
-
提交了问题
2019-02-14
flink写hive表有什么好的建议?
-
提交了问题
2019-01-22
flinkstream的checkpoint是要同步到hdfs中的，如果没有hdfs是不是会导致无法checkpoint？
-
提交了问题
2019-01-22
flink的时间窗口怎么写？
-
提交了问题
2019-01-22
请问一下 Flink做批处理一般用什么调度工具比较好
-
提交了问题
2019-01-22
请问，flink写hdfs目前支持exactly once么？
-
提交了问题
2019-01-22
请问下 为什么 1.6.1版本为什么不能这样order by呢 ？
-
提交了问题
2019-01-22
有大佬知道 blink 共享模式 只能强制写sql 吗
-
提交了问题
2019-01-22
各位大神，问一个入门问题： 我在flatMap算子里放了一个状态，我需要在sink中拿出来看这个状态，但是发现是null，请问这个是什么原因？ 用的是同一个ValueStateDescriptor
-
提交了问题
2019-01-22
flink standalone yarn的区别是什么
-
提交了问题
2019-01-22
大神们，问一下怎么在yarn上提交程序到flink集群上，yarn客户端和flnk的masters不在同一台机器上，yarn提交的时候怎么知道是提交到指定的flink集群上，需要在哪配置一下吗？
-
提交了问题
2019-01-22
大神们，有没有flink on yarn比较完整的环境搭建参考啊，我搭个测试集群Standalone都可以起来，但on yarn就不行
-
提交了问题
2019-01-22
flink中如何实现，只统计一天的pv,到凌晨00:00的时候置为0，再进行统计
-
提交了问题
2019-01-22
编译flink遇到类似的异常？求教
-
提交了问题
2019-01-22
问一下大佬，如果远程提交程序到flink集群运行的话的话，怎么提交，本地是否得安装flink的客户端，客户端需要怎么配置～代码中获取环境环境的时候需要把flink集群的ip及端口加上吗？
-
提交了问题
2019-01-22
请教下 checkpoint相关的问题， 我目前部署中准备使用rocksDb作为state backend。 那rocksDb的state可以启用incremental来做checkpoint，达到提高checkpint performance的作用。 每次都是保存与前一个diff的进行store。 我的问题是，那我们在从某个checkpoint启动某个job的时候，这个checkpoint应该只含有diff的内容， 那没有变化的state就获取不到。
-
提交了问题
2019-01-22
我现在在部署flink上生产。 yarn跟standalone的主要优劣势能分享下吗
-
提交了问题
2019-01-22
请教大家一个问题，请教大家一个问题，我们在应用里面使用了KafkaConnector 然后现在要对kafka里面的每个topic的一些特征数据做一些简单的监控，现在的思路是基于Flink 的system metrics 但是我大概看了一下官方的文档，和Flink 里面FlinkKafkaConsumerBase的open方法和run方法的实现，暂时没有找到获取kafka topic相关的信息的API，大家有这方面的经验吗？
-
提交了问题
2019-01-22
有没有相关的benchmark的数据分享一下
-
提交了问题
2019-01-22
blink使用streaming的runtime实现batch，效率会降低吗？
-
提交了问题
2019-01-22
请问一下 现在有一个场景 在mysql中对数据进行处理发现时间太长 就拿着mysql中的原始数据到FLink来完成加工逻辑 但是发现时间更长了 Flink job时间: 直接查询时间: 是我使用FLink的方式不对 还是Flink不适合这种场景
-
发表了文章 2019-01-05
Apache Flink，流计算？不仅仅是流计算！
作者：王峰（花名：莫问） 2018年12月下旬，由阿里巴巴集团主办的Flink Forward China在北京国家会议中心举行。Flink Forward是由Apache软件基金会授权的全球范围内的Flink技术大会，2015年开始在德国柏林举办，今年第一次进入中国。 今天，计算平台事业部的资深技术专家莫问，将带领我们重温这场大数据技术的饕餮盛宴，感受Apache Flink 作为下一代大数
-
提交了问题
2018-12-10
本地编译flink1.6 1.7都不过，有个 flink-MapR 有问题
-
提交了问题
2018-12-06
我想问下，keyby的时候不同key可以配权重吗？分到task上的流量不均衡怎么解决呀？
-
提交了问题
2018-11-30
Flink SQL相关问题
-
发表了文章 2018-11-30
Apache Flink 干货合集打包好了，速来下载
作者：王绍翾（花名：大沙） 最近的一份市场调查报告显示，Apache Flink 是2018年开源大数据生态中发展“最快”的引擎，和2017年相比增长了125% 。为了让大家更为全面地了解Flink，我们制作了一本电子干货合集：《不仅仅是流计算：Apache Flink实践》，融合了Apache Flink在国内各大顶级互联网公司的大规模
-
提交了问题
2018-11-30
flink用什么工具开发？
-
提交了问题
2018-11-30
请教大佬们，Flink UI界面，对于Completed Job怎么看日志？
-
提交了问题
2018-11-29
请问怎么做去重？
-
提交了问题
2018-11-16
随着我数据量变大 checkpoint时间在变长 这个问题可以这么解决啊
-
提交了问题
2018-11-16
请问flink no window join 是怎么样的呀 有相关文档吗
-
提交了问题
2018-11-16
用flink run -s命令指定checkpoint点手动恢复测试发现报错
-
发表了文章 2018-11-06
取之开源，用之开源-深度剖析阿里巴巴对Flink的优化与改进
作者 | 阿里巴巴实时计算团队 导读：随着人工智能时代的降临，数据量的爆发，阿里巴巴的商品数据处理就经常需要面对增量和全量两套不同的业务流程问题，所以阿里巴巴就在想：能不能有一套统一的大数据引擎技术，用户只需要根据自己的业务逻辑开发一套代码。这样在各种不同的场景下，不管是全量数据还是增量数据，亦或者实时处理，一套方案即可全部支持，这就是阿里巴巴选择 Flink 的背景和初衷。彼时的 Fl
-
提交了问题
2018-10-30
请叫一个flink和kafka集成问题，如果用这个API（FlinkKafkaConsumer010(List<String> topics, DeserializationSchema<T> deserializer, Properties props)）同时读多个topic，用什么Schema，能在收到的消息中得到这个消息时来自哪个topic？
暂无更多信息
-
发表了文章
2019-01-05
Apache Flink，流计算？不仅仅是流计算！
-
发表了文章
2018-11-30
Apache Flink 干货合集打包好了，速来下载
-
发表了文章
2018-11-06
取之开源，用之开源-深度剖析阿里巴巴对Flink的优化与改进
-
发表了文章
2018-10-16
阿里巴巴为什么选择Apache Flink？
-
发表了文章
2018-10-15
Flink在唯品会的实践
-
发表了文章
2018-10-15
Flink在美团的实践与应用
-
发表了文章
2018-10-15
Flink 靠什么征服饿了么工程师？（Flink在饿了么实时计算平台的应用）
-
发表了文章
2018-10-15
携程基于Flink的实时特征平台
-
发表了文章
2018-10-15
下：比拼生态和未来，Spark和Flink哪家强？
-
发表了文章
2018-10-15
Flink状态管理和容错机制介绍
-
发表了文章
2018-10-15
Jstorm到Flink 在今日头条的迁移实践
-
发表了文章
2018-10-15
Flink在美团的实践与应用
-
发表了文章
2018-10-15
上：Spark VS Flink – 下一代大数据计算引擎之争，谁主沉浮？
-
发表了文章
2018-10-15
携程基于Flink的实时特征平台
-
发表了文章
2018-10-15
Flink在唯品会的实践
-
发表了文章
2018-10-15
Flink 的新方向在哪里？这场顶级盛会给出了答案
滑动查看更多
-
提交了问题
2019-02-21
有没有flink实时计算的demo，集群方式的
-
提交了问题
2019-02-21
各位大牛下午好，请问在编译Blink时，发生如下异常： 我的maven版本：3.2.5，请问该如何解决 Failed to execute goal net.alchim31.maven:scala-maven-plugin:3.2.2:compile (scala-compile-first) on project flink-table_2.11: wrap: org.apache.commons.exec.ExecuteException: Process exited with an error
-
提交了问题
2019-02-21
大神们，你们一般hadoop设置几个副本啊？
-
提交了问题
2019-02-21
编译完Blink源码，启动集群时报这个警告。哪位大佬知道在哪里设置？
-
提交了问题
2019-02-21
Flink on Yarn 有两种模式 分离模式 和 客户端模式 ，我现在在做调研，没有大规模的使用，我想知道的是，这两种模式具体适用的场景是什么，对于我现在来说，两种模式我感觉区别不是很大，有人说 客户端模式的隔离性更好，但是我想知道这个这个在实际应用起来，所谓的隔离性影响大吗？或者说这两者有什么其他的较大的区别，有朋友了解吗？
-
提交了问题
2019-02-21
flink + rocketmq从指定Offsets启动有人做过吗
-
提交了问题
2019-02-21
Job倒了如何自动重新启动呢？
-
提交了问题
2019-02-21
请教大牛，我自己写了一个SinkFunction，继承了RichSinkFunction，初始化这个SinkFunction时，我传进去了一个数据库连接池对象，在SinkFunction的invoke里，调用数据库连接池对象来写数据库。我的问题是，当SinkFunction被partition到多个机器的vm执行时，这个数据库连接池对象是在程序入口的JobClient（程序提交所在的机器VM），还是这个对象也被复制了好多份，有多少个SinkFunction在运行就有多少个数据库连接池对象？
-
提交了问题
2019-02-21
flink可以通过代码自动重启job程序嘛？
-
提交了问题
2019-02-21
设置了flink source的 parallelism 为4，会直接造成flink启动4个taskmanager吗？
-
提交了问题
2019-02-21
blink有开发文档么
-
提交了问题
2019-02-21
State Backend中backend是什么意思，是存储的意思吗
-
提交了问题
2019-02-21
请问flink on yarn模式, 怎么使用REST API接口对作业进行监控? 我想集成到自己的后台里 而不是在原本的web UI上查看
-
提交了问题
2019-02-21
flink on yarn任务失败了之后，错误日志从哪看有人知道吗？
-
提交了问题
2019-02-21
blink中是否已经实现了HBase表的维表JOIN功能？有的话，具体体现在哪个包里？
-
提交了问题
2019-02-21
请问Flink on Yarn的模式是否需要部署Flink 集群？个人理解下来，Flink on Yarn会从启动session的节点上传jar和配置文件，但是每次想到spark on yarn部署了集群心里总是不安。还请在生产中使用Flink的前辈确认一下，谢谢！
-
提交了问题
2019-02-21
谁有flink的学习资料
-
提交了问题
2019-02-21
现在blink能用在生产环境吗
-
提交了问题
2019-02-21
flink每分钟滚动和滑动窗口能不能join在一起啊？
-
提交了问题
2019-02-21
blink是不是支持hadoop3？
滑动查看更多
暂无更多信息