user-zh  

文章索引

• Flink+Hudi:java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V Summer
  • Re:Flink+Hudi:java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V Xuyang
  • Re: Flink+Hudi:java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V Summer
• partition 李乐
• flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? 郑 致远
  • Re:flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? Xuyang
  • Re: flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? yh z
  • Re: flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? Shammon FY
  • Re: flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? yanfei lei
  • Re: flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? yidan zhao
• Key group is not in KeyGroupRange junjie.m...@goupwith.com
  • ??????Key group is not in KeyGroupRange ????
  • Re: Key group is not in KeyGroupRange yue ma
  • Re: Re: Key group is not in KeyGroupRange junjie.m...@goupwith.com
  • 回复: Re: Key group is not in KeyGroupRange junjie.m...@goupwith.com
  • Re: Re: Key group is not in KeyGroupRange yidan zhao
• ??????????????null?????????????????????????????? Asahi Lee
  • Re:这里为什么会报null指针错误，和源表数据有关系吗？ Xuyang
  • ????????????????????null?????????????????????????????? Asahi Lee
  • Re: 这里为什么会报null指针错误，和源表数据有关系吗？ yh z
• 触发savepoint后, source算子会从对应offset处停止消费吗? 郑 致远
  • Re: 触发savepoint后, source算子会从对应offset处停止消费吗? yh z
• 关于keyby()如何保留原并行度的问题 junjie.m...@goupwith.com
  • Re: 关于keyby()如何保留原并行度的问题 r pp
  • Re: Re: 关于keyby()如何保留原并行度的问题 junjie.m...@goupwith.com
  • Re:Re: Re: 关于keyby()如何保留原并行度的问题 haishui
• flink 1.13 发现下游busy是0 ，上游backpressure 是100% 周虓岗
• 关于flink table store的疑问 Kyle Zhang
  • Re: 关于flink table store的疑问 r pp
  • Re:Re: 关于flink table store的疑问 Xuyang
  • Re: Re: 关于flink table store的疑问 Jing Ge
  • Re: 关于flink table store的疑问 yh z
• 关于 UDAF 里面 ListView 的疑问 Zhiwen Sun
  • Re:关于 UDAF 里面 ListView 的疑问 Xuyang
  • Re: 关于 UDAF 里面 ListView 的疑问 Zhiwen Sun
  • Re:Re: 关于 UDAF 里面 ListView 的疑问 Xuyang
• flink-1.15.2 ConfigOption package-local method kcz
  • ??????flink-1.15.2 ConfigOption package-local method kcz
• flink table API使用 小昌同学
  • Re:flink table API使用 Xuyang
  • 回复：flink table API使用 小昌同学
• flink-1.14.4 ?????????????????? kcz
  • Re: flink-1.14.4 提示内置函数不存在 Shuo Cheng
  • ??????flink-1.14.4 ?????????????????? kcz
• questions about FLINK-27341 yidan zhao
• Re: hello flink yh z
  • Re: hello flink yidan zhao
• flink ????????hive?????????????????????????? ??????
  • Re: flink 读取多个hive表进行计算会有什么隐患吗？ yuxia
• Flink1.15.1读取Tidb6，sql-client执行select count异常 java.sql.SQLSyntaxErrorException RS
  • Re:Flink1.15.1读取Tidb6，sql-client执行select count异常 java.sql.SQLSyntaxErrorException Xuyang
  • Re:Re:Flink1.15.1读取Tidb6，sql-client执行select count异常 java.sql.SQLSyntaxErrorException RS
• Cannot serialize operator object class org.apache.flink.streaming.api.operators.SourceOperatorFactory yidan zhao
• flink on k8s的taskmanager为啥不是Replica Sets Jiacheng Jiang
• 关于flink的state 曲洋
  • Re: 关于flink的state yue ma
  • Re:Re: 关于flink的state 曲洋
  • Re: 关于flink的state yanfei lei
  • Re:Re: 关于flink的state 曲洋
  • Re: Re: 关于flink的state yue ma
  • Re:Re: Re: 关于flink的state 曲洋
• 【flink native k8s】HA配置 taskmanager pod一直重启 Wu,Zhiheng
  • Re:【flink native k8s】HA配置 taskmanager pod一直重启 Xuyang
  • Re: 【flink native k8s】HA配置 taskmanager pod一直重启 Yang Wang
  • Re: 【flink native k8s】HA配置 taskmanager pod一直重启 Wu,Zhiheng
• flink作业生成保存点失败 casel.chen
  • Re:flink作业生成保存点失败 Xuyang
  • Re: flink作业生成保存点失败 Congxian Qiu
• [ANNOUNCE] Apache Flink Table Store 0.2.0 released Jingsong Li
  • Re: [ANNOUNCE] Apache Flink Table Store 0.2.0 released Jane Chan
• k8s环境下application模式flink作业HA的原理是什么？ casel.chen
  • ??????k8s??????application????flink????HA?????????????? hjw
• 基于savepoint重启作业无法保证端到端一致性 杨扬
  • Re: 基于savepoint重启作业无法保证端到端一致性 Hangxiang Yu
  • Re: 基于savepoint重启作业无法保证端到端一致性 杨扬
  • Re:Re: 基于savepoint重启作业无法保证端到端一致性 gulugulucxg
  • Re: 基于savepoint重启作业无法保证端到端一致性 杨扬
  • Re: 基于savepoint重启作业无法保证端到端一致性 Shuo Cheng
• 咨询下大家访问jira、github慢咋解决的都。 yidan zhao
• 请问 taskmanger.host 和 taskmanager.bind-host 的区别是什么呢？ yidan zhao
  • Re: 请问 taskmanger.host 和 taskmanager.bind-host 的区别是什么呢？ yidan zhao
  • Re: 请问 taskmanger.host 和 taskmanager.bind-host 的区别是什么呢？ yidan zhao
• 关于Flink state初始化的问题 曲洋
  • Re: 关于Flink state初始化的问题 Hangxiang Yu
  • Re:Re: 关于Flink state初始化的问题 曲洋
  • Re: Re: 关于Flink state初始化的问题 Zhiwen Sun
  • Re:Re: Re: 关于Flink state初始化的问题 曲洋
• Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0 gulugulucxg
  • Re: Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0 Weihua Hu
  • Re:Re: Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0 gulugulucxg
  • Re: Re: Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0 Weihua Hu
  • Re:Re: Re: Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0 gulugulucxg
  • ???? ????
• [ANNOUNCE] Apache Flink 1.15.2 released Danny Cranmer
  • Re: [ANNOUNCE] Apache Flink 1.15.2 released Jing Ge
  • Re: [ANNOUNCE] Apache Flink 1.15.2 released Xingbo Huang
• pyflink内存管理 yidan zhao
  • Re: pyflink内存管理 yu'an huang
  • Re: pyflink内存管理 yidan zhao
  • Re: pyflink内存管理 zhanghao.chen
• Re:升级1.14.2后作业无法启动 Xuyang
• flink1.15.1 stop 任务失败 yidan zhao
  • Re: flink1.15.1 stop 任务失败 yidan zhao
  • Re:Re: flink1.15.1 stop 任务失败 Xuyang
  • Re: Re: flink1.15.1 stop 任务失败 yidan zhao
  • Re: Re: flink1.15.1 stop 任务失败 yidan zhao
  • ?????? Re: flink1.15.1 stop ???????? hjw
  • Re: Re: flink1.15.1 stop 任务失败 yanfei lei
  • Re: Re: flink1.15.1 stop 任务失败 yidan zhao
• HA模式，standalone集群，仅单个 JM 情况下任务异常。 yidan zhao
  • Re: HA模式，standalone集群，仅单个 JM 情况下任务异常。 Weihua Hu
  • Re: HA模式，standalone集群，仅单个 JM 情况下任务异常。 yidan zhao
  • Re: HA模式，standalone集群，仅单个 JM 情况下任务异常。 yidan zhao
  • Re: HA模式，standalone集群，仅单个 JM 情况下任务异常。 yidan zhao
  • Re: HA模式，standalone集群，仅单个 JM 情况下任务异常。 yidan zhao
• flink cdc如何将捕获变更记录转成canal json格式输出到下游kafka? casel.chen
  • Re:flink cdc如何将捕获变更记录转成canal json格式输出到下游kafka? Xuyang
  • Re:Re:flink cdc如何将捕获变更记录转成canal json格式输出到下游kafka? casel.chen
  • Re:Re:Re:flink cdc如何将捕获变更记录转成canal json格式输出到下游kafka? Xuyang
• Re: akka.framesize配置问题 Weihua Hu
  • Re: akka.framesize配置问题 杨扬
  • 回复： akka.framesize配置问题 谭家良
• flink sql支持监听单个文件内容变化吗？ casel.chen
  • Re: flink sql支持监听单个文件内容变化吗？ Weihua Hu
  • Re: flink sql支持监听单个文件内容变化吗？ yu'an huang
• flink自动重启出错 Jason_H
  • Re: flink自动重启出错 zhanghao.chen
  • 回复： flink自动重启出错 Jason_H
  • 回复：flink自动重启出错 Michael Ran
  • 回复：flink自动重启出错 Jason_H
  • Re: flink自动重启出错 Hangxiang Yu
  • Re: flink自动重启出错 yue ma
  • 回复： flink自动重启出错 Jason_H
  • Re: flink自动重启出错 yue ma
  • 回复： flink自动重启出错 Jason_H
  • Re: flink自动重启出错 谢振爵
  • 回复： flink自动重启出错 Jason_H
• get state from window 曲洋
  • Re: get state from window yuxia
  • Re: get state from window yuxia
  • get state from window 曲洋
  • Re: get state from window yanfei lei
  • Re:Re: get state from window 曲洋
  • ??????get state from window xyz
• flink sink kafka exactly once???? kcz
• 用什么工具展示实时报表？ Kyle Zhang
  • Re: 用什么工具展示实时报表？ m...@sinoiov.com
  • Re: 用什么工具展示实时报表？ joey
  • Re:Re: 用什么工具展示实时报表？ 郑垚（ZhengYao）
  • ??????Re: ???????????????????????? ????
  • Re:回复：Re: 用什么工具展示实时报表？ 郑垚（ZhengYao）
  • ??????Re: ???????????????????????? ????
• Flink ????????????????Tag?????? hjw
• Flink ????????????????Tag?????? hjw
  • Re: Flink 镜像同一版本不同Tag的差异 Lijie Wang
• flink on k8s作业支持弹性扩缩容吗？ casel.chen
  • Re: flink on k8s作业支持弹性扩缩容吗？ yu'an huang
• flink on k8s作业失败后如何自动释放资源？ casel.chen
  • Re: flink on k8s作业失败后如何自动释放资源？ yu'an huang
  • Re:Re: flink on k8s作业失败后如何自动释放资源？ casel.chen
  • Re: Re:Re: flink on k8s作业失败后如何自动释放资源？ zhanghao.chen
• FlinkSqlClient创建hudi表时，未在Hive中同步创建rt、ro表 Summer
• Client启动有异常： SQL Client must stop. Unexpected exception. This is a bug. Please consider filing an issue. Summer
  • Re:Client启动有异常： SQL Client must stop. Unexpected exception. This is a bug. Please consider filing an issue. RS
  • Re:Client启动有异常： SQL Client must stop. Unexpected exception. This is a bug. Please consider filing an issue. 许学伟
• Re: 关于flink读取csv文件问题 Weihua Hu
• Oracle CDC产生大量logminer日志 Kyle Zhang
  • Re: Oracle CDC产生大量logminer日志 Weihua Hu
• flink sql ???? ????phoenix count ???? ????
  • Re:flink sql 实现 查询phoenix count 语法 Xuyang
• 看了官方文档的Versioned Table，有一些小疑惑希望可以得到解答 林影
  • Re: 看了官方文档的Versioned Table，有一些小疑惑希望可以得到解答 Leonard Xu
  • Re: 看了官方文档的Versioned Table，有一些小疑惑希望可以得到解答 林影
• Flink Native Kubernetes Resources Requests and Limits casel.chen
  • Re:Flink Native Kubernetes Resources Requests and Limits spoon_lz
  • Re:Re:Flink Native Kubernetes Resources Requests and Limits casel.chen
  • Re:Flink Native Kubernetes Resources Requests and Limits spoon_lz
• pyflink目前map、flatmap都是process实现，那么process当前如何支持sideoutput呢？ yidan zhao
  • Re: pyflink目前map、flatmap都是process实现，那么process当前如何支持sideoutput呢？ Dian Fu
• Flink 1.15 FileSink合并压缩的小文件后不可读 Wenhao Xiao
  • Flink 1.15 FileSink合并压缩的小文件后不可读 Wenhao Xiao
  • Re:Flink 1.15 FileSink合并压缩的小文件后不可读 左岩
  • Re:Flink 1.15 FileSink合并压缩的小文件后不可读 Wenhao Xiao
• 作业每次手动停止做savepoint耗时较久 Howie Yang
  • Re: 作业每次手动停止做savepoint耗时较久 Jinzhong Li
• Flink SQL 如何描述 ES（ElasticSearch）的nested字段类型？ RS
• Flink内部如何做到消息不丢失？ m18814122325
  • Re: Flink内部如何做到消息不丢失？ tison
  • Re: Flink内部如何做到消息不丢失？ yidan zhao
• Flink作业修改时State的兼容性 m18814122325
  • Re: Flink作业修改时State的兼容性 tison
  • Re: Flink作业修改时State的兼容性 Hangxiang Yu
• 关于老版本cdh兼容性问题 赵帅
  • Re: 关于老版本cdh兼容性问题 yuxia
• 接收Http请求与flink如何建立联系 张锴
  • Re:接收Http请求与flink如何建立联系 Jeff
  • Re: 接收Http请求与flink如何建立联系 yidan zhao
• flink-k8s-operator中webhook的作用 Kyle Zhang
  • Re: flink-k8s-operator中webhook的作用 Yang Wang
• hive catalog不支持jdk11 Jeff

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