user-zh
文章
日期
较舊的信息
较新的信息
文章索引
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
转发: 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
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
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 on yarn任务停止发生异常
Jiangang Liu
Flink????????????
hjw
Re: Flink计算机制疑问
Jiangang Liu
?????? Flink????????????
hjw
flink s3 checkpoint 一直IN_PROGRESS(100%)直到失败
Sun.Zhu
Re:flink s3 checkpoint 一直IN_PROGRESS(100%)直到失败
Sun.Zhu
Re: Re:flink s3 checkpoint 一直IN_PROGRESS(100%)直到失败
Yun Tang
Re:jdk11创建hive catalog抛错
zhangmang1
k8s native session 问题咨询
崔深圳
Re: k8s native session 问题咨询
yu'an huang
Re:Re: k8s native session 问题咨询
崔深圳
Re:Re: k8s native session 问题咨询
崔深圳
Re: Re: k8s native session 问题咨询
Yang Wang
Re: k8s native session 问题咨询
yu'an huang
Re: k8s native session 问题咨询
Yang Wang
flink-connector-jdbc是否支持多个values问题
payne_z
??????flink-connector-jdbc????????????values????
????
Re: flink-connector-jdbc是否支持多个values问题
Zhiwen Sun
flink任务经常性报错
潘明文
Re: flink任务经常性报错
yue ma
Re:Re: flink任务经常性报错
潘明文
??????Re: flink??????????????
????
?????? flink??????????????
????
io.network.netty.exception
潘明文
Re: io.network.netty.exception
Zhilong Hong
Re:Re: io.network.netty.exception
潘明文
Re: Re: io.network.netty.exception
yue ma
flink1.14.0 temporal join hive
guanyq
Re:flink1.14.0 temporal join hive
mack143
CDC 分表同步快照顺序
刘 家锹
Flink??????????????????,????????????
Tony
Re: Flink的集群数据处理能力,如何计算出来
yu'an huang
flink 反压导致checkpoint超时,从而导致任务失败问题
kong
Re: flink 反压导致checkpoint超时,从而导致任务失败问题
yu'an huang
Re: flink 反压导致checkpoint超时,从而导致任务失败问题
yu'an huang
Re: flink 反压导致checkpoint超时,从而导致任务失败问题
Zhilong Hong
??????????????????kafka??????????????kafka??????????????????????????
jianjianjianjianjianjianjianjian
[DISCUSS]当timestamp - offset + windowSize < 0时,元素无法被分配到正确的窗口
邓子琦
Re: [DISCUSS]当timestamp - offset + windowSize < 0时,元素无法被分配到正确的窗口
yu'an huang
Re: [DISCUSS]当timestamp - offset + windowSize < 0时,元素无法被分配到正确的窗口
邓子琦
Re: [DISCUSS]当timestamp - offset + windowSize < 0时,元素无法被分配到正确的窗口
yidan zhao
Re: [DISCUSS]当timestamp - offset + windowSize < 0时,元素无法被分配到正确的窗口
邓子琦
Re: [DISCUSS]当timestamp - offset + windowSize < 0时,元素无法被分配到正确的窗口
yidan zhao
Flink On K8s ???????? SSL????????
hjw
K8s部署Flink 作业,无法在Web UI查看TaskManger的STDOUT日志
xinzhuxiansheng
Re: K8s部署Flink 作业,无法在Web UI查看TaskManger的STDOUT日志
Yang Wang
Re: K8s部署Flink 作业,无法在Web UI查看TaskManger的STDOUT日志
吴Janick
elasticsearch+hbase
潘明文
elasticsearch+hbase
潘明文
Re: elasticsearch+hbase
Guo Thompson
回复:退订
胡云川
使用CUMULATE WINDOW 消费upsertkafka遇到的问题
赵旭晨
Re:使用CUMULATE WINDOW 消费upsertkafka遇到的问题
赵旭晨
Re: 使用CUMULATE WINDOW 消费upsertkafka遇到的问题
Caizhi Weng
flinksql 使用kafka connector (自定义的cdc格式) 消费删除语义的数据没有纳入计算
赵旭晨
Re: flinksql 使用kafka connector (自定义的cdc格式) 消费删除语义的数据没有纳入计算
Guo Thompson
keyBy 后的 getKey 函数调用了两次
Lei Wang
Re: keyBy 后的 getKey 函数调用了两次
yidan zhao
Re: keyBy 后的 getKey 函数调用了两次
Lei Wang
Re: keyBy 后的 getKey 函数调用了两次
yidan zhao
回复: keyBy 后的 getKey 函数调用了两次
Liu Join
Flink FailureRateRestartStrategy策略异常
刘 家锹
Re: Flink FailureRateRestartStrategy策略异常
胡伟华
回复: Flink FailureRateRestartStrategy策略异常
刘 家锹
Re: Flink FailureRateRestartStrategy策略异常
胡伟华
回复: Flink FailureRateRestartStrategy策略异常
刘 家锹
Re:回复: Flink FailureRateRestartStrategy策略异常
janke
Re:答复: 回复:如何从复杂的kafka消息体定义 table
mack143
Flink UI 经常打不开作业的拓扑图
xinzhuxiansheng
Re: Flink UI 经常打不开作业的拓扑图
胡伟华
Re: Flink UI 经常打不开作业的拓扑图
胡伟华
Re: Flink UI 经常打不开作业的拓扑图
yu'an huang
flink-connector-jdbc sink mysql是否存在乱序问题
Guo Thompson
Re: flink-connector-jdbc sink mysql是否存在乱序问题
yu'an huang
Fwd: flink-connector-jdbc sink mysql是否会存在乱序问题
Guo Thompson
flink状态恢复
enginegun
Re: flink状态恢复
Guo Thompson
Re: flink状态恢复
yidan zhao
flink状态恢复
小昌同学
Re: flink状态恢复
Hangxiang Yu
如何按比例丢弃kafka中消费的数据
jack zhang
Re: 如何按比例丢弃kafka中消费的数据
18703416...@163.com
Re: 如何按比例丢弃kafka中消费的数据
张昊 陈
Re: 如何按比例丢弃kafka中消费的数据
史延朋
Re:Re: 如何按比例丢弃kafka中消费的数据
chenkaibit
实时数据入库怎样过滤中间状态,保证最终一致
Lei Wang
Re: 实时数据入库怎样过滤中间状态,保证最终一致
18703416...@163.com
Re: 实时数据入库怎样过滤中间状态,保证最终一致
yidan zhao
回复: 实时数据入库怎样过滤中间状态,保证最终一致
Liu Join
Re: 实时数据入库怎样过滤中间状态,保证最终一致
Lei Wang
Re: 实时数据入库怎样过滤中间状态,保证最终一致
18703416...@163.com
Re: 实时数据入库怎样过滤中间状态,保证最终一致
Guo Thompson
flink状态共享
huangzhi...@iwgame.com
Re: flink状态共享
18703416...@163.com
Re: flink状态共享
yidan zhao
flink1.14 注册mysql connector报错
xiaoyue
Re: flink1.14 注册mysql connector报错
Tony Wei
Re: Re: flink1.14 注册mysql connector报错
xiaoyue
Re: Re: flink1.14 注册mysql connector报错
Tony Wei
Re: Re: flink1.14 注册mysql connector报错
xiaoyue
reserved key percentile_cont
ZHANG YU
Flink????????HDFS
Tony
Re: Flink数据写入HDFS
wenjie li
?????? Flink????????HDFS
Tony
Re: Flink数据写入HDFS
wenjie li
状态初始化
huangzhi...@iwgame.com
Re: 状态初始化
Jiangang Liu
Re: 状态初始化
Yun Tang
状态初始化
huangzhi...@iwgame.com
状态初始化
huangzhi...@iwgame.com
Re: 状态初始化
Jie Han
rocksdb backend设置后没有启用
swessia
Re: rocksdb backend设置后没有启用
胡伟华
Re:Re: rocksdb backend设置后没有启用
swessia
使用Apache Pulsar Connector发生NoClassDefFoundError
AaronFae
Re:使用Apache Pulsar Connector发生NoClassDefFoundError
高大余
Re:Re:使用Apache Pulsar Connector发生NoClassDefFoundError
AaronFae
flink Per-Job-Cluster 支持提交sql任务吗
shanwu...@rockontrol.com
Re:flink Per-Job-Cluster 支持提交sql任务吗
高大余
Re: flink Per-Job-Cluster 支持提交sql任务吗
丛鹏
?????? flink Per-Job-Cluster ????????sql??????
??????
Fiink-sql的官方函数的代码哪里可以看到
王宇航
??????Fiink-sql????????????????????????????
?Y??????????????????
hive 进行 overwrite 合并数据后文件变大?
RS
Re:hive 进行 overwrite 合并数据后文件变大?
周瑞
回复:hive 进行 overwrite 合并数据后文件变大?
Shuai Xia
Re:回复:hive 进行 overwrite 合并数据后文件变大?
RS
关于timestamp在eventTime和processTIme、以及各种不同API情况下的不同实现。
yidan zhao
关于“批”处理元素导致batch的event timestamp变化,后接window统计错乱的问题。
yidan zhao
Re: 关于“批”处理元素导致batch的event timestamp变化,后接window统计错乱的问题。
yidan zhao
[ANNOUNCE] Apache Flink 1.13.6 released
Konstantin Knauf
FlinkSQL vs DataStream API 对硬件的需求
Pinjie Huang
Re: FlinkSQL vs DataStream API 对硬件的需求
Jie Han
Re: FlinkSQL vs DataStream API 对硬件的需求
yue ma
flink 不触发checkpoint
董少杰
Re:flink 不触发checkpoint
RS
Re: flink 不触发checkpoint
Tony Wei
org.apache.flink.runtime.rpc.exceptions.FencingTokenException
casel.chen
cep 的困惑
翼 之道
Re: cep 的困惑
yue ma
关于将数据batch到一起处理再拆分后timestamp发生错乱的问题
yidan zhao
flinkcdc:slave with the same server_uuid/server_id as this slave has connected to the master;
maker_d...@foxmail.com
回复: flinkcdc:slave with the same server_uuid/server_id as this slave has connected to the master;
chengyanan1...@foxmail.com
flink sql jdbc sink事务提交问题
casel.chen
Re:flink sql jdbc sink事务提交问题
Michael Ran
Re:Re:flink sql jdbc sink事务提交问题
casel.chen
??????<??????>
????????
flink-netty-shuffle文件占满节点磁盘
智能平台
Re: flink-netty-shuffle文件占满节点磁盘
Yingjie Cao
flink创建视图后,SELECT语句后使用OPTIONS报错
liangjinghong
Re: flink创建视图后,SELECT语句后使用OPTIONS报错
godfrey he
转发: flink创建视图后,SELECT语句后使用OPTIONS报错
liangjinghong
Re: flink创建视图后,SELECT语句后使用OPTIONS报错
godfrey he
jdbc connector ??????????????????????????????????????????????????????????????
jianjianjianjianjianjianjianjian
Re: jdbc connector 写入异常数据后,不再写入新数据时,异常信息不断嵌套,且不会抛出
Caizhi Weng
回复:jdbc connector 写入异常数据后,不再写入新数据时,异常信息不断嵌套,且不会抛出
jianjianjianjianjianjianjianjian
Re:jdbc connector ??????????????????????????????????????????????????????????????
Michael Ran
[statefun] How to make the input/output topics live in different kafka clusters for flink stateful functions
casel.chen
请教设置了table.exec.state.ttl后,结果数据不更新问题
liangjinghong
Re: 请教设置了table.exec.state.ttl后,结果数据不更新问题
Caizhi Weng
flink on yarn HDFS_DELEGATION_TOKEN清除后,任务am attempt时失败
xieyi
flink on yarn HDFS_DELEGATION_TOKEN清除后,任务am attempt时失败
xieyi
回复:flink on yarn HDFS_DELEGATION_TOKEN清除后,任务am attempt时失败
xieyi
Flink sql 客户端实现
JianWen Huang
??????Flink sql ??????????
??????
较舊的信息
较新的信息