user-zh  

文章索引

• • Re:what time support java17 ? jiangjiguang719
  • Re:Re:what time support java17 ? Xuyang
  • Re:Re:Re:what time support java17 ? jiangjiguang719
• jobmanager 与taskmanager间的对象传递 [email protected]
  • Re: jobmanager 与taskmanager间的对象传递 Yunfeng Zhou
• flink sql????????????GroupWindowAggregate???????????????? ????
  • Re: flink sql生成执行图中GroupWindowAggregate算子数不符合预期 Shengkai Fang
• flink ????Managed Memory???? ??????
  • Re: flink 关于Managed Memory疑惑 Lijie Wang
  • Re: flink 关于Managed Memory疑惑 Lijie Wang
• flink sql解析kafka数据 小昌同学
  • Re:flink sql解析kafka数据 Xuyang
  • 回复：flink sql解析kafka数据 JasonLee
  • Re: flink sql解析kafka数据 林影
  • Re:flink sql解析kafka数据 RS
• 使用lombok生成的pojo对象是否支持State Schema Evolution Howie Yang
  • Re:使用lombok生成的pojo对象是否支持State Schema Evolution Xuyang
  • Re:Re:使用lombok生成的pojo对象是否支持State Schema Evolution Howie Yang
• flink on k8s??application???? ??????
  • flink on k8s??application???? ??????
  • Re: flink on k8s的application模式 Weihua Hu
• IDEA尝试编译最新flink源码报错 Howie Yang
  • Re:IDEA尝试编译最新flink源码报错 Howie Yang
  • Re: IDEA尝试编译最新flink源码报错 Weihua Hu
• flink1.13.2 -> 1.13.6 任务cpu从50%左右飙升到1000%，window算子故障。 yidan zhao
  • Re: flink1.13.2 -> 1.13.6 任务cpu从50%左右飙升到1000%，window算子故障。 Shengkai Fang
  • Re: flink1.13.2 -> 1.13.6 任务cpu从50%左右飙升到1000%，window算子故障。 yidan zhao
  • Re: flink1.13.2 -> 1.13.6 任务cpu从50%左右飙升到1000%，window算子故障。 yidan zhao
  • Re: flink1.13.2 -> 1.13.6 任务cpu从50%左右飙升到1000%，window算子故障。 yidan zhao
  • Re: flink1.13.2 -> 1.13.6 任务cpu从50%左右飙升到1000%，window算子故障。 yidan zhao
• Flink-Kubernetes-operator error. Murphy, Matthew
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.1 released Gyula Fóra
  • Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.1 released Yang Wang
  • Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.1 released Gyula Fóra
• Flink k8s ???????????? hjw
  • Re: Flink k8s 作业提交流程 Lijie Wang
• flink1.15可以用jdk8吗 yidan zhao
  • Re: flink1.15可以用jdk8吗 yuxia
• 任务 cancel 失败，个别 task 一直处于 CANCELING 状态 李辉
  • Re: 任务 cancel 失败，个别 task 一直处于 CANCELING 状态 Lijie Wang
  • Re: 任务 cancel 失败，个别 task 一直处于 CANCELING 状态 Weihua Hu
• 新kafka source中如何做到忽略kafka offset呢 yidan zhao
• Flink状态过期时是否可以将其输出到日志中 haishui
  • Re: Flink状态过期时是否可以将其输出到日志中 yidan zhao
  • 回复: Flink状态过期时是否可以将其输出到日志中 haishui
  • Re: Flink状态过期时是否可以将其输出到日志中 yanfei lei
• Flink-1.15.0 消费kafka提交offset失败？ RS
  • Re: Flink-1.15.0 消费kafka提交offset失败？ Qingsheng Ren
• 来自杨柳的邮件 杨柳
  • 退订 henrylee
  • Re: 退订 yuxia
  • 来自杨柳的邮件 杨柳
• Flink消费kafka实时同步到MongoDB出现丢数据 casel.chen
  • Re: Flink消费kafka实时同步到MongoDB出现丢数据 Qingsheng Ren
• lookup join对应task无法正常恢复？ Xuchao
  • Re: lookup join对应task无法正常恢复？ Lincoln Lee
  • Re: Re: lookup join对应task无法正常恢复？ xuchao
• 来自潘明文的邮件 潘明文
  • Re: 来自潘明文的邮件 Lincoln Lee
  • Re: 来自潘明文的邮件 Weihua Hu
  • Re:Re: 来自潘明文的邮件 潘明文
  • Re: Re: 来自潘明文的邮件 Weihua Hu
• k8s ha????????????jobmanager?????????? ??????
• ????flink??????????????????checkpoint???? ??????
  • Re: 线上flink任务突然出现连续的checkpoint失败 Lijie Wang
• flink1.15中kafka source、sink对kafka-client的版本要求是否可降低 yidan zhao
  • Re: flink1.15中kafka source、sink对kafka-client的版本要求是否可降低 Qingsheng Ren
• 使用join+聚合时，checkpoint异常 [email protected]
  • Re: 使用join+聚合时，checkpoint异常 Shengkai Fang
  • Re: Re: 使用join+聚合时，checkpoint异常 [email protected]
  • Re: Re: 使用join+聚合时，checkpoint异常 Lincoln Lee
  • Re: Re: 使用join+聚合时，checkpoint异常 [email protected]
  • Re: Re: 使用join+聚合时，checkpoint异常 Lincoln Lee
  • Re:使用join+聚合时，checkpoint异常 lxk
• 如何写 flink udf 的 ut? forideal
  • Re: 如何写 flink udf 的 ut? yuxia
• 关于PyFlink的环境问题，期望得到回复。 张 兴博
  • Re: 关于PyFlink的环境问题，期望得到回复。 yuxia
  • Re: 关于PyFlink的环境问题，期望得到回复。 LuNing Wang
  • Re: 关于PyFlink的环境问题，期望得到回复。 LuNing Wong
• flink 1.10.1 flinkui ???????? ????????????cancalling?? ???????????????? ??????
  • Re: flink 1.10.1 flinkui 取消任务 任务一直处于cancalling中 很长时间才取消掉 Weihua Hu
  • ?????? flink 1.10.1 flinkui ???????? ????????????cancalling?? ???????????????? ??????
  • Re: flink 1.10.1 flinkui 取消任务 任务一直处于cancalling中 很长时间才取消掉 Lijie Wang
  • Re:flink 1.10.1 flinkui ???????? ????????????cancalling?? ???????????????? Xuyang
• flink 1.10.1 cep ????flollowdby ?????????? ????1?????????? ??????
  • Re: flink 1.10.1 cep 使用flollowdby 同一条事件 模式1会匹配多次 yue ma
• Re: flink-connector-jdbc是否支持多个values问题 Zhiwen Sun
• 关于PyFlink的开发环境问题 张 兴博
  • Re: 关于PyFlink的开发环境问题 Xingbo Huang
  • Re: 关于PyFlink的开发环境问题 Weihua Hu
• 怀疑源码中的一个方法是never reached code 朱育锋
  • Re: 怀疑源码中的一个方法是never reached code Yun Tang
  • Re: 怀疑源码中的一个方法是never reached code Jing Ge
• （无主题） 李国辉
  • （无主题） 陈鑫
• Flink k8s HA 手动删除作业deployment导致的异常 m18814122325
  • Re: Flink k8s HA 手动删除作业deployment导致的异常 Zhanghao Chen
  • Re: Flink k8s HA 手动删除作业deployment导致的异常 Yang Wang
  • Re:Re: Flink k8s HA 手动删除作业deployment导致的异常 m18814122325
• unsubscribe; 退订 [email protected]
  • Re: unsubscribe; 退订 Zhanghao Chen
• Unaligned Checkpoint 小昌同学
  • Re: Unaligned Checkpoint Zhanghao Chen
• Flink JobManager 节点 JVM Metaspace 过高 Summer
  • Re:Flink JobManager 节点 JVM Metaspace 过高 lxk
  • 回复：Flink JobManager 节点 JVM Metaspace 过高 JasonLee
• 12/04/2022 11:01:43 自动保存草稿 郑林怡
  • Re:12/04/2022 11:01:43 自动保存草稿 Xuyang
• Flink 使用interval join数据丢失疑问 lxk
  • Re: Flink 使用interval join数据丢失疑问 Shengkai Fang
  • Re:Re: Flink 使用interval join数据丢失疑问 lxk
  • Re:Re:Re: Flink 使用interval join数据丢失疑问 Xuyang
  • Re:Re:Re:Re: Flink 使用interval join数据丢失疑问 lxk
  • Re:Re:Re:Re:Re: Flink 使用interval join数据丢失疑问 Xuyang
  • Re:Re:Re:Re:Re:Re: Flink 使用interval join数据丢失疑问 lxk
  • Re:Re:Re:Re:Re:Re:Re: Flink 使用interval join数据丢失疑问 lxk
  • 回复: Re: Flink 使用interval join数据丢失疑问 [email protected]
  • Re: Re: Flink 使用interval join数据丢失疑问 Shengkai Fang
  • Re: Re: Flink 使用interval join数据丢失疑问 [email protected]
  • Re:Re: Re: Flink 使用interval join数据丢失疑问 Xuyang
  • Re:Re:Re: Re: Flink 使用interval join数据丢失疑问 lxk
  • Re: Re:Re: Re: Flink 使用interval join数据丢失疑问 Shengkai Fang
  • Re: Re:Re: Re: Flink 使用interval join数据丢失疑问 Zhiwen Sun
  • Re:Re: Re:Re: Re: Flink 使用interval join数据丢失疑问 lxk
  • Re: Re: Re:Re: Re: Flink 使用interval join数据丢失疑问 Shengkai Fang
• flinkcdc 1223681919
  • Re:flinkcdc Xuyang
• flink webui stdout???? ??????
  • Re:flink webui stdout疑惑 Xuyang
  • flink webui stdout???? ??????
  • Re: flink webui stdout疑惑 Weihua Hu
• flink k8s ha json
  • Re:flink k8s ha json
  • Re: flink k8s ha Weihua Hu
  • Re:Re: flink k8s ha json
• flink运行一段时间后TaskManager退出，报OutOfMemoryError: Metaspace [email protected]
  • Re: flink运行一段时间后TaskManager退出，报OutOfMemoryError: Metaspace Lijie Wang
• Re: [DISCUSS] Update Scala 2.12.7 to 2.12.15 Martijn Visser
  • Re: [DISCUSS] Update Scala 2.12.7 to 2.12.15 Ran Tao
• sql-client pyexec参数生效疑问 RS
  • Re: sql-client pyexec参数生效疑问 Dian Fu
  • Re:Re: sql-client pyexec参数生效疑问 RS
  • RE: Re:Re: sql-client pyexec参数生效疑问 kung harold
• kafka数据落地到Hive/Filesystem（orc/parquet格式）的疑问 谭家良
  • Re: kafka数据落地到Hive/Filesystem（orc/parquet格式）的疑问 yuxia
  • Re:kafka数据落地到Hive/Filesystem（orc/parquet格式）的疑问 RS
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released Yang Wang
  • Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released rui fan
  • Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released tison
  • Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released Jing Ge
  • ?????? [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released ????
  • Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released Aitozi
  • Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released John Gerassimou
  • Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.0.0 released Lijie Wang
• [ANNOUNCE] Welcome to join the Apache Flink community on Slack Xintong Song
  • Re: [ANNOUNCE] Welcome to join the Apache Flink community on Slack Jark Wu
  • Re: [ANNOUNCE] Welcome to join the Apache Flink community on Slack Jingsong Li
  • Re: [ANNOUNCE] Welcome to join the Apache Flink community on Slack Martijn Visser
  • Re: [ANNOUNCE] Welcome to join the Apache Flink community on Slack Jing Ge
  • Re: [ANNOUNCE] Welcome to join the Apache Flink community on Slack Yuan Mei
  • Re: [ANNOUNCE] Welcome to join the Apache Flink community on Slack Jing Ge
• Flink写入CK数据丢失问题 lxk
  • Re:Flink写入CK数据丢失问题 lxk
  • Re: Flink写入CK数据丢失问题 yue ma
  • Re: Re: Flink写入CK数据丢失问题 [email protected]
• 实现SupportsFilterPushDown接口过程中遇到的问题 朱育锋
  • Re:实现SupportsFilterPushDown接口过程中遇到的问题 Xuyang
  • Re: 实现SupportsFilterPushDown接口过程中遇到的问题 Shengkai Fang
  • Re: 实现SupportsFilterPushDown接口过程中遇到的问题 朱育锋
  • Re:Re: 实现SupportsFilterPushDown接口过程中遇到的问题 Xuyang
  • Re: Re: 实现SupportsFilterPushDown接口过程中遇到的问题 Shengkai Fang
• 关于flinksql聚合函数实现的学习疑问 [email protected]
  • Re: 关于flinksql聚合函数实现的学习疑问 Lincoln Lee
  • Re: 关于flinksql聚合函数实现的学习疑问 陈铜玖
  • Re:关于flinksql聚合函数实现的学习疑问 Xuyang
• flink key by 逻辑疑问 Peihui He
  • Re: flink key by 逻辑疑问 yidan zhao
  • Re: flink key by 逻辑疑问 Shengkai Fang
  • Re:flink key by 逻辑疑问 Xuyang
• Flink-1.15.0 在使用cumulate window报key group 不在范围内的错误 zhangbin
  • Re: Flink-1.15.0 在使用cumulate window报key group 不在范围内的错误 godfrey he
  • Re: Flink-1.15.0 在使用cumulate window报key group 不在范围内的错误 godfrey he
• Flink异步IO使用问题 [email protected]
  • 回复: Flink异步IO使用问题 [email protected]
  • Re: Flink异步IO使用问题 Weihua Hu
• Re: flinksql关联hive维表java.lang.UnsupportedOperationException错误 Jingsong Li
  • Re: Re: flinksql关联hive维表java.lang.UnsupportedOperationException错误 Jingsong Li
• Re: 1.13.5版本sql大小64k限制bug Yun Tang
  • Re: 1.13.5版本sql大小64k限制bug godfrey he
  • Re: 1.13.5版本sql大小64k限制bug Lincoln Lee
  • Re: 1.13.5版本sql大小64k限制bug xianbin mo
• Kafka source 检测到分区变更时发生 WakeupException 邹璨
  • Re: Kafka source 检测到分区变更时发生 WakeupException Qingsheng Ren
• pyflink报错：Java gateway process exited before sending its port number RS
  • Re: pyflink报错：Java gateway process exited before sending its port number Dian Fu
  • Re:Re: pyflink报错：Java gateway process exited before sending its port number RS
• Some question with Flink state [email protected]
  • Re: Some question with Flink state Hangxiang Yu
  • Re: Re: Some question with Flink state [email protected]

• 较舊的信息
• 较新的信息