user-zh
文章
日期
较舊的信息
较新的信息
文章索引
Re: flinksql执行时提示自定义UDF无法加载的
Zhanghao Chen
flink命令行参数不生效问题
gangzi
Re: flink命令行参数不生效问题
Zhanghao Chen
Re: flink命令行参数不生效问题
QQ
Re: flink命令行参数不生效问题
Zhanghao Chen
日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
段晓雄
Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
yidan zhao
RE: Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
段晓雄
Re: Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
Zhanghao Chen
RE: Re: Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
段晓雄
Re: Re: Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
Zhanghao Chen
RE: Re: Re: Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
段晓雄
flink jdbc connector不支持source
casel.chen
Re: flink jdbc connector不支持source
Qingsheng Ren
yarn api 提交报错
周涛
Re:yarn api 提交报错
Mang Zhang
Re:Re:yarn api 提交报错
周涛
Re:Re:Re:yarn api 提交报错
Mang Zhang
答复: Re:Re:yarn api 提交报错
Geng Biao
flink sql 任务中jm Blob server 总是在凌晨报 java.io.exception :unknow opreation 71
su wenwen
Re:flink sql 任务中jm Blob server 总是在凌晨报 java.io.exception :unknow opreation 71
Mang Zhang
k8s session cluster flink1.13.6创建后提示的地址啥用。
yidan zhao
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
Zhanghao Chen
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
yu'an huang
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
yidan zhao
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
yidan zhao
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
yidan zhao
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
Zhanghao Chen
flink table store
yidan zhao
Re: flink table store
LuNing Wang
Re: flink table store
Xianxun Ye
Re: flink table store
Leonard Xu
Re: flink table store
tison
Re: flink table store
Paul Lam
flink1.1.36用SQL方式如何设置输出到hive表为upsert模式?
799590...@qq.com.INVALID
Re: flink1.1.36用SQL方式如何设置输出到hive表为upsert模式?
LuNing Wang
[ANNOUNCE] Apache Flink Kubernetes Operator 0.1.0 released
Gyula Fóra
flink 1.15
guanyq
Re: flink 1.15
Zhanghao Chen
如何条件查询不扫描全表
汪赟
Re: 如何条件查询不扫描全表
Shengkai Fang
Could you please give me a hand about json object in flink sql
wang
Re:Could you please give me a hand about json object in flink sql
Mang Zhang
How can I set job parameter in flink sql
wang
How can I set job parameter in flink sql
wang
Re: How can I set job parameter in flink sql
yuxia
Re:Re: How can I set job parameter in flink sql
wang
Does kafka key is supported in kafka sink table
wang
Re: Does kafka key is supported in kafka sink table
Dhavan Vaidya
Re: Does kafka key is supported in kafka sink table
Shengkai Fang
GlobalCommitter in Flink's two-phase commit
di wu
Re: GlobalCommitter in Flink's two-phase commit
Jing Ge
Re: Disable the chain of the Sink operator
Shammon FY
Re: Disable the chain of the Sink operator
wudi
Re: Disable the chain of the Sink operator
weijie guo
Re: Disable the chain of the Sink operator
Chesnay Schepler
Re: Disable the chain of the Sink operator
wudi
Re: Disable the chain of the Sink operator
Shammon FY
Re: Disable the chain of the Sink operator
wudi
LinkedMap ClassCastException issue
wang
Re: LinkedMap ClassCastException issue
Shengkai Fang
Does flink sql support UDTAGG
wang
Re:Does flink sql support UDTAGG
Xuyang
Re:Re:Does flink sql support UDTAGG
wang
Re: Re:Does flink sql support UDTAGG
Weihua Hu
Watermark generating mechanism in Flink SQL
wang
Re: Watermark generating mechanism in Flink SQL
Matthias Pohl
Whether Flink SQL window operations support "Allow Lateness and SideOutput"?
wang
Re: Whether Flink SQL window operations support "Allow Lateness and SideOutput"?
Weihua Hu
flink jdbc source oom
Peihui He
Re: flink jdbc source oom
r pp
Re: flink jdbc source oom
Lincoln Lee
Re:Re: flink jdbc source oom
Michael Ran
Re: Re: flink jdbc source oom
r pp
Re: Re: flink jdbc source oom
r pp
Re: flink jdbc source oom
Guo Thompson
flink on k8s场景,大家一般如何解决访问hdfs的问题呢。
yidan zhao
Re:flink on k8s场景,大家一般如何解决访问hdfs的问题呢。
casel.chen
Re: flink on k8s场景,大家一般如何解决访问hdfs的问题呢。
LuNing Wang
Re: 实时数据入库怎样过滤中间状态,保证最终一致
Guo Thompson
Re: elasticsearch+hbase
Guo Thompson
flink on k8s是否有替代yarn.ship-files的参数
shimin huang
Re: flink on k8s是否有替代yarn.ship-files的参数
Geng Biao
Re: flink on k8s是否有替代yarn.ship-files的参数
shimin huang
Re: flink on k8s是否有替代yarn.ship-files的参数
yu'an huang
Re: flink on k8s是否有替代yarn.ship-files的参数
shimin huang
Re: flink on k8s是否有替代yarn.ship-files的参数
shimin huang
Hash join exceeded maximum number of recursions, without reducing partitions enough to be memory resident. Probably cause: Too many duplicate keys.
Asahi Lee
计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
yj h
Re: 计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
r pp
Re: 计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
yj h
Re: 计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
r pp
Re: 计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
yue ma
Re: 计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
yj h
The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
Kaiqiang XIE谢开强
Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
胡伟华
Re:Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
Kaiqiang XIE谢开强
Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
Geng Biao
Re:Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
Kaiqiang XIE谢开强
Re:Re:Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
Kaiqiang XIE谢开强
Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
胡伟华
Flink本地集群监控问题
Kaiqiang
Re: Flink本地集群监控问题
Ning Xu
Re:Re: Flink本地集群监控问题
Kaiqiang XIE谢开强
flink1.12. The error message is maybe misguided
丛鹏
Re: flink1.12. The error message is maybe misguided
胡伟华
Re: flink1.12. The error message is maybe misguided
丛鹏
Re: flink1.12. The error message is maybe misguided
丛鹏
Flink ad-hoc方向问题
LuNing Wang
Re: Flink ad-hoc方向问题
Xintong Song
问题咨询: Too more data in this partition: 2147483648
Kevin Lee
使用问题咨询:Postgres 数据库作为 Catalog 时如何设置一些其他参数
17610801...@163.com
Re: 使用问题咨询:Postgres 数据库作为 Catalog 时如何设置一些其他参数
史延朋
flink-sql,对于kafka 的一些额外参数如何配置
Michael Ran
Re:flink-sql,对于kafka 的一些额外参数如何配置
RS
??????flink-sql??????kafka ??????????????????????
??????
Re:回复:flink-sql,对于kafka 的一些额外参数如何配置
Michael Ran
FLINK 实时写入HBASE性能问题
潘明文
维度表变化,关联结果全部更新在Flink SQL该如何实现
JianWen Huang
Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
zns
Re:Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
casel.chen
Re: Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
JianWen Huang
Re:Re: Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
RS
Re:Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
Michael Ran
Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
wushijjian5
设定kafka消费结束位置
李航飞
设定kafka消费结束位置
李航飞
Table Api Connectors kafka bounded
李航飞
Re:Table Api Connectors kafka bounded
RS
RocksDB 读 cpu 100% 如何调优
Peihui He
Re:RocksDB 读 cpu 100% 如何调优
deng xuezhao
Re: RocksDB 读 cpu 100% 如何调优
Jiangang Liu
Re: RocksDB 读 cpu 100% 如何调优
yue ma
Re: RocksDB 读 cpu 100% 如何调优
Jiangang Liu
Re: RocksDB 读 cpu 100% 如何调优
Peihui He
Re: RocksDB 读 cpu 100% 如何调优
Peihui He
Re: RocksDB 读 cpu 100% 如何调优
Yun Tang
Re: RocksDB 读 cpu 100% 如何调优
Peihui He
Re: RocksDB 读 cpu 100% 如何调优
Guo Thompson
Re: RocksDB 读 cpu 100% 如何调优
Yun Tang
Re: RocksDB 读 cpu 100% 如何调优
Guo Thompson
如何根据flink日志排查错误
yidan zhao
Re: 如何根据flink日志排查错误
吴Janick
Re: 如何根据flink日志排查错误
yidan zhao
Re: 如何根据flink日志排查错误
胡伟华
如何得知当前Flink集群的leader
yidan zhao
Re: 如何得知当前Flink集群的leader
yu'an huang
Re: 如何得知当前Flink集群的leader
yidan zhao
Re: 如何得知当前Flink集群的leader
yu'an huang
Re: 如何得知当前Flink集群的leader
yidan zhao
[ANNOUNCE] Apache Flink 1.1.4.4 released
Konstantin Knauf
Re: [ANNOUNCE] Apache Flink 1.1.4.4 released
Martijn Visser
Re: [ANNOUNCE] Apache Flink 1.1.4.4 released
Leonard Xu
Re: [ANNOUNCE] Apache Flink 1.1.4.4 released
Xingbo Huang
Re: [ANNOUNCE] Apache Flink 1.1.4.4 released
Konstantin Knauf
Re: [ANNOUNCE] Apache Flink 1.1.4.4 released
Xingbo Huang
Flink写入Hive错误
顾斌杰
Re:Flink写入Hive错误
Mang Zhang
flinksql 使用kafka connector (自定义的cdc格式) 消费删除语义的数据没有纳入计算
赵旭晨
Re: flinksql 使用kafka connector (自定义的cdc格式) 消费删除语义的数据没有纳入计算
Guo Thompson
转发: flinkcdc:slave with the same server_uuid/server_id as this slave has connected to the master;
maker_d...@foxmail.com
Re: flinkcdc:slave with the same server_uuid/server_id as this slave has connected to the master;
Leonard Xu
Re: 如何按比例丢弃kafka中消费的数据
史延朋
Re:Re: 如何按比例丢弃kafka中消费的数据
chenkaibit
flink1.13.6用tableApi的方式从kafka写入hive失败,也不报错,但是写入文件或者mysql没有问题
799590...@qq.com.INVALID
Re: flink1.13.6用tableApi的方式从kafka写入hive失败,也不报错,但是写入文件或者mysql没有问题
Caizhi Weng
Re: Re: flink1.13.6用tableApi的方式从kafka写入hive失败,也不报错,但是写入文件或者mysql没有问题
799590...@qq.com.INVALID
????
Ever
Re: 退订
Caizhi Weng
????
??????
Re: 退订
LuNing Wang
????
598465018
Re: 退订
LuNing Wang
????
????
Re: 退订
Shengkai Fang
????
tears river
????
??????
Re: 退订
yu'an huang
????
????????
Re: 退订
yuxia
????
????
Re:退订
Xuyang
????
tears river
????
1120344670
????
??
Re: 退订
yanfei lei
????
????
????
zhangjunjie
Flink1.13 standalone基于zk进行HA,经常出现重启后无限leader选举的情况
yidan zhao
Re: Flink1.13 standalone基于zk进行HA,经常出现重启后无限leader选举的情况
Biao Geng
Re: Flink1.13 standalone基于zk进行HA,经常出现重启后无限leader选举的情况
yidan zhao
Re: Flink1.13 standalone基于zk进行HA,经常出现重启后无限leader选举的情况
Biao Geng
Re: Flink1.13 standalone基于zk进行HA,经常出现重启后无限leader选举的情况
yidan zhao
Re: Flink1.13 standalone基于zk进行HA,经常出现重启后无限leader选举的情况
胡伟华
Re: Flink1.13 standalone基于zk进行HA,经常出现重启后无限leader选举的情况
yidan zhao
求助:Flink Session模式下,多次重跑同一个批处理任务会导致系统内存被耗尽
renshang...@deepexi.com
Re: 求助:Flink Session模式下,多次重跑同一个批处理任务会导致系统内存被耗尽
yu'an huang
Re: 求助:Flink Session模式下,多次重跑同一个批处理任务会导致系统内存被耗尽
邮箱
Re: 求助:Flink Session模式下,多次重跑同一个批处理任务会导致系统内存被耗尽
Caizhi Weng
Re: Flink的集群数据处理能力,如何计算出来
yu'an huang
较舊的信息
较新的信息