user-zh

日期索引

2023/02/13 Flink程序内存Dump不了 lxk
2023/02/13 运行中的作业状态清除操作 Jason_H
2023/02/12 flink connector kafka，单条 msg 为 7kb，poll 较慢 xuhaiLong
2023/02/09 退订 ZhouZH
2023/02/09 Re: 退订 huang huang
2023/02/08 flink canal json格式忽略不识别的type casel.chen
2023/02/08 Re: Re: Kafka 数据源无法实现基于事件时间的窗口聚合 yidan zhao
2023/02/07 Re: 退订 weijie guo
2023/02/07 Re: I want to subscribe users' questions yuxia
2023/02/07 Re: I want to subscribe users' questions Hang Ruan
2023/02/07 I want to subscribe users' questions guanyuan chen
2023/02/07 回复： Kafka 数据源无法实现基于事件时间的窗口聚合 drewfranklin
2023/02/07 Re: Kafka 数据源无法实现基于事件时间的窗口聚合 Weihua Hu
2023/02/07 Re: idea构建flink源码失败 Ran Tao
2023/02/06 Re: idea构建flink源码失败 Weihua Hu
2023/02/06 退订郑林怡
2023/02/06 Re: Flink SQL使用hive dialect异常 yuxia
2023/02/04 idea构建flink源码失败 tiger
2023/02/02 flink提交jar包时报连接不上BlobServer 孙冬燕
2023/02/02 Re: Flink消费消息队列写入HDFS weijie guo
2023/02/02 Flink消费消息队列写入HDFS Howie Yang
2023/02/01 Re: [ANNOUNCE] Apache Flink 1.16.1 released weijie guo
2023/02/01 Re: [ANNOUNCE] Apache Flink 1.16.1 released Konstantin Knauf
2023/02/01 [ANNOUNCE] Apache Flink 1.16.1 released Martijn Visser
2023/01/31 flink 访问hive 表，怎样实现读写权限校验？ melin li
2023/01/31 Re:Re: Flink SQL 如何优化以及处理反压 lxk
2023/01/31 Re: Flink SQL 如何优化以及处理反压 weijie guo
2023/01/31 回复: Flink SQL 如何优化以及处理反压 ssmq
2023/01/31 Re: [ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released Leonard Xu
2023/01/30 Re: [ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released Yun Tang
2023/01/30 Flink SQL 如何优化以及处理反压 lxk
2023/01/30 Re: [ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released Yuan Mei
2023/01/30 Re: 退订 weijie guo
2023/01/30 Re: 任务本地运行正常，提交到集群报错 - 图片挂掉，文字贴一下报错信息，非常抱歉打扰 weijie guo
2023/01/30 Re: [ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released Jing Ge
2023/01/30 [ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released Yanfei Lei
2023/01/29 flink sql-client kerberos认证不通过 xiaohui zhang
2023/01/18 Re: Dear All，关于State processor API，有一些疑惑 ying lin
2023/01/18 Re: Dear All，关于State processor API，有一些疑惑 Hangxiang Yu
2023/01/18 Re: 取消订阅 Jiangang Liu
2023/01/18 取消订阅 lei-tian
2023/01/17 Dear All，关于State processor API，有一些疑惑 ying lin
2023/01/16 Re: 如何监控flink sql on native k8s作业是否过度申请资源？ Weihua Hu
2023/01/16 如何监控flink sql on native k8s作业是否过度申请资源？ casel.chen
2023/01/15 Re: flink状态恢复 Hangxiang Yu
2023/01/15 Re: 未知类异常： org/apache/flink/table/connector/sink/abilities/SupportsSchemaEvolutionWriting Shammon FY
2023/01/15 取消订阅 wangwj03
2023/01/13 [ANNOUNCE] Apache Flink Table Store 0.3.0 released Jingsong Li
2023/01/13 Re: sql-client.sh 终止后, 进程不会被 kill Shengkai Fang
2023/01/12 退订 willluzheng
2023/01/12 退订 DannyLau
2023/01/12 sql-client.sh 终止后, 进程不会被 kill 704669594
2023/01/12 Re: 请问cancel的任务能够恢复running状态吗？ yidan zhao
2023/01/12 Re: 任务本地运行正常，提交到集群报错 - 图片挂掉，文字贴一下报错信息，非常抱歉打扰 yidan zhao
2023/01/11 flink状态恢复小昌同学
2023/01/10 [ANNOUNCE] Apache Flink Kubernetes Operator 1.3.1 released Gyula Fóra
2023/01/09 Re: flink-kubernetes-operator部署问题 Weihua Hu
2023/01/09 任务本地运行正常，提交到集群报错 - 图片挂掉，文字贴一下报错信息，非常抱歉打扰 WD.Z
2023/01/09 任务本地运行正常，提交到集群报错 - 图片挂掉了重发一下 WD.Z
2023/01/09 任务本地运行正常，提交到集群报错 WD.Z
2023/01/09 回复：flink自带的web ui为什么不能提供一个触发生成保存点的按钮？朱文忠
2023/01/09 flink自带的web ui为什么不能提供一个触发生成保存点的按钮？ casel.chen
2023/01/09 flink-kubernetes-operator部署问题圣万
2023/01/08 退订于光远
2023/01/08 Re: Re: 退订 Shammon FY
2023/01/08 Re: 退订张立阳
2023/01/08 Re:Re: 退订中微子
2023/01/08 Re: 退订 Yuxin Tan
2023/01/08 退订张保淇
2023/01/07 Re: flink任务重启后监控指标从0开始重新统计 XJ Li
2023/01/04 Re: checkpoint首次触发时间疑问 Jiangang Liu
2023/01/04 Re: 请问cancel的任务能够恢复running状态吗？ Weihua Hu
2023/01/02 退订邱钺
2023/01/02 使用 WindowDeduplicate 时，数据没有按照期望的时效写入sink 端 lk_hadoop
2022/12/30 回复：请问cancel的任务能够恢复running状态吗？ DannyLau
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一样每次变化 799590...@qq.com.INVALID
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