user-zh  

文章索引

• • Re:Re: ​请问是否有计划合并blink gemini到flink的计划 mack143
  • Re:Re: ​请问是否有计划合并blink gemini到flink的计划 蔡荣
• IF IS NULL 函数运行报错：NullPointerException RS
• [ANNOUNCE] Apache Flink ML 2.1.0 released Zhipeng Zhang
• 关于 storm 转 flink 的一些咨询 yidan zhao
  • Re: 关于 storm 转 flink 的一些咨询 yidan zhao
  • Re: 关于 storm 转 flink 的一些咨询 Xingbo Huang
  • Re: 关于 storm 转 flink 的一些咨询 yidan zhao
  • Re: 关于 storm 转 flink 的一些咨询 yidan zhao
  • Re: 关于 storm 转 flink 的一些咨询 Xingbo Huang
• flink web ui Checkpoints???????? ??????
  • Re: flink web ui Checkpoints显示为空 Weihua Hu
• 请教：关于如何释放 Flink Job 中某个对象持有的资源 Bruce Zu
  • Re:请教：关于如何释放 Flink Job 中某个对象持有的资源 RS
  • Re: 请教：关于如何释放 Flink Job 中某个对象持有的资源 Weihua Hu
• on k8s ????taskmanager???????????? ??????
  • Re: on k8s 部署taskmanager一直不能启动 Lijie Wang
• flink native k8s 按照文档提交任务找不到对应的集群 yidan zhao
  • Re: flink native k8s 按照文档提交任务找不到对应的集群 Yang Wang
  • Re: flink native k8s 按照文档提交任务找不到对应的集群 yidan zhao
  • Re: flink native k8s 按照文档提交任务找不到对应的集群 yidan zhao
  • Re: flink native k8s 按照文档提交任务找不到对应的集群 yidan zhao
  • Re: flink native k8s 按照文档提交任务找不到对应的集群 Yang Wang
  • Re: flink native k8s 按照文档提交任务找不到对应的集群 yidan zhao
  • Re: flink native k8s 按照文档提交任务找不到对应的集群 Yang Wang
• sql-client java.lang.ClassNotFoundException: org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat jiangjiguang719
  • Re: sql-client java.lang.ClassNotFoundException: org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat Weihua Hu
  • Re:Re: sql-client java.lang.ClassNotFoundException: org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat jiangjiguang719
  • Re: sql-client java.lang.ClassNotFoundException: org.apache.flink.formats.parquet.ParquetColumnarRowInputFormat Geng Biao
• flink-hudi-hive ynz...@163.com
  • Re: flink-hudi-hive Weihua Hu
  • Re: Re: flink-hudi-hive ynz...@163.com
  • Re: Re: flink-hudi-hive Weihua Hu
  • Re: Re: flink-hudi-hive ynz...@163.com
  • Re: Re: flink-hudi-hive Lijie Wang
• [ANNOUNCE] Apache Flink 1.15.1 released David Anderson
  • Re: [ANNOUNCE] Apache Flink 1.15.1 released Xingbo Huang
• es连接器支持lookup 李宇彬
• filesystem java.lang.ClassNotFoundException: org.apache.flink.table.planner.delegation.ParserFactory RS
  • Re: filesystem java.lang.ClassNotFoundException: org.apache.flink.table.planner.delegation.ParserFactory Weihua Hu
  • Re:Re: filesystem java.lang.ClassNotFoundException: org.apache.flink.table.planner.delegation.ParserFactory jiangjiguang719
  • Re:Re:Re: filesystem java.lang.ClassNotFoundException: org.apache.flink.table.planner.delegation.ParserFactory RS
  • Re:Re: filesystem java.lang.ClassNotFoundException: org.apache.flink.table.planner.delegation.ParserFactory RS
• Flink interval join 水印疑问 lxk
  • Re: Flink interval join 水印疑问 yidan zhao
  • Re:Re: Flink interval join 水印疑问 lxk
  • Re: Re: Flink interval join 水印疑问 yidan zhao
• 希望能够在FileSystemTableFactory中增加用以支持OutputFileConfig定义的Options，使得在flink sql中可以完成精准控制FileSink输出的文件 TonyChen
• 请教下flink的提交方式 sherlock zw
  • Re: 请教下flink的提交方式 Lijie Wang
  • Re: 请教下flink的提交方式 Weihua Hu
  • Re:请教下flink的提交方式 RS
• Flink SQL Client 解析 Protobuf Min Tu
  • Re: Flink SQL Client 解析 Protobuf Benchao Li
  • Re: Flink SQL Client 解析 Protobuf Min Tu
• 任务出现TooLongFrameException: Adjusted frame length exceeds问题 谭家良
  • Re: 任务出现TooLongFrameException: Adjusted frame length exceeds问题 Zhanghao Chen
  • 回复： 任务出现TooLongFrameException: Adjusted frame length exceeds问题 谭家良
• what time support java17 ? jiangjiguang719
  • Re:what time support java17 ? jiangjiguang719
  • Re:Re:what time support java17 ? Xuyang
  • Re:Re:Re:what time support java17 ? jiangjiguang719
• jobmanager 与taskmanager间的对象传递 ycbch...@gmail.com
  • 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异常 amber_...@qq.com.INVALID
  • Re: 使用join+聚合时，checkpoint异常 Shengkai Fang
  • Re: Re: 使用join+聚合时，checkpoint异常 amber_...@qq.com.INVALID
  • Re: Re: 使用join+聚合时，checkpoint异常 Lincoln Lee
  • Re: Re: 使用join+聚合时，checkpoint异常 amber_...@qq.com.INVALID
  • 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
• 关于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; 退订 chenshu...@foxmail.com
  • 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数据丢失疑问 lxk7...@163.com
  • Re: Re: Flink 使用interval join数据丢失疑问 Shengkai Fang
  • Re: Re: Flink 使用interval join数据丢失疑问 lxk7...@163.com
  • 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 weishishuo...@163.com
  • 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

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