user-zh

日期索引

2022/11/28 Re: 怎样从flink执行计划json生成StreamGraph? yidan zhao
2022/11/28 flink sql有办法获取到rowkind元数据字段吗？ casel.chen
2022/11/28 flink sql作业无缝升级问题 casel.chen
2022/11/28 flink sql接cdc数据源按最新数据统计问题 casel.chen
2022/11/28 Flink Kubernetes Operator何时会保留JobManager hjw
2022/11/28 回复：请问flink metrics如何获取任务状态？ m17610775726_1
2022/11/28 Flink Kubernetes Operator何时会保留JobManager Pod hjw
2022/11/28 请问flink sql可以被捕获异常吗？陈佳豪
2022/11/28 Re:Re: Flink Kubernetes Operator何时会保留JobManager Pod hjw
2022/11/28 Re:Re: 回复: FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里左岩
2022/11/28 如果一个hive 数据库同时有hudi表和parquet，需要注册两个catalog？ melin li
2022/11/27 Re: Flink Kubernetes Operator何时会保留JobManager Pod Biao Geng
2022/11/27 Flink Kubernetes Operator何时会保留JobManager Pod hjw
2022/11/27 Re:回复：请问flink metrics如何获取任务状态？陈佳豪
2022/11/27 Re:回复：请问flink metrics如何获取任务状态？陈佳豪
2022/11/27 回复：请问flink metrics如何获取任务状态？陈佳豪
2022/11/27 怎样从flink执行计划json生成StreamGraph? casel.chen
2022/11/27 请问flink metrics如何获取任务状态？陈佳豪
2022/11/25 如何扩展flink sql以实现延迟调用？ casel.chen
2022/11/25 Flink jdbc base-url 格式限制探讨 melin li
2022/11/25 [ANNOUNCE] Apache Flink 1.15.3 released Fabian Paul
2022/11/25 Re: 支持oracle、sqlserver、db2 jdbc catalog melin li
2022/11/25 flink-kafka-connector 消费时获取不到topic-paitition 朱文忠
2022/11/25 Re: Pyflink提交 Xingbo Huang
2022/11/25 Re: Pyflink提交 Dian Fu
2022/11/25 flink 1.15.3 已发布，但 maven repo 库中，暂无 1.15.3 的依赖 highfei2011
2022/11/25 Pyflink提交程龙
2022/11/24 Re: debezium-json数据timestamp类型时区问题 Leonard Xu
2022/11/24 Re: flink 新特性 guozhi mang
2022/11/24 flink 新特性 guanyq
2022/11/24 支持oracle、sqlserver、db2 jdbc catalog melin li
2022/11/24 回复：如何能正确的获取任务总写入量？ JasonLee
2022/11/24 Re: 回复：Flink HIve 文件压缩报错 yuxia
2022/11/23 Re: flink作业提交运行后如何监听作业状态发生变化？ TonyChen
2022/11/23 如何使用flink sql优雅的处理大量嵌套if-else逻辑 casel.chen
2022/11/23 Re:Re: flink作业提交运行后如何监听作业状态发生变化？ casel.chen
2022/11/23 Re: flink作业提交运行后如何监听作业状态发生变化？ Yang Wang
2022/11/23 Re: Optimize ApplicationDeployer API design melin li
2022/11/23 回复：flink作业提交运行后如何监听作业状态发生变化？ JasonLee
2022/11/23 Re: Optimize ApplicationDeployer API design Yang Wang
2022/11/23 Re: flink作业提交运行后如何监听作业状态发生变化？ TonyChen
2022/11/23 Re:Re:flink作业提交运行后如何监听作业状态发生变化？ casel.chen
2022/11/23 Re:Re: 如何扩展flink sql以支持CTAS/CDAS语句？ casel.chen
2022/11/23 动态按需注册catalog melin li
2022/11/23 Optimize ApplicationDeployer API design melin li
2022/11/23 Support Stored procedures melin li
2022/11/22 Re: Re: Flink启动python任务异常：undefined symbol: _Py_LegacyLocaleDetected Xingbo Huang
2022/11/22 Re:Re:Re: Flink启动python任务异常：undefined symbol: _Py_LegacyLocaleDetected RS
2022/11/22 Re: 如何扩展flink sql以支持CTAS/CDAS语句？ Shengkai Fang
2022/11/22 Re:flink作业提交运行后如何监听作业状态发生变化？ RS
2022/11/22 Re:Re: Flink启动python任务异常：undefined symbol: _Py_LegacyLocaleDetected RS
2022/11/22 flink作业提交运行后如何监听作业状态发生变化？ casel.chen
2022/11/22 如何扩展flink sql以支持CTAS/CDAS语句？ casel.chen
2022/11/22 如何扩展flink sql以支持CTAS/CDAS语句？ casel.chen
2022/11/22 如何正确扩展jdbc connector以支持更多的数据库方言？ casel.chen
2022/11/22 debezium-json数据timestamp类型时区问题 Kyle Zhang
2022/11/21 Re: Flink启动python任务异常：undefined symbol: _Py_LegacyLocaleDetected Xingbo Huang
2022/11/21 Flink启动python任务异常：undefined symbol: _Py_LegacyLocaleDetected RS
2022/11/21 Re: 关于LocalTransportException的优化方向咨询 yidan zhao
2022/11/21 Re: flink1.15.2无论blob.server.port设置什么端口范围，都会报错 yidan zhao
2022/11/21 退订李朋
2022/11/20 Re: flink sql 类型转化遇到转化失败时候可以跳过这条数据嘛 Shuo Cheng
2022/11/20 Re: 关于LocalTransportException的优化方向咨询 yidan zhao
2022/11/18 Re: 关于LocalTransportException的优化方向咨询 Rui Fan
2022/11/17 Re: 关于LocalTransportException的优化方向咨询 yidan zhao
2022/11/17 退订王翔
2022/11/16 Re: flinksql join Zhiwen Sun
2022/11/16 Re: flinksql join Jason_H
2022/11/15 退订 jack zhang
2022/11/14 Re:Re: Flink CDC2.2.1 设置server id范围 casel.chen
2022/11/14 Re: flink 1.16 kafka 流和自定义流collect后，watermark 消失 Tony Wei
2022/11/14 Re: flinksql join Jason_H
2022/11/14 Re: flinksql join Jason_H
2022/11/14 Re:flinksql join RS
2022/11/13 flink 1.16 kafka 流和自定义流collect后，watermark 消失 Peihui He
2022/11/11 Re: 来自古月的邮件 JunRui Lee
2022/11/10 Re: flinksql join Jason_H
2022/11/10 Re: flinksql join Jason_H
2022/11/10 Re: flinksql join Jason_H
2022/11/10 Re: flinksql join Zhiwen Sun
2022/11/10 来自古月的邮件古月
2022/11/10 flinksql join Jason_H
2022/11/10 Re: [ACCOUNCE] Apache Flink Elasticsearch Connector 3.0.0 released Ryan Skraba
2022/11/10 Re: [ACCOUNCE] Apache Flink Elasticsearch Connector 3.0.0 released Leonard Xu
2022/11/10 Re: [ACCOUNCE] Apache Flink Elasticsearch Connector 3.0.0 released Martijn Visser
2022/11/10 [ACCOUNCE] Apache Flink Elasticsearch Connector 3.0.0 released Chesnay Schepler
2022/11/09 Re: batch mode如何同步等待执行结果 weijie guo
2022/11/09 Re: FeatHub - 一个基于Flink的开源实时特征工程平台 Dong Lin
2022/11/09 Re:FeatHub - 一个基于Flink的开源实时特征工程平台 kanata163
2022/11/08 Re: batch mode如何同步等待执行结果唐世伟
2022/11/08 Re: batch mode如何同步等待执行结果 yuxia
2022/11/08 batch mode如何同步等待执行结果唐世伟
2022/11/07 Re: Remote system has been silent for too long. (more than 48.0 hours) Guo Thompson
2022/11/07 FeatHub - 一个基于Flink的开源实时特征工程平台 Dong Lin
2022/11/07 flink sql作业动态设置告警规则问题 casel.chen
2022/11/07 Re: 设置slot是vcore的几倍会有什么影响 Yanfei Lei
2022/11/07 Re: flink on k8s 提交作业，使用 oss 作为 checkpoint 地址，但找不到 oss Lijie Wang
2022/11/07 Re: flink cdc 全量拉取阶段, 会等所有的chunk 都拉取成功后, 才output到下游吗? Guo Thompson
2022/11/06 Re: 回复: FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里 Shengkai Fang
2022/11/06 Re:flink-sql读取kafka Source并行度问题 Xuyang
2022/11/04 Re:回复: FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里左岩
2022/11/04 flink cdc 全量拉取阶段, 会等所有的chunk 都拉取成功后, 才output到下游吗? 郑致远
2022/11/03 FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里左岩
2022/11/02 Re: flinkcdc 读不到mysql中数据 Leonard Xu
2022/11/02 Re: flinkcdc 读不到mysql中数据 yinghua_zh
2022/11/02 flinkcdc 读不到mysql中数据左岩
2022/11/02 Re: flink1.14.5报错提示 “无法编译表程序。这是一个bug。请提交一个问题。” ron
2022/11/02 Re: Remote system has been silent for too long. (more than 48.0 hours) Weihua Hu
2022/11/02 Re: 【SQL Gateway - HiveServer2】UnsupportedOperationException: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS. yu zelin
2022/11/02 回复: Re:flink exactly once 写kafka,如果checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢? 郑致远
2022/11/01 Re: Flink CDC 打宽表 Leonard Xu
2022/11/01 Flink CDC 打宽表 Fei Han
2022/11/01 Remote system has been silent for too long. (more than 48.0 hours) casel.chen
2022/11/01 Re:flink exactly once 写kafka,如果checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢? Xuyang
2022/11/01 Re:???????????????????????????? Xuyang
2022/11/01 flink exactly once 写kafka,如果checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢? 郑致远
2022/10/31 【SQL Gateway - HiveServer2】UnsupportedOperationException: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS. QiZhu Chan
2022/10/31 Re: Flink k8s operator高可用部署Flink Session Cluster，提交job遇到异常。汪赟
2022/10/31 Re: 关于LocalTransportException的优化方向咨询 weijie guo
2022/10/31 Re:Re: Re: 关于如何得到管道中哪些源是有界和无界的问题 Guojun Li
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