user-zh  

文章索引

• Re: 设置slot是vcore的几倍会有什么影响 Yanfei Lei
• Re: flink on k8s 提交作业，使用 oss 作为 checkpoint 地址，但找不到 oss Lijie Wang
• Re:flink-sql读取kafka Source并行度问题 Xuyang
• flink cdc 全量拉取阶段, 会等所有的chunk 都拉取成功后, 才output到下游吗? 郑 致远
  • Re: flink cdc 全量拉取阶段, 会等所有的chunk 都拉取成功后, 才output到下游吗? Guo Thompson
• FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里 左岩
  • Re:回复: FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里 左岩
  • Re: 回复: FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里 Shengkai Fang
  • Re:Re: 回复: FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里 左岩
  • Re: FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里 Leonard Xu
• flinkcdc 读不到mysql中数据 左岩
  • Re: flinkcdc 读不到mysql中数据 Leonard Xu
  • Re: flinkcdc 读不到mysql中数据 yinghua_zh
• Re: flink1.14.5报错提示 “无法编译表程序。这是一个bug。请提交一个问题。” ron
• Flink CDC 打宽表 Fei Han
  • Re: Flink CDC 打宽表 Leonard Xu
• Remote system has been silent for too long. (more than 48.0 hours) casel.chen
  • Re: Remote system has been silent for too long. (more than 48.0 hours) Weihua Hu
  • Re: Remote system has been silent for too long. (more than 48.0 hours) Guo Thompson
• Re:???????????????????????????? Xuyang
• flink exactly once 写kafka,如果checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢? 郑 致远
  • Re:flink exactly once 写kafka,如果checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢? Xuyang
  • 回复: Re:flink exactly once 写kafka,如果checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢? 郑 致远
• 【SQL Gateway - HiveServer2】UnsupportedOperationException: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS. QiZhu Chan
  • Re: 【SQL Gateway - HiveServer2】UnsupportedOperationException: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS. yu zelin
• flink sql client取消sql-clients-default.yaml后那些预置catalogs建议在哪里定义呢？ casel.chen
  • Re: flink sql client取消sql-clients-default.yaml后那些预置catalogs建议在哪里定义呢？ Leonard Xu
  • Re: flink sql client取消sql-clients-default.yaml后那些预置catalogs建议在哪里定义呢？ yu zelin
• Flink CDC2.2.1 设置server id范围 Fei Han
  • Re: Flink CDC2.2.1 设置server id范围 Leonard Xu
  • Re:Re: Flink CDC2.2.1 设置server id范围 casel.chen
  • Re: Re: Flink CDC2.2.1 设置server id范围 林影
  • Re: Flink CDC2.2.1 设置server id范围 Leonard Xu
  • Re: Flink CDC2.2.1 设置server id范围 林影
  • Re:Re: Flink CDC2.2.1 设置server id范围 casel.chen
  • Re: Flink CDC2.2.1 设置server id范围 Leonard Xu
• 关于busy,idle,backpressure的指标 yidan zhao
  • Re: 关于busy,idle,backpressure的指标 weijie guo
• 关于LocalTransportException的优化方向咨询 yidan zhao
  • Re: 关于LocalTransportException的优化方向咨询 weijie guo
  • Re: 关于LocalTransportException的优化方向咨询 yidan zhao
  • Re: 关于LocalTransportException的优化方向咨询 weijie guo
  • Re: 关于LocalTransportException的优化方向咨询 yidan zhao
  • Re: 关于LocalTransportException的优化方向咨询 Rui Fan
  • Re: 关于LocalTransportException的优化方向咨询 yidan zhao
  • Re: 关于LocalTransportException的优化方向咨询 yidan zhao
• upsert kafka作为source时，消费不到kafka中的数据 左岩
  • Re: upsert kafka作为source时，消费不到kafka中的数据 Shengkai Fang
  • Re:Re: upsert kafka作为source时，消费不到kafka中的数据 左岩
  • Re: Re: upsert kafka作为source时，消费不到kafka中的数据 guozhi mang
  • Re:Re: Re: upsert kafka作为source时，消费不到kafka中的数据 左岩
  • Re: Re: Re: upsert kafka作为source时，消费不到kafka中的数据 guozhi mang
• Re: 关于如何得到管道中哪些源是有界和无界的问题 TonyChen
  • Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 weijie guo
  • Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 weijie guo
  • Re: 关于如何得到管道中哪些源是有界和无界的问题 TonyChen
  • Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 weijie guo
  • Re:Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 Guojun Li
• [ANNOUNCE] Apache Flink 1.16.0 released Xingbo Huang
  • Re: [ANNOUNCE] Apache Flink 1.16.0 released 任庆盛
  • Re: [ANNOUNCE] Apache Flink 1.16.0 released 任庆盛
  • Re: [ANNOUNCE] Apache Flink 1.16.0 released Jing Ge
• flink web ui cancel job时能否指定要不要生成savepoint? casel.chen
  • Re: flink web ui cancel job时能否指定要不要生成savepoint? Jinzhong Li
• Flink k8s operator高可用部署Flink Session Cluster，提交job遇到异常。 Young Chen
  • Re: Flink k8s operator高可用部署Flink Session Cluster，提交job遇到异常。 Weihua Hu
  • Re: Flink k8s operator高可用部署Flink Session Cluster，提交job遇到异常。 汪赟
• flinksql-redis-connector Jason_H
• flinksql 维表join Fei Han
  • Re: flinksql 维表join Lincoln Lee
• flinksql-redis插件 Jason_H
  • Re: flinksql-redis插件 Shengkai Fang
• 使用flink-operator 配置中的 taskmanager.numOfSlots 取值存在问题？ Liting Liu (litiliu)
  • 回复：使用flink-operator 配置中的 taskmanager.numOfSlots 取值存在问题？ Jason_H
  • Re: 使用flink-operator 配置中的 taskmanager.numOfSlots 取值存在问题？ Weihua Hu
• batch job 结束时， flink-k8s-operator crd 状态展示不清晰 Liting Liu (litiliu)
  • Re: batch job 结束时， flink-k8s-operator crd 状态展示不清晰 Yang Wang
• Flink SQL 问题请教 邮件帮助中心
  • Re: Flink SQL 问题请教 Leonard Xu
  • Re: Flink SQL 问题请教 yinghua_zh
  • Re: Flink SQL 问题请教 yinghua_zh
  • Re: Flink SQL 问题请教 yinghua_zh
  • Re: Re: Flink SQL 问题请教 Shengkai Fang
• 关于Sql Gateway / Rest Endpoint的Session超时时间的配置 TonyChen
  • Re: 关于Sql Gateway / Rest Endpoint的Session超时时间的配置 TonyChen
  • Re: 关于Sql Gateway / Rest Endpoint的Session超时时间的配置 Shengkai Fang
• Tumble Window 会带来反压问题吗？ macia kk
  • Re: Tumble Window 会带来反压问题吗？ yidan zhao
  • Re: Tumble Window 会带来反压问题吗？ Shammon FY
  • Re: Tumble Window 会带来反压问题吗？ macia kk
  • Re: Tumble Window 会带来反压问题吗？ macia kk
  • Re: Tumble Window 会带来反压问题吗？ yidan zhao
• Re: 怎样禁用 flink k8s operator 自动删除停止后的 pod ？ Biao Geng
• 使用flink-operator 成功生成savepoint， 但job 并未取消 Liting Liu (litiliu)
  • Re: 使用flink-operator 成功生成savepoint， 但job 并未取消 shimin huang
• 1.16什么时候release？ 谭家良
  • Re:1.16什么时候release？ Xuyang
• Re: Flink 1.15 Deduplicate之后Interval Join出错 余列冰
  • Re: Flink 1.15 Deduplicate之后Interval Join出错 Lincoln Lee
  • Re: Flink 1.15 Deduplicate之后Interval Join出错 Zhiwen Sun
• Flink 的 Taskmanager 间网络连接数、task之间的result sub partition 数对任务性能的影响。 yidan zhao
• [ANNOUNCE] Apache Flink Table Store 0.2.1 released Jingsong Lee
  • Re: [ANNOUNCE] Apache Flink Table Store 0.2.1 released Martijn Visser
• Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序 Zhiwen Sun
  • 回复: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序 仙路尽头谁为峰
  • Re: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序 Shuo Cheng
  • Re: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序 yidan zhao
  • Re: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序 Zhiwen Sun
  • Re: Flink SQL 中同时写入多个 sink 时，是否能够保证先后次序 Zhiwen Sun
• flink cdc什么时候支持flink 1.15.x? casel.chen
  • Re:flink cdc什么时候支持flink 1.15.x? Xuyang
• Flink sql从ck恢复，统计数据波动问题 天下五帝东
  • Re: Flink sql从ck恢复，统计数据波动问题 Hangxiang Yu
  • Re: Flink sql从ck恢复，统计数据波动问题 Congxian Qiu
  • Re: Flink sql从ck恢复，统计数据波动问题 yidan zhao
  • Fwd: Flink sql从ck恢复，统计数据波动问题 天下五帝东
  • 回复：Flink sql从ck恢复，统计数据波动问题 JasonLee
• flink sql cdc 2.2.1消费mysql binlog异常 casel.chen
• OutOfMemoryError: Direct buffer memory RS
  • Re:OutOfMemoryError: Direct buffer memory allanqinjy
  • Re: OutOfMemoryError: Direct buffer memory yanfei lei
  • Re:Re: OutOfMemoryError: Direct buffer memory RS
  • Re: Re: OutOfMemoryError: Direct buffer memory yanfei lei
• Flink Forward Asia 2022 议题征集 王翔
  • Re: Flink Forward Asia 2022 议题征集 Steven 王昱翔
• table store 和connector-kafka包冲突吗？ RS
  • Re: table store 和connector-kafka包冲突吗？ Shammon FY
  • Re:Re: table store 和connector-kafka包冲突吗？ RS
  • Re: Re: table store 和connector-kafka包冲突吗？ yanfei lei
  • Re:Re: Re: table store 和connector-kafka包冲突吗？ RS
  • 回复： Re: table store 和connector-kafka包冲突吗？ 李宇彬
  • Re: Re: table store 和connector-kafka包冲突吗？ Jingsong Li
  • Re: Re: table store 和connector-kafka包冲突吗？ Jingsong Li
• [ANNOUNCE] Apache Flink Kubernetes Operator 1.2.0 released Gyula Fóra
• 提交新的flink-sql的最佳方案是什么？ Zeguang ZHANG
  • Re: 提交新的flink-sql的最佳方案是什么？ Geng Biao
• Re:Hive提交分区异常，Caused by: java.io.FileNotFoundException: /tmp/... (No such file or directory) RS
• 如何实现flink作业失败实时通知告警？ casel.chen
  • Re:如何实现flink作业失败实时通知告警？ RS
• 依赖flink cdc如何达到kafka connect with schema registry效果？ casel.chen
• 如何处理Flink KafkaSource的异常的数据 Summer
  • Re:如何处理Flink KafkaSource的异常的数据 RS
• Re: [ANNOUNCE] Apache Flink 1.14.6 released Jingsong Li
• Flink作业算子uid修复 BIGO
  • Re: Flink作业算子uid修复 zilong xiao
  • Re: [*Newsletter*] Flink作业算子uid修复 BIGO
• Re: Flink任务异常停止 Lijie Wang
• PartitionNotFoundException yidan zhao
  • Re: PartitionNotFoundException yidan zhao
  • Re: PartitionNotFoundException yidan zhao
  • Re: PartitionNotFoundException Shammon FY
  • Re: PartitionNotFoundException yidan zhao
  • Re: PartitionNotFoundException Lijie Wang
  • Re: PartitionNotFoundException yidan zhao
  • Re: PartitionNotFoundException Shammon FY
  • Re: PartitionNotFoundException Shammon FY
  • Re: PartitionNotFoundException yidan zhao
  • Re: Re: PartitionNotFoundException Shammon FY
  • Re: Re: PartitionNotFoundException Weihua Hu
• 控制流方式能否改变作业ExecutionGraph? casel.chen
  • Re:控制流方式能否改变作业ExecutionGraph? Xuyang
• flink cdc能否同步DDL语句? casel.chen
  • Re:flink cdc能否同步DDL语句? Xuyang
  • Re: flink cdc能否同步DDL语句? yh z
  • Re: flink cdc能否同步DDL语句? yuxia
  • Re:Re: flink cdc能否同步DDL语句? casel.chen
  • Re: Re: flink cdc能否同步DDL语句? Shengkai Fang
• flink cdc同只步表的schema到下游kafka topic吗？ casel.chen
• flink cdc + kafka场景下增加kafka分区数问题 casel.chen
  • Re: flink cdc + kafka场景下增加kafka分区数问题 yidan zhao
  • Re:Re: flink cdc + kafka场景下增加kafka分区数问题 casel.chen
  • 回复：flink cdc + kafka场景下增加kafka分区数问题 JasonLee
• flink的消费速率是否可以调整 Jason_H
  • 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

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