user-zh

日期索引

2022/12/30 请问cancel的任务能够恢复running状态吗？陈佳豪
2022/12/29 flink任务重启后监控指标从0开始重新统计孙路昊
2022/12/28 Re:Re:Re:Re:flink sql connector options如何支持Map数据类型？ casel.chen
2022/12/27 Re:Re:Re:flink sql connector options如何支持Map数据类型？ RS
2022/12/27 Re: 退订 Lijie Wang
2022/12/26 Re:Re:flink sql connector options如何支持Map数据类型？ casel.chen
2022/12/26 退订 DannyLau
2022/12/26 Re:Re:如何查看Flink on Native K8s模式下失败作业的日志 hjw
2022/12/25 Re:如何查看Flink on Native K8s模式下失败作业的日志 RS
2022/12/25 Re:Re: 提交任务不能指定第三方jar RS
2022/12/25 Re:flink sql connector options如何支持Map数据类型？ RS
2022/12/25 Re:flink如何调用py模型 RS
2022/12/22 为何雪花算法的udf 每次执行的结果都一样，如何能像UUID一样每次变化 [email protected]
2022/12/22 如何查看Flink on Native K8s模式下失败作业的日志 hjw
2022/12/21 退订 DannyLau
2022/12/21 [ANNOUNCE] Apache flink-connector-rabbitmq 3.0.0 released Martijn Visser
2022/12/21 [ANNOUNCE] Apache flink-connector-jdbc 3.0.0 released Martijn Visser
2022/12/21 [ANNOUNCE] Apache flink-connector-pulsar 3.0.0 released Martijn Visser
2022/12/21 来自Lynn Chen的邮件 Lynn Chen
2022/12/20 RE: Re: 【PyFlink】对于数据以Csv()格式写入kafka报错，以及使用python udf时无法启动udf kung harold
2022/12/19 退订邱钺
2022/12/19 Re:Re: flink sql connector options如何支持Map数据类型？ casel.chen
2022/12/19 RE: Re:Re: sql-client pyexec参数生效疑问 kung harold
2022/12/19 关于flink sql调用python udf失败的问题 kung harold
2022/12/18 Re: flink sql connector options如何支持Map数据类型？ Weihua Hu
2022/12/18 退订爱吃鱼
2022/12/16 flink sql connector options如何支持Map数据类型？ casel.chen
2022/12/16 Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.3.0 released Biao Geng
2022/12/14 [ANNOUNCE] Apache Flink Kubernetes Operator 1.3.0 released Őrhidi Mátyás
2022/12/13 Re: HiveServer2 Endpoint只支持Hive3.1以上版本吗 yuxia
2022/12/13 Re: 提交任务不能指定第三方jar melin li
2022/12/13 回复： flink-gelly官方文档 Jason_H
2022/12/13 Re: flink-gelly官方文档 guozhi mang
2022/12/13 flink-gelly官方文档 Jason_H
2022/12/12 Flink 中的类加载KafkaSerializerWrapper wangshuai
2022/12/11 Re: 使用flink 动态广播mysql数据报错 yidan zhao
2022/12/09 Re: 关于Flink重启策略疑惑 weijie guo
2022/12/08 关于Flink重启策略疑惑李义
2022/12/08 flink kubernetes operator生产环境配置谭家良
2022/12/07 Re: 1.15.2作业频繁（每几十分钟 ~ 1小时）报 LocalTransportException: readAddress(..) failed: Connection timed out . yidan zhao
2022/12/07 Re: 提交任务不能指定第三方jar melin li
2022/12/07 Re: 提交任务不能指定第三方jar yuxia
2022/12/07 提交任务不能指定第三方jar melin li
2022/12/07 Re: flink 1.16 lookup join重试策略问题 Lincoln Lee
2022/12/07 flink 1.16 lookup join重试策略问题 casel.chen
2022/12/07 Re:Re: 如何扩展flink sql以实现延迟调用？ casel.chen
2022/12/07 Re:Re: 如何扩展flink sql以实现延迟调用？ casel.chen
2022/12/07 (无主题) zhufangliang
2022/12/07 Re: 1.15.2作业频繁（每几十分钟 ~ 1小时）报 LocalTransportException: readAddress(..) failed: Connection timed out . yidan zhao
2022/12/06 Re: 如何扩展flink sql以实现延迟调用？ Lincoln Lee
2022/12/06 flink on native k8s模式调度能否根据节点磁盘和网络io指标进行调度？ casel.chen
2022/12/06 Re:如何扩展flink sql以实现延迟调用？ casel.chen
2022/12/06 flink sql是否支持延迟lookup join? casel.chen
2022/12/06 flink web ui 提交任务报错朱文忠
2022/12/06 Re:flink on k8s节点网络io飙高问题如何解决？ casel.chen
2022/12/06 1.15.2作业频繁（每几十分钟 ~ 1小时）报 LocalTransportException: readAddress(..) failed: Connection timed out . yidan zhao
2022/12/06 flink executeAsync() guanyq
2022/12/05 flink sql滑动窗口问题谭家良
2022/12/05 flink on k8s节点网络io飙高问题如何解决？ casel.chen
2022/12/05 Re:回复：flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？ casel.chen
2022/12/05 回复：flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？ JasonLee
2022/12/05 flink sql消费upsert-kafka源表如何指定从哪个位点开始消费？ casel.chen
2022/12/04 sql查询数据库不走索引杨扬
2022/12/02 退订悠舒刘
2022/12/01 回复: 回复: Re: 怎样从flink执行计划json生成StreamGraph? 仙路尽头谁为峰
2022/12/01 Re: Re: flink sql作业无缝升级问题 yidan zhao
2022/12/01 Re:回复: Re: 怎样从flink执行计划json生成StreamGraph? casel.chen
2022/12/01 Re:Re: flink sql作业无缝升级问题 casel.chen
2022/12/01 Re:FLINK postgresql CDC 报语法错误 bmw
2022/12/01 FLINK postgresql CDC 报语法错误 bmw
2022/12/01 ???? ????
2022/11/30 Re: flink sql作业无缝升级问题 yidan zhao
2022/11/30 Re: flink sql作业无缝升级问题 Jiangang Liu
2022/11/29 ElasticsearchSink 设置es 主分片数 allanqinjy
2022/11/29 回复: Re: 怎样从flink执行计划json生成StreamGraph? 仙路尽头谁为峰
2022/11/29 Re: Re: 怎样从flink执行计划json生成StreamGraph? yidan zhao
2022/11/29 Re:Re: 怎样从flink执行计划json生成StreamGraph? casel.chen
2022/11/29 Re: FlinkCDC可以读到MySQL变更数据，但是插不到新的MySQL表里 Leonard Xu
2022/11/29 Re: flink sql接cdc数据源按最新数据统计问题 Leonard Xu
2022/11/28 Re: 如何使用flink sql优雅的处理大量嵌套if-else逻辑 macia kk
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