user-zh  

文章索引

• • Re: flink的消费速率是否可以调整 yidan zhao
  • Re:Re: flink的消费速率是否可以调整 casel.chen
• 咨询多条flink cdc作业消费同一个库下不同表优化方案 casel.chen
  • Re:咨询多条flink cdc作业消费同一个库下不同表优化方案 Xuyang
• flink cdc作业是否支持将湖表作为源表source? casel.chen
• Re: StreamTableEnvironment.fromDataStream(dataStream)如何生成T类型的Schema? Shammon FY
  • Re: StreamTableEnvironment.fromDataStream(dataStream)如何生成T类型的Schema? Shammon FY
• 关于Managed Memory的疑问 haishui
  • Re: 关于Managed Memory的疑问 Shammon FY
  • Re:Re: 关于Managed Memory的疑问 haishui
• Re: 并行度>1时实时写入hive partition table且开启了checkpoint没有同步信息到metastore yuxia
  • Re: 并行度>1时实时写入hive partition table且开启了checkpoint没有同步信息到metastore yuxia
• Flink 的 大Hive 维度表 macia kk
  • Re: Flink 的 大Hive 维度表 yuxia
• Re: flink sql中如何对于hive进行hive的参数set yuxia
• native k8s部署模式下使用HA架构的HDFS集群无法正常连接 Tino Hean
  • Re:native k8s部署模式下使用HA架构的HDFS集群无法正常连接 Xuyang
  • Re: native k8s部署模式下使用HA架构的HDFS集群无法正常连接 yanfei lei
  • Re: native k8s部署模式下使用HA架构的HDFS集群无法正常连接 Yang Wang
• Flink SQL suport tfrecord format 张颖
  • Flink SQL suport tfrecord format 张颖
• flink web ui 异常问题 yidan zhao
• flink hybrid source问题 casel.chen
  • Re: flink hybrid source问题 yh z
• Flink-1.15 HiveDynamicTableFactory 取Catalog使用 yanggang_it_job
  • Re:Flink-1.15 HiveDynamicTableFactory 取Catalog使用 Xuyang
  • Re: Flink-1.15 HiveDynamicTableFactory 取Catalog使用 yuxia
• Flink Session模式常驻taskmanager 谭家良
• flink实时双流驱动join问题 casel.chen
  • Re:flink实时双流驱动join问题 Xuyang
  • Re: flink实时双流驱动join问题 Jinzhong Li
  • Re:Re: flink实时双流驱动join问题 casel.chen
  • Re: Re: flink实时双流驱动join问题 Zhiwen Sun
• 如何监控flink sql作业端到端延迟? casel.chen
• 任务启动异常导致Flink服务挂掉，无法启动Flink服务 Summer
  • Re: 任务启动异常导致Flink服务挂掉，无法启动Flink服务 yidan zhao
  • 回复： 任务启动异常导致Flink服务挂掉，无法启动Flink服务 Summer
  • Re: 任务启动异常导致Flink服务挂掉，无法启动Flink服务 yidan zhao
  • 回复： 任务启动异常导致Flink服务挂掉，无法启动Flink服务 Summer
  • Re: 任务启动异常导致Flink服务挂掉，无法启动Flink服务 yidan zhao
  • 回复： 任务启动异常导致Flink服务挂掉，无法启动Flink服务 Summer
  • Re: 任务启动异常导致Flink服务挂掉，无法启动Flink服务 yidan zhao
  • 回复： 任务启动异常导致Flink服务挂掉，无法启动Flink服务 小昌同学
• flink-sql-connector-hbase-2.2模块在shade打包时遗漏了commons-io依赖 [email protected]
  • Re:flink-sql-connector-hbase-2.2模块在shade打包时遗漏了commons-io依赖 Xuyang
• Re: 某作业计算算子处于busy状态 yidan zhao
  • Re: 某作业计算算子处于busy状态 杨扬
  • Re: 某作业计算算子处于busy状态 yidan zhao
  • Re: 某作业计算算子处于busy状态 yidan zhao
  • Re: 某作业计算算子处于busy状态 杨扬
  • Re: 某作业计算算子处于busy状态 yidan zhao
  • Re: 某作业计算算子处于busy状态 杨扬
  • Re:Re: 某作业计算算子处于busy状态 Xuyang
• 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 [email protected]
  • ??????Key group is not in KeyGroupRange ????
  • Re: Key group is not in KeyGroupRange yue ma
  • Re: Re: Key group is not in KeyGroupRange [email protected]
  • 回复: Re: Key group is not in KeyGroupRange [email protected]
  • 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()如何保留原并行度的问题 [email protected]
  • Re: 关于keyby()如何保留原并行度的问题 r pp
  • Re: Re: 关于keyby()如何保留原并行度的问题 [email protected]
  • 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: 用什么工具展示实时报表？ [email protected]

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