user-zh

日期索引

2023/09/24 Re: Flink SQL的状态清理 Jane Chan
2023/09/24 Re: 退订 Yunfeng Zhou
2023/09/24 Re: 1.17.1 - Interval join的时候发生NPE Hangxiang Yu
2023/09/24 在使用使用jemalloc内存分配器一段时间后，出现checkpoint 超时，任务卡住的情况 rui chen
2023/09/24 After using the jemalloc memory allocator for a period of time, checkpoint timeout occurs and tasks are stuck rui chen
2023/09/24 flink两阶段提交海风
2023/09/23 1.17.1 - Interval join的时候发生NPE Phoes Huang
2023/09/22 如何获取flink任务 source 和sink的所链接的中间件的ip信息阿华田
2023/09/21 回复：Flink SQL的状态清理 faronzz
2023/09/21 Flink SQL的状态清理小昌同学
2023/09/20 Re: Flink cdc 2.0 历史数据太大，导致log积压怎么解决 jinzhuguang
2023/09/20 Re: 回复：flink1.17版本不支持hive 2.1版本了吗 yuxia
2023/09/20 Flink cdc 2.0 历史数据太大，导致log积压怎么解决 jinzhuguang
2023/09/20 Re: Flink cdc 2.0 历史数据太大，导致log积压怎么解决 Jiabao Sun
2023/09/20 Flink cdc 2.0 历史数据太大，导致log积压怎么解决 jinzhuguang
2023/09/19 [CVE-2023-41834] Apache Flink Stateful Functions allowed HTTP header injection due to Improper Neutralization of CRLF Sequences Martijn Visser
2023/09/19 [ANNOUNCE] Apache Flink Stateful Functions Release 3.3.0 released Martijn Visser
2023/09/15 回复: 退订 Chen Zhanghao
2023/09/15 回复: flink-metrics如何获取applicationid Chen Zhanghao
2023/09/15 Re: flink-metrics如何获取applicationid im huzi
2023/09/12 Re: 退订 Biao Geng
2023/09/11 回复：flink-metrics如何获取applicationid 吴先生
2023/09/11 Re: 退订 Hang Ruan
2023/09/11 Re: 退订 Hang Ruan
2023/09/10 退订 Hunk
2023/09/10 退订 Hunk
2023/09/10 退订 whsyj-1989
2023/09/10 退订刘海
2023/09/10 退订 wangchuan
2023/09/09 退订 Hanelalo
2023/09/06 Re: flink rocksdb在托管&非托管模式下rocksdb内存计算 Hangxiang Yu
2023/09/03 Re: 退订 Jane Chan
2023/09/03 退订 lei-tian
2023/08/31 Re: Could not retrieve JobResults of globally-terminated jobs from JobResultStore Shammon FY
2023/08/31 Could not retrieve JobResults of globally-terminated jobs from JobResultStore denghaibin
2023/08/30 回复：flink-metrics如何获取applicationid allanqinjy
2023/08/30 回复：flink-metrics如何获取applicationid allanqinjy
2023/08/30 Re: flink-metrics如何获取applicationid Feng Jin
2023/08/30 flink-metrics如何获取applicationid allanqinjy
2023/08/29 Re:Re: Re: K8s Appliaction模式无法支持flinkjar中Java动态编译？周坤
2023/08/29 退订喻凯
2023/08/29 Re: Re: K8s Appliaction模式无法支持flinkjar中Java动态编译？孙路昊
2023/08/29 Re:Re: K8s Appliaction模式无法支持flinkjar中Java动态编译？周坤
2023/08/29 flink_1.13 rocksdb???? crazy
2023/08/28 Re: flink sql语句转成底层处理函数 Feng Jin
2023/08/27 来自周勃的邮件周勃
2023/08/27 退订刘海
2023/08/27 退订蔡荣
2023/08/27 回复：flink sql语句转成底层处理函数海风
2023/08/27 Re: flink sql语句转成底层处理函数 Shammon FY
2023/08/27 flink sql语句转成底层处理函数海风
2023/08/26 妈逼，这些都是假洋鬼子北野 �悦
2023/08/26 pyflink aggfunction in window tvf can not sink connection='kafka', it notice consuming update changesm, java aggfunction and aggfunction in flink, such as sum is ok faronzz
2023/08/26 中国各地居民担心盐被污染，掀起抢购食盐的浪潮北野 �悦
2023/08/26 答复: 朝鲜第二次发射军事侦察卫星，对话是解决问题的“唯一出路” 北野 �悦
2023/08/25 Re: 朝鲜第二次发射军事侦察卫星，对话是解决问题的“唯一出路” tison
2023/08/25 朝鲜第二次发射军事侦察卫星，对话是解决问题的“唯一出路” 北野 �悦
2023/08/24 Re: 事件流和规则流匹配问题 guozhi mang
2023/08/24 Re: flink1.17.1版本 flink sql多表关联优化 xiaohui zhang
2023/08/24 RE: 普里戈任专机，是被导弹打下来的？ crysis56563726
2023/08/24 普里戈任专机，是被导弹打下来的？北野 �悦
2023/08/23 事件流和规则流匹配问题 haishui
2023/08/23 Re: K8s Appliaction模式无法支持flinkjar中Java动态编译？ Weihua Hu
2023/08/23 Fwd: [Discussion] Slack Channel Jing Ge
2023/08/20 Re:Re: RE: 咨询求助: Least函数输入正常但是返回值异常 guifeng huang
2023/08/20 Re: RE: 咨询求助: Least函数输入正常但是返回值异常 guozhi mang
2023/08/20 Re:RE: 咨询求助: Least函数输入正常但是返回值异常 guifeng huang
2023/08/20 RE: 咨询求助: Least函数输入正常但是返回值异常 Jiabao Sun
2023/08/20 咨询求助: Least函数输入正常但是返回值异常 guifeng huang
2023/08/20 checkpoint原理和2pc原理 zyzandmz
2023/08/17 Re: flink sql作业状态跨存储系统迁移问题 Tianwang Li
2023/08/16 Re: 背压分析 yidan zhao
2023/08/15 [ANNOUNCE] Apache Flink Kubernetes Operator 1.6.0 released Gyula Fóra
2023/08/14 来自周勃的邮件周勃
2023/08/13 Re: 关于RichFlatMapFunction的状态输出 Shammon FY
2023/08/10 关于RichFlatMapFunction的状态输出 Liu Join
2023/08/10 退订蔡荣
2023/08/10 退订 DannyLau
2023/08/10 在flink1.17.1中java调用pythonUDF奇怪问题[maximum recursion depth][python函数正常] 1
2023/08/10 在flink1.17.1中java调用pythonUDF奇怪问题[maximum recursion depth][python函数正常] 1
2023/08/10 在flink1.17.1中java调用pythonUDF奇怪问题[maximum recursion depth][python函数正常] 1
2023/08/10 Re: Flink消费MySQL Leo
2023/08/09 退订 Inso Zhy
2023/08/09 回复： Flink 窗口触发条件小昌同学
2023/08/09 Re: Flink 窗口触发条件 Yanfei Lei
2023/08/09 Flink 窗口触发条件小昌同学
2023/08/09 退订 fl
2023/08/09 回复：回复： Flink消费MySQL 小昌同学
2023/08/09 Re: 自定义ScalarFunction函数运行报错 ron
2023/08/09 Re: 回复： Flink消费MySQL ron
2023/08/07 Re: Flink消费MySQL Shammon FY
2023/08/07 Re: Flink消费MySQL Jiabao Sun
2023/08/07 回复： Flink消费MySQL 小昌同学
2023/08/07 Re: Flink消费MySQL Shammon FY
2023/08/07 Re:Re: flink作业如何从yarn平滑迁移到k8s？ casel.chen
2023/08/07 Re: flink1.14.5 sql-client无法查询hbase1.4.3数据 Shammon FY
2023/08/07 Flink消费MySQL 小昌同学
2023/08/06 Re: flink作业如何从yarn平滑迁移到k8s？ Ruibin Xing
2023/08/06 flink作业如何从yarn平滑迁移到k8s？ casel.chen
2023/08/05 flink1.14.5 sql-client无法查询hbase1.4.3数据杨东树
2023/08/03 Re: 作业full gc 很严重 Shammon FY
2023/08/03 Re: flink1.17.1版本 flink sql多表关联优化周先明
2023/08/03 Re: 作业full gc 很严重 yidan zhao
2023/08/03 flink1.17.1版本 flink sql多表关联优化 guanyq
2023/08/02 Re: Flink窗口状态清除疑问 yidan zhao
2023/08/02 Re: Flink ML yidan zhao
2023/08/01 Re: 如何把自己新增的定制化connector deploy snapshot版本到私服仓库 Jiabao Sun
2023/08/01 Re: 如何把自己新增的定制化connector deploy snapshot版本到私服仓库 jinzhuguang
2023/08/01 Re: flink sql作业状态跨存储系统迁移问题 Hangxiang Yu
2023/08/01 flink1.17.1版本 flink on yarn 提交无法获取配置文件 guanyq
2023/08/01 退订 Inso Zhy
2023/08/01 Flink ML 15904502343
2023/07/28 flink sql作业状态跨存储系统迁移问题 casel.chen
2023/07/28 关于使用DataStream实现有界流的join Liu Join
2023/07/27 回复： flink-job-history 任务太多页面卡死阿华田
2023/07/27 Re: flink-job-history 任务太多页面卡死 Weihua Hu
2023/07/27 Re: flink-job-history 任务太多页面卡死 Shammon FY
2023/07/27 flink-job-history 任务太多页面卡死阿华田
2023/07/26 Re: 退订 daniel sun
2023/07/26 退订许琦
2023/07/26 Re: 如何把自己新增的定制化connector deploy snapshot版本到私服仓库 Jiabao Sun
2023/07/26 如何把自己新增的定制化connector deploy snapshot版本到私服仓库 jinzhuguang
2023/07/26 Re:RE: flink如何正确使用mybatis lxk
2023/07/26 RE: flink如何正确使用mybatis Jiabao Sun
2023/07/26 退订 lei-tian
2023/07/26 回复: 关于DataStream API计算批数据的聚合值 Liu Join
2023/07/26 Re: 退订 Edward Wang
2023/07/26 退订 Edward Wang
2023/07/25 回复： JdbcSink引发的IO过高小昌同学
2023/07/25 Re: JdbcSink引发的IO过高 Shammon FY
2023/07/25 Re: 关于DataStream API计算批数据的聚合值 weijie guo
2023/07/25 Re: 关于DataStream API计算批数据的聚合值 Shammon FY
2023/07/25 关于DataStream API计算批数据的聚合值 Liu Join
2023/07/25 JdbcSink引发的IO过高小昌同学
2023/07/24 Flink窗口状态清除疑问 lxk
2023/07/24 RE: 安装operator Guozhen Yang
2023/07/23 Re: flink1.17.1版本 MiniCluster is not yet running or has already been shut down. Shammon FY
2023/07/23 退订 zjw
2023/07/22 安装operator Jiacheng Jiang
2023/07/22 flink1.17.1版本 MiniCluster is not yet running or has already been shut down. guanyq
2023/07/21 flink1.17.1版本 guanyq
2023/07/21 退订 XJ Li
2023/07/20 flink异步IO超时时，如何释放连接池资源李一飞
2023/07/20 Re: ASF jira account jinzhuguang
2023/07/19 ASF jira account 李天龙
2023/07/19 答复: Flink1.17.1 yarn token 过期问题王刚
2023/07/19 Flink1.17.1 yarn token 过期问题王刚
2023/07/18 Re: 建议Flink ROWKIND做成元数据metadata Feng Jin
2023/07/18 Re: 建议Flink ROWKIND做成元数据metadata casel.chen
2023/07/17 退订 WD.Z
2023/07/17 flink如何正确使用mybatis lxk
2023/07/16 回复：flink on k8s 任务状态监控问题 tanjialiang
2023/07/16 回复：flink on k8s 任务状态监控问题阿华田
2023/07/16 Re: Re: flink1.14.5 sql-client 运行在yarn-session模式提交任务报错 Shammon FY
2023/07/15 Re:Re: flink1.14.5 sql-client 运行在yarn-session模式提交任务报错杨东树
2023/07/14 建议Flink ROWKIND做成元数据metadata casel.chen
2023/07/14 Re:flink on k8s 任务状态监控问题 casel.chen
2023/07/14 flink on k8s 任务状态监控问题阿华田
2023/07/13 Re: Re: PartitionNotFoundException循环重启 Shammon FY
2023/07/13 Encounter library registration references a different set of library BLOBs after jobManager restarted Liting Liu (litiliu)
2023/07/12 退订 wang
2023/07/12 Re: 如果DataSet API 被彻底废掉了，那我如何用DataStream实现分区、排序这个需求？ jinzhuguang
2023/07/12 Re: 如果DataSet API 被彻底废掉了，那我如何用DataStream实现分区、排序这个需求？ weijie guo
2023/07/12 Re: 如果DataSet API 被彻底废掉了，那我如何用DataStream实现分区、排序这个需求？ jinzhuguang
2023/07/12 Re: 如果DataSet API 被彻底废掉了，那我如何用DataStream实现分区、排序这个需求？ weijie guo
2023/07/12 flink sql 传参数问题 1
2023/07/11 Re: 如果DataSet API 被彻底废掉了，那我如何用DataStream实现分区、排序这个需求？ yuxia
2023/07/11 Re:Re: 从kafka中读取数据到hdfs，过段时间报错 chenyu_opensource
2023/07/11 Re: 从kafka中读取数据到hdfs，过段时间报错 Shammon FY
2023/07/11 从kafka中读取数据到hdfs，过段时间报错 chenyu_opensource
2023/07/11 Re:Re: Flink connector 是否支持忽略delete message casel.chen
2023/07/11 如果DataSet API 被彻底废掉了，那我如何用DataStream实现分区、排序这个需求？ jinzhuguang
2023/07/11 如果DataSet API 被彻底废掉了，那我如何用DataStream实现分区、排序这个需求？ jinzhuguang
2023/07/11 Re:Flink cep busy lxk
2023/07/10 Re: Flink connector 是否支持忽略delete message yh z
2023/07/10 退订曹佳清
2023/07/09 Re: flink1.14.5 sql-client 运行在yarn-session模式提交任务报错 Shammon FY
2023/07/09 flink1.14.5 sql-client 运行在yarn-session模式提交任务报错杨东树
2023/07/07 Re: Flink connector 是否支持忽略delete message shi franke
2023/07/07 Flink connector 是否支持忽略delete message shi franke
2023/07/06 两个流进行coGroup，水位线推进问题喻凯
2023/07/06 回复: Flink 1.16 流表 join 的 FilterPushDown 及并行 Chai Kelun
2023/07/05 Re: flink1.17.1使用kafka source异常 yh z
2023/07/05 Re: Flink 1.16 流表 join 的 FilterPushDown 及并行 yh z
2023/07/05 Re: flink on native k8s里如何使用flink sql gateway Shammon FY
2023/07/05 Re: Re: PartitionNotFoundException循环重启 Shammon FY
2023/07/03 Re: PartitionNotFoundException循环重启 Shammon FY
2023/07/03 退订周勃
2023/07/03 Flink 1.16 流表 join 的 FilterPushDown 及并行 Chai Kelun
2023/06/29 Re: 关于flink批计算 Shammon FY
2023/06/29 关于flink批计算 Liu Join
2023/06/27 Flink CDC消费MySQL Binlog出现中文乱码问题 casel.chen
2023/06/23 Re:Flink CDC消费mysql `0000-00-00 00:00:00` 时间值问题 casel.chen
2023/06/22 Re:Re: How can i update OnlineLogisticRegression Model continuously 刘勋
2023/06/20 Re: Flink1.14 需求超大内存郭欣瑞
2023/06/20 Re:Re: Flink1.14 需求超大内存王国成
2023/06/19 Re: Flink1.14 需求超大内存 Yanfei Lei
2023/06/19 Re: Flink1.14 需求超大内存 Shammon FY
2023/06/19 Flink1.14 需求超大内存郭欣瑞
2023/06/18 Flink CDC消费mysql `0000-00-00 00:00:00` 时间值问题 casel.chen