user-zh

日期索引

2022/10/03 Re: 提交新的flink-sql的最佳方案是什么？ Geng Biao
2022/10/03 提交新的flink-sql的最佳方案是什么？ Zeguang ZHANG
2022/09/30 Re:如何实现flink作业失败实时通知告警？ RS
2022/09/30 Re:Hive提交分区异常，Caused by: java.io.FileNotFoundException: /tmp/... (No such file or directory) RS
2022/09/29 如何实现flink作业失败实时通知告警？ casel.chen
2022/09/29 Re: PartitionNotFoundException Shammon FY
2022/09/29 依赖flink cdc如何达到kafka connect with schema registry效果？ casel.chen
2022/09/28 Re: PartitionNotFoundException yidan zhao
2022/09/28 Re: PartitionNotFoundException Lijie Wang
2022/09/28 如何处理Flink KafkaSource的异常的数据 Summer
2022/09/28 Re: [ANNOUNCE] Apache Flink 1.14.6 released Jingsong Li
2022/09/28 Re: PartitionNotFoundException yidan zhao
2022/09/28 Re: PartitionNotFoundException Shammon FY
2022/09/28 Re: [*Newsletter*] Flink作业算子uid修复 BIGO
2022/09/27 Re: Flink作业算子uid修复 zilong xiao
2022/09/27 Flink作业算子uid修复 BIGO
2022/09/27 Re: Flink任务异常停止 Lijie Wang
2022/09/27 Re: flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? yidan zhao
2022/09/27 Re: PartitionNotFoundException yidan zhao
2022/09/27 Re: PartitionNotFoundException yidan zhao
2022/09/27 PartitionNotFoundException yidan zhao
2022/09/26 回复：flink cdc + kafka场景下增加kafka分区数问题 JasonLee
2022/09/26 控制流方式能否改变作业ExecutionGraph? casel.chen
2022/09/26 Re:Re: flink的消费速率是否可以调整 casel.chen
2022/09/26 Re:Re: flink cdc + kafka场景下增加kafka分区数问题 casel.chen
2022/09/26 Re: flink cdc + kafka场景下增加kafka分区数问题 yidan zhao
2022/09/26 Re: flink的消费速率是否可以调整 yidan zhao
2022/09/26 flink cdc能否同步DDL语句? casel.chen
2022/09/26 flink cdc同只步表的schema到下游kafka topic吗？ casel.chen
2022/09/26 flink cdc + kafka场景下增加kafka分区数问题 casel.chen
2022/09/25 flink的消费速率是否可以调整 Jason_H
2022/09/25 Re:咨询多条flink cdc作业消费同一个库下不同表优化方案 Xuyang
2022/09/25 咨询多条flink cdc作业消费同一个库下不同表优化方案 casel.chen
2022/09/25 flink cdc作业是否支持将湖表作为源表source? casel.chen
2022/09/23 Re: StreamTableEnvironment.fromDataStream(dataStream)如何生成T类型的Schema? Shammon FY
2022/09/23 Re: Re: flink实时双流驱动join问题 Zhiwen Sun
2022/09/22 Re: StreamTableEnvironment.fromDataStream(dataStream)如何生成T类型的Schema? Shammon FY
2022/09/22 Re:Re: flink实时双流驱动join问题 casel.chen
2022/09/22 Re:Re: 关于Managed Memory的疑问 haishui
2022/09/22 Re: 并行度>1时实时写入hive partition table且开启了checkpoint没有同步信息到metastore yuxia
2022/09/22 Re: 关于Managed Memory的疑问 Shammon FY
2022/09/21 关于Managed Memory的疑问 haishui
2022/09/21 Re: 并行度>1时实时写入hive partition table且开启了checkpoint没有同步信息到metastore yuxia
2022/09/21 Re: Flink 的大Hive 维度表 yuxia
2022/09/21 Flink 的大Hive 维度表 macia kk
2022/09/21 Re: flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? yanfei lei
2022/09/21 Re: native k8s部署模式下使用HA架构的HDFS集群无法正常连接 Yang Wang
2022/09/21 Re: native k8s部署模式下使用HA架构的HDFS集群无法正常连接 yanfei lei
2022/09/21 Re: flink sql中如何对于hive进行hive的参数set yuxia
2022/09/21 Re: Flink+Hudi:java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V Summer
2022/09/21 Re: Flink-1.15 HiveDynamicTableFactory 取Catalog使用 yuxia
2022/09/21 Re:Flink-1.15 HiveDynamicTableFactory 取Catalog使用 Xuyang
2022/09/21 Re:native k8s部署模式下使用HA架构的HDFS集群无法正常连接 Xuyang
2022/09/21 Re:Re: 某作业计算算子处于busy状态 Xuyang
2022/09/21 native k8s部署模式下使用HA架构的HDFS集群无法正常连接 Tino Hean
2022/09/20 Re: 某作业计算算子处于busy状态杨扬
2022/09/20 Re: flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? Shammon FY
2022/09/20 Flink SQL suport tfrecord format 张颖
2022/09/20 Re: flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? yh z
2022/09/20 Re: flink hybrid source问题 yh z
2022/09/20 Flink SQL suport tfrecord format 张颖
2022/09/20 flink web ui 异常问题 yidan zhao
2022/09/19 Re: flink实时双流驱动join问题 Jinzhong Li
2022/09/19 Re:flink实时双流驱动join问题 Xuyang
2022/09/19 Re:flink-sql-connector-hbase-2.2模块在shade打包时遗漏了commons-io依赖 Xuyang
2022/09/19 Re:Flink+Hudi:java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V Xuyang
2022/09/19 flink hybrid source问题 casel.chen
2022/09/19 Re: 某作业计算算子处于busy状态 yidan zhao
2022/09/19 Flink-1.15 HiveDynamicTableFactory 取Catalog使用 yanggang_it_job
2022/09/18 退订 jimandlice
2022/09/18 Re: 这里为什么会报null指针错误，和源表数据有关系吗？ yh z
2022/09/18 Flink Session模式常驻taskmanager 谭家良
2022/09/18 Re: 某作业计算算子处于busy状态杨扬
2022/09/16 flink实时双流驱动join问题 casel.chen
2022/09/16 Re: 任务启动异常导致Flink服务挂掉，无法启动Flink服务 yidan zhao
2022/09/16 回复：任务启动异常导致Flink服务挂掉，无法启动Flink服务 Summer
2022/09/16 Re: 任务启动异常导致Flink服务挂掉，无法启动Flink服务 yidan zhao
2022/09/16 回复：任务启动异常导致Flink服务挂掉，无法启动Flink服务 Summer
2022/09/15 回复：任务启动异常导致Flink服务挂掉，无法启动Flink服务小昌同学
2022/09/15 Re: 任务启动异常导致Flink服务挂掉，无法启动Flink服务 yidan zhao
2022/09/15 回复：任务启动异常导致Flink服务挂掉，无法启动Flink服务 Summer
2022/09/15 Re: 任务启动异常导致Flink服务挂掉，无法启动Flink服务 yidan zhao
2022/09/15 如何监控flink sql作业端到端延迟? casel.chen
2022/09/15 任务启动异常导致Flink服务挂掉，无法启动Flink服务 Summer
2022/09/15 flink-sql-connector-hbase-2.2模块在shade打包时遗漏了commons-io依赖 junjie.m...@goupwith.com
2022/09/15 Re: 某作业计算算子处于busy状态 yidan zhao
2022/09/15 Re: 某作业计算算子处于busy状态 yidan zhao
2022/09/15 Re: 某作业计算算子处于busy状态杨扬
2022/09/15 Re: 某作业计算算子处于busy状态 yidan zhao
2022/09/13 ????????????????????null?????????????????????????????? Asahi Lee
2022/09/13 Flink+Hudi:java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V Summer
2022/09/13 Re: 关于flink table store的疑问 yh z
2022/09/13 Re: Re:退订 zhanghao.chen
2022/09/13 Re:退订陈奉刚
2022/09/12 Re: Re: Key group is not in KeyGroupRange yidan zhao
2022/09/11 partition 李乐
2022/09/11 退订杨金勇
2022/09/10 退订 xudongjun123...@163.com
2022/09/10 退订 xudongjun123...@163.com
2022/09/09 Re: Re: 关于flink table store的疑问 Jing Ge
2022/09/09 Re:Re: 关于 UDAF 里面 ListView 的疑问 Xuyang
2022/09/09 Re:Re: 关于flink table store的疑问 Xuyang
2022/09/09 Re:这里为什么会报null指针错误，和源表数据有关系吗？ Xuyang
2022/09/09 Re:flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? Xuyang
2022/09/09 flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? 郑致远
2022/09/09 回复: Re: Key group is not in KeyGroupRange junjie.m...@goupwith.com
2022/09/09 Re: Re: Key group is not in KeyGroupRange junjie.m...@goupwith.com
2022/09/09 Re: Key group is not in KeyGroupRange yue ma
2022/09/09 ??????Key group is not in KeyGroupRange ????
2022/09/09 Key group is not in KeyGroupRange junjie.m...@goupwith.com
2022/09/09 ??????Re: ???????????????????????? ????
2022/09/09 Re:回复：Re: 用什么工具展示实时报表？郑垚（ZhengYao）
2022/09/08 ??????????????null?????????????????????????????? Asahi Lee
2022/09/08 Re: 触发savepoint后, source算子会从对应offset处停止消费吗? yh z
2022/09/08 触发savepoint后, source算子会从对应offset处停止消费吗? 郑致远
2022/09/08 Re:Re: Re: 关于keyby()如何保留原并行度的问题 haishui
2022/09/08 Re: Re: 关于keyby()如何保留原并行度的问题 junjie.m...@goupwith.com
2022/09/08 Re: 关于keyby()如何保留原并行度的问题 r pp
2022/09/08 Re: 关于flink table store的疑问 r pp
2022/09/07 关于keyby()如何保留原并行度的问题 junjie.m...@goupwith.com
2022/09/07 Re: 关于 UDAF 里面 ListView 的疑问 Zhiwen Sun
2022/09/07 flink 1.13 发现下游busy是0 ，上游backpressure 是100% 周虓岗
2022/09/07 关于flink table store的疑问 Kyle Zhang
2022/09/07 Re:关于 UDAF 里面 ListView 的疑问 Xuyang
2022/09/07 Re: flink作业生成保存点失败 Congxian Qiu
2022/09/07 关于 UDAF 里面 ListView 的疑问 Zhiwen Sun
2022/09/06 退订 shaojiang_2009
2022/09/06 ??????flink-1.15.2 ConfigOption package-local method kcz
2022/09/06 flink-1.15.2 ConfigOption package-local method kcz
2022/09/05 回复：flink table API使用小昌同学
2022/09/05 退订勇Steve 金
2022/09/05 Re:flink table API使用 Xuyang
2022/09/05 flink table API使用小昌同学
2022/09/04 ??????flink-1.14.4 ?????????????????? kcz
2022/09/04 Re: flink-1.14.4 提示内置函数不存在 Shuo Cheng
2022/09/04 flink-1.14.4 ?????????????????? kcz
2022/09/04 Re: flink 读取多个hive表进行计算会有什么隐患吗？ yuxia
2022/09/03 questions about FLINK-27341 yidan zhao
2022/09/02 Re: hello flink yidan zhao
2022/09/02 Re: hello flink yh z
2022/09/02 Re: 基于savepoint重启作业无法保证端到端一致性 Shuo Cheng
2022/09/02 flink ????????hive?????????????????????????? ??????
2022/09/02 ???? ????
2022/09/02 ???? ????
2022/09/01 Re: 基于savepoint重启作业无法保证端到端一致性杨扬
2022/09/01 ??????Re: ???????????????????????? ????
2022/09/01 Re:Re: 用什么工具展示实时报表？郑垚（ZhengYao）
2022/09/01 Re:Re:Flink1.15.1读取Tidb6，sql-client执行select count异常 java.sql.SQLSyntaxErrorException RS
2022/09/01 Re:Flink1.15.1读取Tidb6，sql-client执行select count异常 java.sql.SQLSyntaxErrorException Xuyang
2022/09/01 Flink1.15.1读取Tidb6，sql-client执行select count异常 java.sql.SQLSyntaxErrorException RS
2022/09/01 Cannot serialize operator object class org.apache.flink.streaming.api.operators.SourceOperatorFactory yidan zhao
2022/08/31 flink on k8s的taskmanager为啥不是Replica Sets Jiacheng Jiang
2022/08/31 Re: 【flink native k8s】HA配置 taskmanager pod一直重启 Wu,Zhiheng
2022/08/31 Re: 【flink native k8s】HA配置 taskmanager pod一直重启 Yang Wang
2022/08/30 Re:【flink native k8s】HA配置 taskmanager pod一直重启 Xuyang
2022/08/30 Re:flink作业生成保存点失败 Xuyang
2022/08/30 Re:Re: Re: 关于flink的state 曲洋
2022/08/30 Re: Re: 关于flink的state yue ma
2022/08/29 Re:Re: 关于flink的state 曲洋
2022/08/29 Re: 关于flink的state yanfei lei
2022/08/29 Re:Re: 关于flink的state 曲洋
2022/08/29 Re: 关于flink的state yue ma
2022/08/29 Re:Re: Re: 关于Flink state初始化的问题曲洋
2022/08/29 关于flink的state 曲洋
2022/08/29 【flink native k8s】HA配置 taskmanager pod一直重启 Wu,Zhiheng
2022/08/29 Re: Re: 关于Flink state初始化的问题 Zhiwen Sun
2022/08/29 Re: 退订 Yuxin Tan
2022/08/29 Re: 退订 Yuxin Tan
2022/08/29 flink作业生成保存点失败 casel.chen
2022/08/29 退订廖启发
2022/08/28 退订 hihl
2022/08/28 Re: [ANNOUNCE] Apache Flink Table Store 0.2.0 released Jane Chan
2022/08/28 [ANNOUNCE] Apache Flink Table Store 0.2.0 released Jingsong Li
2022/08/28 Re:Flink Native Kubernetes Resources Requests and Limits spoon_lz
2022/08/28 ??????k8s??????application????flink????HA?????????????? hjw
2022/08/27 Re:Re:Flink Native Kubernetes Resources Requests and Limits casel.chen
2022/08/27 k8s环境下application模式flink作业HA的原理是什么？ casel.chen
2022/08/26 Re:Re: Re: Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0 gulugulucxg
2022/08/26 Re:Re: 基于savepoint重启作业无法保证端到端一致性 gulugulucxg
2022/08/26 Re: 基于savepoint重启作业无法保证端到端一致性杨扬
2022/08/26 Re: 基于savepoint重启作业无法保证端到端一致性 Hangxiang Yu
2022/08/26 Re: 请教下flink源码分支和tag的命名 Weihua Hu
2022/08/26 Re: Re: Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0 Weihua Hu
2022/08/26 基于savepoint重启作业无法保证端到端一致性杨扬
2022/08/25 咨询下大家访问jira、github慢咋解决的都。 yidan zhao
2022/08/25 Re: 请问 taskmanger.host 和 taskmanager.bind-host 的区别是什么呢？ yidan zhao
2022/08/25 Re: 请问 taskmanger.host 和 taskmanager.bind-host 的区别是什么呢？ yidan zhao
2022/08/25 请问 taskmanger.host 和 taskmanager.bind-host 的区别是什么呢？ yidan zhao
2022/08/25 Re:Re: 关于Flink state初始化的问题曲洋
2022/08/25 Re: HA模式，standalone集群，仅单个 JM 情况下任务异常。 yidan zhao
2022/08/25 Re: 关于Flink state初始化的问题 Hangxiang Yu
2022/08/25 Re: HA模式，standalone集群，仅单个 JM 情况下任务异常。 yidan zhao
2022/08/25 关于Flink state初始化的问题曲洋
2022/08/25 Re: 请教下flink源码分支和tag的命名 yidan zhao
2022/08/25 Re: HA模式，standalone集群，仅单个 JM 情况下任务异常。 yidan zhao
2022/08/25 Re: pyflink内存管理 zhanghao.chen
2022/08/25 Re: 退订 zhanghao.chen
2022/08/25 Re:Re: Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0 gulugulucxg
2022/08/25 Re: Flink Kafka Sink Error: org.apache.kafka.common.errors.UnsupportedVersionException: Attempted to write a non-default producerId at version 0 Weihua Hu
2022/08/25 退订柳懿珊