user-zh  

文章索引

• Flink 2.0 CDC连接器缺失与Flink 1.20.1通用连接器版本兼容性问题 陈佳豪
  • Re: Flink 2.0 CDC连接器缺失与Flink 1.20.1通用连接器版本兼容性问题 Xiqian YU
• [PyFlink] No FileSystem for scheme "hdfs" when setting checkpoint storage 林珈斌
• [ANNOUNCE] Apache Flink 2.0.0 released Xintong Song
  • Re: [ANNOUNCE] Apache Flink 2.0.0 released Zakelly Lan
  • Re: [ANNOUNCE] Apache Flink 2.0.0 released Luke Chen
  • Re: [ANNOUNCE] Apache Flink 2.0.0 released Leonard Xu
  • Re: [ANNOUNCE] Apache Flink 2.0.0 released Yuan Mei
  • Re: [ANNOUNCE] Apache Flink 2.0.0 released Jingsong Li
  • Re: [ANNOUNCE] Apache Flink 2.0.0 released Jark Wu
  • Re: [ANNOUNCE] Apache Flink 2.0.0 released Xuannan Su
• Hardware CPU vCore fetch issue when Flink is running on yarn Vincent Woo
  • Re: Hardware CPU vCore fetch issue when Flink is running on yarn Zhanghao Chen
  • Re: Hardware CPU vCore fetch issue when Flink is running on yarn Zhanghao Chen
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.11.0 released Gyula Fóra
  • Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.11.0 released Gyula Fóra
• flink sql消费kafka中的cdc消息如何获取rowkind？ casel.chen
  • Re:flink sql消费kafka中的cdc消息如何获取rowkind？ Xuyang
  • Re: flink sql消费kafka中的cdc消息如何获取rowkind？ Xiqian YU
• 关于Flink应对Kafka定期密码更新 曲洋
• Re: flink cdc operator在v1.11.0出现404的问题 Xiqian YU
• 来自ji_longzh...@163.com的邮件 ji_longzhang
• [ANNOUNCE] Apache Flink 1.19.2 released Alexander Fedulov
• [ANNOUNCE] Apache Flink 1.20.1 released Alexander Fedulov
• flink-cdc pipeline????????paimon Mobile
  • Re: flink-cdc pipeline无法写入paimon Yanquan Lv
  • Re:flink-cdc pipeline无法写入paimon AaronFae
  • Re:Re:flink-cdc pipeline无法写入paimon AaronFae
• Re: flink-cdc Pipeline模式下如何使用状态？ Xiqian YU
• 来自宋泳康的邮件 宋泳康
  • 来自宋泳康的邮件 宋泳康
  • Re: 来自宋泳康的邮件 佘敦泽
• HadoopFSDelegationTokenProvider引起的低版本hadoop认证报错 杨东树
• Re: 服务打成docker镜像后业务方法报找不到ExecutionConfig类 Yanquan Lv
• [ANNOUNCE] Apache Flink CDC 3.3.0 released Hang Ruan
  • Re: [ANNOUNCE] Apache Flink CDC 3.3.0 released Leonard Xu
• flink sql append only数据源去重如何不产生retract消息？ casel.chen
  • Re:flink sql append only数据源去重如何不产生retract消息？ casel.chen
  • Re:Re:flink sql append only数据源去重如何不产生retract消息？ casel.chen
  • Re: Re:flink sql append only数据源去重如何不产生retract消息？ Feng Jin
  • Re:Re: Re:flink sql append only数据源去重如何不产生回撤retract消息？ casel.chen
  • Re: Re: Re:flink sql append only数据源去重如何不产生回撤retract消息？ Feng Jin
  • Re:Re: Re: Re:flink sql append only数据源去重如何不产生回撤retract消息？ Xuyang
• flink是否支持web ui和rest接口用户鉴权处理 宋春喜
  • Re:flink是否支持web ui和rest接口用户鉴权处理 Xuyang
• flink tableAPI 写 starrocks 提示 No operators 杨承波
  • Re:flink tableAPI 写 starrocks 提示 No operators Xuyang
• Re: Alink 是否还在维护，以及现在支持最高的flink版本是多少 Yunfeng Zhou
• Re: user-zh Digest 11 Dec 2024 09:39:53 -0000 Issue 2760 fangc...@chinatelecom.cn
• Re: cannot locate classes in flink-release-2.0-preview1 source Zakelly Lan
• java.lang.IllegalAccessError in java11 Smokeriu
  • Re:java.lang.IllegalAccessError in java11 Xuyang
• https://www.ikeguang.com/article/1922 李天祥
• flink on k8s operator zhou longhua
  • flink on k8s operator zhou longhua
• 我实现了一个基于数量和处理时间的trigger,但是总是在同一时间触发多次 丁浩
  • Re: 我实现了一个基于数量和处理时间的trigger,但是总是在同一时间触发多次 丁浩
• jira用户密码获取以及bug说明 冯培育
  • Re: jira用户密码获取以及bug说明 Shengkai Fang
  • Re: jira用户密码获取以及bug说明 Shengkai Fang
• Re: 寻找pyflink技术专家，做有偿技术咨询 Mack Liu
  • 回复： Re: 寻找pyflink技术专家，做有偿技术咨询 Jeff
  • Re: 寻找pyflink技术专家，做有偿技术咨询 Mack Liu
  • Re: Re: 寻找pyflink技术专家，做有偿技术咨询 len...@126.com
• flink怎么解决metaspace溢出的问题 yyjwork
  • Re: flink怎么解决metaspace溢出的问题 hekaifei
• [ANNOUNCE] Apache Flink CDC 3.2.1 released Hang Ruan
• 订阅 肖振男
  • 订阅 yyjwork
• 来自李天祥的邮件 李天祥
• Re: upsert-kafka source表在sql client中执行sql没有输出 Yanquan Lv
  • Re: upsert-kafka source表在sql client中执行sql没有输出 Shawn Huang
  • Re: upsert-kafka source表在sql client中执行sql没有输出 Yanquan Lv
  • Re: upsert-kafka source表在sql client中执行sql没有输出 Shawn Huang
• Re: Flink 1.11版本LeaseRenewer线程不释放 Bruce Bian
• 怎样解决Flink滑动窗口状态过多且连续输出无变化状态到下游写入问题？ casel.chen
  • Re: 怎样解决Flink滑动窗口状态过多且连续输出无变化状态到下游写入问题？ shuai xu
• Re:Re: flink sql维表关联数据膨胀问题 Xuyang
• Flink BigQuery Connector Public Preview Jayant Jain
• [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Yuepeng Pan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Gyula Fóra
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? yuanfeng hu
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Rui Fan
  • Re: [DISCUSS] Is it a bug that the AdaptiveScheduler does not prioritize releasing TaskManagers during downscaling in Application mode? Matthias Pohl
• Pyflink 如何合并流数据 Xiao Zhang
  • 回复: Pyflink 如何合并流数据 tianyuan Liu
  • Re: Pyflink 如何合并流数据 Dian Fu
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.10.0 released Őrhidi Mátyás
• Re: cumulate函数和比较函数连用报错 Paul Lam
• [ANNOUNCE] Apache Flink 2.0 Preview released Xintong Song
  • Re: [ANNOUNCE] Apache Flink 2.0 Preview released weijie guo
  • Re: [ANNOUNCE] Apache Flink 2.0 Preview released Zakelly Lan
• ?????? ????????????????????????????join????????sql ????
  • Re: 关于如何根据参数条件动态生成join的关联的sql Feng Jin
• pyflink fromsource调用自定义source 报错 Xiao Zhang
  • Re: pyflink fromsource调用自定义source 报错 Yanquan Lv
• ????????????????????????????join????????sql ????
  • Re: 关于如何根据参数条件动态生成join的关联的sql Feng Jin
• We found a deadlock problem when a single piece of data is too large on Flink1.13.2, do not continue to process the data, which more understand the data transmission piece, welcome to comment. rui chen
  • Re: We found a deadlock problem when a single piece of data is too large on Flink1.13.2, do not continue to process the data, which more understand the data transmission piece, welcome to comment. rui chen
• Flink has a large number of data and appears to be suspended after restarting. rui chen
  • Re:Flink has a large number of data and appears to be suspended after restarting. Xuyang
  • Re: Flink has a large number of data and appears to be suspended after restarting. rui chen
• Join Us for Flink Forward Asia 2024 in Shanghai (Nov 29-30) & Jakarta (Dec 5)! Xintong Song
• 来自li的邮件 li
• 来自15904502343的邮件 15904502343
• Re: 开源flink cep是否支持动态规则配置 Feng Jin
• Re:flink 1.20为何不再支持Pulsar的connector了 Xuyang
• Re:flink对象重用问题询问 Xuyang
  • Re:回复：flink对象重用问题询问 Xuyang
• 数据大小倾斜，数据量不倾斜 焦童
  • Re: 数据大小倾斜，数据量不倾斜 Jiangang Liu
• Taskmanager堆积LeaseRenewer线程问题咨询 付永华
  • Re: Taskmanager堆积LeaseRenewer线程问题咨询 Bruce Bian
• flink 1.20 MDC功能使用 logback 存在严重问题-无法正常启动 xuhaiLong
• Flink SQL 中如何将回撤流转为append流 焦童
  • Re:Flink SQL 中如何将回撤流转为append流 Xuyang
  • Re: Flink SQL 中如何将回撤流转为append流 xiaohui zhang
• 请问BackPressure是否影响Watermarks机制 jwfktv
  • 请问BackPressure是否影响Watermarks机制 jwfktv
  • 回复：请问BackPressure是否影响Watermarks机制 wjw_bigdata
  • 回复：请问BackPressure是否影响Watermarks机制 wjw_bigdata
  • 回复：请问BackPressure是否影响Watermarks机制 wjw_bigdata
• flink on yarn 模式，在jar任务中，怎么获取rest port melin li
  • Re: flink on yarn 模式，在jar任务中，怎么获取rest port Lei Wang
  • 回复： flink on yarn 模式，在jar任务中，怎么获取rest port wjw_bigdata
  • Re: flink on yarn 模式，在jar任务中，怎么获取rest port xiaohui zhang
• Re: flink 任务运行抛ClassNotFoundException Yanquan Lv
  • Re: flink 任务运行抛ClassNotFoundException Yanquan Lv
• 如何基于FLIP-384扩展对业务数据全链路延时情况的监控 Yubin Li
  • Re: 如何基于FLIP-384扩展对业务数据全链路延时情况的监控 YH Zhu
• 通过 InputFormatSourceFunction 实现flink 实时读取 ftp 的文件时，获取下一个 split 切片失败， Px New
  • Re: 通过 InputFormatSourceFunction 实现flink 实时读取 ftp 的文件时，获取下一个 split 切片失败， YH Zhu
• 使用hive的catalog问题 冯奇
  • Re:使用hive的catalog问题 Xuyang
  • 回复：使用hive的catalog问题 冯奇
  • Re:回复：使用hive的catalog问题 Xuyang
  • Re: 回复：使用hive的catalog问题 Feng Jin
  • 回复：回复：使用hive的catalog问题 冯奇
  • Re:回复：回复：使用hive的catalog问题 Xuyang
• 来自kingdomad的邮件 kingdomad
  • Re:来自kingdomad的邮件 kingdomad
  • Re:来自kingdomad的邮件 张胜军
• Re: Flink Standalone-ZK-HA模式下，CLi任务提交 Zhanghao Chen
  • 回复：Flink Standalone-ZK-HA模式下，CLi任务提交 love_h1...@126.com
• Flink在HA模式，重启ZK集群，客户端任务提交异常 love_h1...@126.com
  • 回复：Flink在HA模式，重启ZK集群，客户端任务提交异常 wjw_bigd...@163.com
• java.lang.OutOfMemory:null 冯路路
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.9.0 released Gyula Fóra
  • Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.9.0 released Őrhidi Mátyás
• flink1.18 on yarn提交任务生成多个application Liu Join
  • Re:flink1.18 on yarn提交任务生成多个application Xuyang
  • 回复: Re:flink1.18 on yarn提交任务生成多个application Liu Join
  • Re:回复: Re:flink1.18 on yarn提交任务生成多个application Xuyang
  • 回复: Re:回复: Re:flink1.18 on yarn提交任务生成多个application Liu Join
• 这绝对算是bug Cuixb
  • Re: 这绝对算是bug Zhanghao Chen
  • Re: 这绝对算是bug Cuixb
  • ????????????????bug wjw_bigd...@163.com
  • ????????????????bug wjw_bigd...@163.com
  • Re: 这绝对算是bug rui chen
  • Re: 这绝对算是bug Cuixb
  • 回复：这绝对算是bug wjw_bigd...@163.com
  • Re: 这绝对算是bug Yan Zhou
• 回复：cdc读取oracle数据如何解析 15868861416
  • 回复：cdc读取oracle数据如何解析 wjw_bigd...@163.com
  • Re: 回复：cdc读取oracle数据如何解析 Yanquan Lv
  • 回复： cdc读取oracle数据如何解析 15868861416
  • 回复：退订 费文杰
  • ?????????? wjw_bigd...@163.com
  • Re: Re：cdc读取oracle数据如何解析 Yanquan Lv
  • 退订 张胜军
  • 回复：退订 wjw_bigdata
• Flink AsyncWriter如何进行固定速率的限速？这一块似乎有bug jinzhuguang
• Re: Flink如何做到动态关联join多张维度表中的n张表？ xiaohui zhang
• [ANNOUNCE] Apache Flink CDC 3.1.1 released Qingsheng Ren
  • Re: [ANNOUNCE] Apache Flink CDC 3.1.1 released Leonard Xu
  • Re: [ANNOUNCE] Apache Flink CDC 3.1.1 released Paul Lam
• flink checkpoint 延迟的性能问题讨论 15868861416
• Flink????????????????join??????????????n?????? ????
  • ??????Flink????????????????join??????????????n?????? ????
  • ??????Flink????????????????join??????????????n?????? ????
  • Re: Flink如何做到动态关联join多张维度表中的n张表？ xiaohui zhang
• flink cdc 3.0 schema变更问题 zapjone
  • Re: flink cdc 3.0 schema变更问题 Xiqian YU
  • Re: flink cdc 3.0 schema变更问题 Yanquan Lv
• changelogstream删除问题 zapjone
  • Re:changelogstream删除问题 Xuyang
• 使用hbase连接器插入数据，一个列族下有多列时如何只更新其中一列 谢县东
  • Re:使用hbase连接器插入数据，一个列族下有多列时如何只更新其中一列 zboyu0104
  • Re: 使用hbase连接器插入数据，一个列族下有多列时如何只更新其中一列 xiaohui zhang
  • 回复： 使用hbase连接器插入数据，一个列族下有多列时如何只更新其中一列 15868861416
• 请问flink sql作业如何给kafka source table消费限速? casel.chen
  • Re: 请问flink sql作业如何给kafka source table消费限速? Alex Ching
  • Re:Re: 请问flink sql作业如何给kafka source table消费限速? casel.chen
  • Re:Re:Re: 请问flink sql作业如何给kafka source table消费限速? Xuyang
• Flink Datastream实现删除操作 zapjone
  • 答复: Flink Datastream实现删除操作 Xiqian YU
• Re: 【求助】关于 Flink ML 迭代中使用keyBy算子报错 Xiqian YU
• flink sqlgateway 提交sql作业如何设置组账号 阿华田

• 较舊的信息