user-zh

日期索引

2022/10/31 Re: 关于LocalTransportException的优化方向咨询 yidan zhao
2022/10/31 Re: flink sql client取消sql-clients-default.yaml后那些预置catalogs建议在哪里定义呢？ yu zelin
2022/10/31 Re: Flink CDC2.2.1 设置server id范围林影
2022/10/31 Re: Flink CDC2.2.1 设置server id范围 Leonard Xu
2022/10/31 Re: Flink CDC2.2.1 设置server id范围 Leonard Xu
2022/10/31 Re: Re: Flink CDC2.2.1 设置server id范围林影
2022/10/31 Re: flink sql client取消sql-clients-default.yaml后那些预置catalogs建议在哪里定义呢？ Leonard Xu
2022/10/31 flink sql client取消sql-clients-default.yaml后那些预置catalogs建议在哪里定义呢？ casel.chen
2022/10/31 Re:Re: Flink CDC2.2.1 设置server id范围 casel.chen
2022/10/31 Re: Re: Re: upsert kafka作为source时，消费不到kafka中的数据 guozhi mang
2022/10/31 Re: Flink CDC2.2.1 设置server id范围 Leonard Xu
2022/10/31 Flink CDC2.2.1 设置server id范围 Fei Han
2022/10/30 Re: 关于busy,idle,backpressure的指标 weijie guo
2022/10/30 Re: 关于LocalTransportException的优化方向咨询 weijie guo
2022/10/30 Re:Re: Re: upsert kafka作为source时，消费不到kafka中的数据左岩
2022/10/30 Re: Re: upsert kafka作为source时，消费不到kafka中的数据 guozhi mang
2022/10/30 Re:Re: upsert kafka作为source时，消费不到kafka中的数据左岩
2022/10/30 Re: upsert kafka作为source时，消费不到kafka中的数据 Shengkai Fang
2022/10/30 关于busy,idle,backpressure的指标 yidan zhao
2022/10/29 关于LocalTransportException的优化方向咨询 yidan zhao
2022/10/28 Re: [ANNOUNCE] Apache Flink 1.16.0 released Jing Ge
2022/10/28 Re: [ANNOUNCE] Apache Flink 1.16.0 released 任庆盛
2022/10/28 Re: [ANNOUNCE] Apache Flink 1.16.0 released 任庆盛
2022/10/28 upsert kafka作为source时，消费不到kafka中的数据左岩
2022/10/28 Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 weijie guo
2022/10/28 Re: 关于如何得到管道中哪些源是有界和无界的问题 TonyChen
2022/10/28 Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 weijie guo
2022/10/28 Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 weijie guo
2022/10/28 Re: 关于如何得到管道中哪些源是有界和无界的问题 TonyChen
2022/10/27 [ANNOUNCE] Apache Flink 1.16.0 released Xingbo Huang
2022/10/27 Re: Flink k8s operator高可用部署Flink Session Cluster，提交job遇到异常。 Weihua Hu
2022/10/27 Re: flink web ui cancel job时能否指定要不要生成savepoint? Jinzhong Li
2022/10/27 Re: flinksql-redis插件 Shengkai Fang
2022/10/27 flink web ui cancel job时能否指定要不要生成savepoint? casel.chen
2022/10/27 Re: flinksql 维表join Lincoln Lee
2022/10/27 Re: 使用flink-operator 配置中的 taskmanager.numOfSlots 取值存在问题？ Weihua Hu
2022/10/27 Re: Flink Forward Asia 2022 议题征集 Steven 王昱翔
2022/10/27 Flink k8s operator高可用部署Flink Session Cluster，提交job遇到异常。 Young Chen
2022/10/26 flinksql-redis-connector Jason_H
2022/10/26 flinksql 维表join Fei Han
2022/10/26 回复：使用flink-operator 配置中的 taskmanager.numOfSlots 取值存在问题？ Jason_H
2022/10/25 flinksql-redis插件 Jason_H
2022/10/25 使用flink-operator 配置中的 taskmanager.numOfSlots 取值存在问题？ Liting Liu (litiliu)
2022/10/25 Re: batch job 结束时， flink-k8s-operator crd 状态展示不清晰 Yang Wang
2022/10/25 batch job 结束时， flink-k8s-operator crd 状态展示不清晰 Liting Liu (litiliu)
2022/10/23 Re: Re: Flink SQL 问题请教 Shengkai Fang
2022/10/22 Re: Flink SQL 问题请教 yinghua_zh
2022/10/22 Re: Flink SQL 问题请教 yinghua_zh
2022/10/22 Re: Flink SQL 问题请教 yinghua_zh
2022/10/22 Re: Flink SQL 问题请教 Leonard Xu
2022/10/21 Flink SQL 问题请教邮件帮助中心
2022/10/20 Re: Tumble Window 会带来反压问题吗？ yidan zhao
2022/10/20 Re: Tumble Window 会带来反压问题吗？ macia kk
2022/10/19 Re: Tumble Window 会带来反压问题吗？ macia kk
2022/10/19 Re: Tumble Window 会带来反压问题吗？ Shammon FY
2022/10/19 Re: 关于Sql Gateway / Rest Endpoint的Session超时时间的配置 Shengkai Fang
2022/10/19 Re: Tumble Window 会带来反压问题吗？ yidan zhao
2022/10/19 Re: 关于Sql Gateway / Rest Endpoint的Session超时时间的配置 TonyChen
2022/10/19 关于Sql Gateway / Rest Endpoint的Session超时时间的配置 TonyChen
2022/10/19 Tumble Window 会带来反压问题吗？ macia kk
2022/10/19 Re: 怎样禁用 flink k8s operator 自动删除停止后的 pod ？ Biao Geng
2022/10/19 Re:1.16什么时候release？ Xuyang
2022/10/19 Re: 使用flink-operator 成功生成savepoint，但job 并未取消 shimin huang
2022/10/19 使用flink-operator 成功生成savepoint，但job 并未取消 Liting Liu (litiliu)
2022/10/19 Re: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序 Zhiwen Sun
2022/10/18 退订郑林怡
2022/10/17 退订王唯
2022/10/17 退订张立阳
2022/10/17 退订王新隆
2022/10/17 Re: Watermark generating mechanism in Flink SQL Matthias Pohl
2022/10/17 1.16什么时候release？谭家良
2022/10/17 Watermark generating mechanism in Flink SQL wang
2022/10/17 Re: Flink 1.15 Deduplicate之后Interval Join出错 Zhiwen Sun
2022/10/16 Re: 退订 Jiangang Liu
2022/10/16 回复:退订 TROY
2022/10/16 Re: Flink 1.15 Deduplicate之后Interval Join出错 Lincoln Lee
2022/10/14 Re: Flink 1.15 Deduplicate之后Interval Join出错余列冰
2022/10/13 Re: Re: flink1.15.1 stop 任务失败 yidan zhao
2022/10/13 Re: Re: flink1.15.1 stop 任务失败 yanfei lei
2022/10/13 Flink 的 Taskmanager 间网络连接数、task之间的result sub partition 数对任务性能的影响。 yidan zhao
2022/10/13 Re: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序 Zhiwen Sun
2022/10/13 Re: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序 yidan zhao
2022/10/13 Re: Re: flink cdc能否同步DDL语句? Shengkai Fang
2022/10/13 Re: 退订 Shengkai Fang
2022/10/13 Re: [ANNOUNCE] Apache Flink Table Store 0.2.1 released Martijn Visser
2022/10/12 [ANNOUNCE] Apache Flink Table Store 0.2.1 released Jingsong Lee
2022/10/12 退订陈鑫
2022/10/12 Re:flink cdc什么时候支持flink 1.15.x? Xuyang
2022/10/12 Re: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序 Shuo Cheng
2022/10/12 回复: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序仙路尽头谁为峰
2022/10/11 Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序 Zhiwen Sun
2022/10/11 Re: Re: OutOfMemoryError: Direct buffer memory yanfei lei
2022/10/11 Re: Re: table store 和connector-kafka包冲突吗？ Jingsong Li
2022/10/11 Re: Re: table store 和connector-kafka包冲突吗？ Jingsong Li
2022/10/11 回复： Re: table store 和connector-kafka包冲突吗？李宇彬
2022/10/10 回复：Flink sql从ck恢复，统计数据波动问题 JasonLee
2022/10/10 flink cdc什么时候支持flink 1.15.x? casel.chen
2022/10/10 Re:Re: flink cdc能否同步DDL语句? casel.chen
2022/10/10 Re: flink cdc能否同步DDL语句? yuxia
2022/10/10 Re: flink cdc能否同步DDL语句? yh z
2022/10/10 Re:Re: OutOfMemoryError: Direct buffer memory RS
2022/10/10 退订 13341000780
2022/10/10 Re:Re: Re: table store 和connector-kafka包冲突吗？ RS
2022/10/10 Fwd: Flink sql从ck恢复，统计数据波动问题天下五帝东
2022/10/10 退订 13341000780
2022/10/10 Re:控制流方式能否改变作业ExecutionGraph? Xuyang
2022/10/10 Re:flink cdc能否同步DDL语句? Xuyang
2022/10/10 Re: Flink sql从ck恢复，统计数据波动问题 yidan zhao
2022/10/10 Re: Flink sql从ck恢复，统计数据波动问题 Congxian Qiu
2022/10/09 Re: Flink sql从ck恢复，统计数据波动问题 Hangxiang Yu
2022/10/09 Flink sql从ck恢复，统计数据波动问题天下五帝东
2022/10/09 退订陈鑫
2022/10/09 Re: Re: table store 和connector-kafka包冲突吗？ yanfei lei
2022/10/09 Re: OutOfMemoryError: Direct buffer memory yanfei lei
2022/10/09 退订赵一文
2022/10/09 退订谭海棠
2022/10/09 flink sql cdc 2.2.1消费mysql binlog异常 casel.chen
2022/10/08 Re:OutOfMemoryError: Direct buffer memory allanqinjy
2022/10/08 OutOfMemoryError: Direct buffer memory RS
2022/10/08 Re:Re: table store 和connector-kafka包冲突吗？ RS
2022/10/07 （无主题）陈鑫
2022/10/07 Re: table store 和connector-kafka包冲突吗？ Shammon FY
2022/10/07 Flink Forward Asia 2022 议题征集王翔
2022/10/07 table store 和connector-kafka包冲突吗？ RS
2022/10/07 [ANNOUNCE] Apache Flink Kubernetes Operator 1.2.0 released Gyula Fóra
2022/10/05 Re:如何处理Flink KafkaSource的异常的数据 RS
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