赵慧 + 关注

赵慧 参与了问答:

有没有flink实时计算的demo,集群方式的

转自钉钉群21789141:有没有flink实时计算的demo,集群方式的

“Jary:https://github.com/apache/flink/tree/master/flink-examples”

赵慧 参与了问答:

各位大牛下午好,请问在编译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

各位大牛下午好,请问在编译Blink时,发生如下异常: 我的maven版本:3.2.5,请问该如何解决Failed to execute goal net.alchim31.maven:scala-m...

“Jary:参看一下这个 mvn clean install -DskipTests -Drat.skip=true -Dcheckstyle.skip=true有时候网络问题 多试几次”

赵慧 参与了问答:

大神们,你们一般hadoop设置几个副本啊?

转自钉钉群21789141:大神们,你们一般hadoop设置几个副本啊?2个够不够

“眭少剑:3个。同机架一个,不同机架一个。这是我的做法,不知道大神们什么思路 高颜:本地,同一个交换机,同数据中心,不同数据中心 3-4, 一级一个副本,如果只考虑可用性”

赵慧 参与了问答:

编译完Blink源码,启动集群时报这个警告。哪位大佬知道在哪里设置?

转自钉钉群21789141:编译完Blink源码,启动集群时报这个警告。哪位大佬知道在哪里设置?

“伪分布式下会出现这个问题,完全分布式模式没有这个问题了。”

赵慧 参与了问答:

“韩非:Flink on yarn应用部署https://mp.weixin.qq.com/s?__biz=Mzg3NjAwNzM4MA==&mid=2247483718&idx=1&a...查看全部>

赵慧 参与了问答:

flink + rocketmq从指定Offsets启动有人做过吗

转自钉钉群21789141:flink + rocketmq从指定Offsets启动有人做过吗

“火锅:Offsets 从外部参数传入? 还是你checkpoint 里面有 问:外部 火锅:你在 initializeState 里面去实现下呢,启动的时候,这里初始化你的offset ,根据你的值...查看全部>

赵慧 参与了问答:

Job倒了如何自动重新启动呢?

转自钉钉群21789141:Job倒了如何自动重新启动呢?blink没倒就是job抛出异常停了

“张迪(雷诺):StreamExecutionEnvironment”

赵慧 参与了问答:

“鲁尼:取决于你的连接池对象是在哪里初始化的,如果是构造函数里就初始化好了,那在客户端就做了,连接池对象会被尝试序列化并分发到多个分布式worker。如果是在类似open的时候才初始化,那就一个task...查看全部>

赵慧 参与了问答:

flink可以通过代码自动重启job程序嘛?

转自钉钉群21789141:flink可以通过代码自动重启job程序嘛?flink程序挂了 ,怎么让它自动拉起?

“于博:如果任务失败了,就没法子自动启动了,可以配置自动拉起服务”

赵慧 参与了问答:

设置了flink source的 parallelism 为4,会直接造成flink启动4个taskmanager吗?

转自钉钉群21789141:设置了flink source的 parallelism 为4,会直接造成flink启动4个taskmanager吗?

“Tom:不会。并行度和taskmanager没有关系”

赵慧 参与了问答:

blink有开发文档么

转自钉钉群21789141:blink有开发文档么

“蒋涛涛: https://flink-china.org/doc/blink/蒋晓峰:https://github.com/apache/flink/tree/blink/docs”

赵慧 参与了问答:

State Backend中backend是什么意思,是存储的意思吗

转自钉钉群21789141:State Backend中backend是什么意思,是存储的意思吗

“扎啤:就是存储的意思,之前介绍不就有使用RocksDB存储state嘛”

赵慧 参与了问答:

请教一个问题 ,我的flink应用里面有4个任务 ,并行写es,导致version conflict,请问有什么通用解决方案么?

转自钉钉群21789141:请教一个问题 ,我的flink应用里面有4个任务 ,并行写es,导致version conflict,请问有什么通用解决方案么?会引起es集群cpu利用率不稳定

“钟葳:这4个任务是不是会对同一个key进行写操作? 如果是的话可以考虑下把任务合并, 在合并后的任务内部解决冲突的问题, 比如对同一个key的操作shuffle到同一个sink的并发上去处理? 问:...查看全部>

赵慧 参与了问答:

请问flink on yarn模式, 怎么使用REST API接口对作业进行监控? 我想集成到自己的后台里 而不是在原本的web UI上查看

转自钉钉群21789141:请问flink on yarn模式, 怎么使用REST API接口对作业进行监控? 我想集成到自己的后台里 而不是在原本的web UI上查看

“蒋涛涛:一般建议用metrics进行监控罗皓坚:参考一下这里https://ci.apache.org/projects/flink/flink-docs-release-1.7/monitoring...查看全部>

赵慧 参与了问答:

flink on yarn任务失败了之后,错误日志从哪看有人知道吗?

转自钉钉群21789141:flink on yarn 任务失败了之后,错误日志从哪看有人知道吗?

“蒋涛涛:yarn logs可以查看所有日志”

赵慧 参与了问答:

blink中是否已经实现了HBase表的维表JOIN功能?有的话,具体体现在哪个包里?

转自钉钉群21789141:blink中是否已经实现了HBase表的维表JOIN功能?有的话,具体体现在哪个包里?

“蒋涛涛:有体现,org.apache.flink.connectors.hbase.table.HBaseLookupFunctionorg.apache.flink.table.plan.nodes...查看全部>

赵慧 参与了问答:

请问Flink on Yarn的模式是否需要部署Flink 集群?个人理解下来,Flink on Yarn会从启动session的节点上传jar和配置文件,但是每次想到spark on yarn部署了集群心里总是不安。还请在生产中使用Flink的前辈确认一下,谢谢!

转自钉钉群21789141:Flink on Yarn的模式是否需要部署Flink 集群?个人理解下来,Flink on Yarn会从启动session的节点上传jar和配置文件,但是每次想到spar...

“罗皓坚:不需要部署flink 集群,有个 客户端提交就可以了。”

赵慧 参与了问答:

谁有flink的学习资料

转自钉钉群21789141:谁有flink的学习资料

“李志涛:云邪博客:http://wuchong.me/archives/《从0到1学习Flink》:http://www.54tianzhisheng.cn/2018/10/13/flink-intr...查看全部>

赵慧 参与了问答:

现在blink能用在生产环境吗

转自钉钉群21789141:现在blink能用在生产环境吗

“鲁尼:能,我们自己都上了两年了”

赵慧 参与了问答:

flink每分钟滚动和滑动窗口能不能join在一起啊?

转自钉钉群21789141:flink每分钟滚动和滑动窗口能不能join在一起啊?

“纯庚:这个没有限制”
4
暂未提供

感兴趣or擅长的领域:

暂无
更多>
apache_flink
apache_flink
文章:13丨 粉丝:18305丨 话题:0
更多>
游客x77uienc5c7aa
游客x77uienc5c7aa
文章:0丨 粉丝:0丨 话题:0
游客fjaytkdqgr2nc
游客fjaytkdqgr2nc
文章:0丨 粉丝:0丨 话题:0
游客alpiqnbu43xd2
游客alpiqnbu43xd2
文章:0丨 粉丝:0丨 话题:0
游客ikhogxr37v6pw
游客ikhogxr37v6pw
文章:0丨 粉丝:0丨 话题:0
游客aw24uxt5lj642
游客aw24uxt5lj642
文章:0丨 粉丝:0丨 话题:0
游客fu3bnckauikwo
游客fu3bnckauikwo
文章:0丨 粉丝:0丨 话题:0