user-zh

日期索引

2023/04/20 Re: kafka实例重启对flink作业的影响 Weihua Hu
2023/04/20 kafka实例重启对flink作业的影响 casel.chen
2023/04/19 退订曹佳清
2023/04/19 Re: 退订 Biao Geng
2023/04/19 回复：控制台打印出流式数据小昌同学
2023/04/19 回复：flink命令行提交作业读取不到properties配置文件小昌同学
2023/04/19 回复：控制台打印出流式数据 Jason_H
2023/04/19 回复：控制台打印出流式数据小昌同学
2023/04/19 回复：控制台打印出流式数据 Jason_H
2023/04/19 flink命令行提交作业读取不到properties配置文件 Jason_H
2023/04/19 控制台打印出流式数据小昌同学
2023/04/18 Re: Re: Re: sink mysql id自增表数据会丢失 Shammon FY
2023/04/18 Re:Re: Re: sink mysql id自增表数据会丢失王国成
2023/04/18 Re: Re: sink mysql id自增表数据会丢失 Shammon FY
2023/04/18 Re: flink api消费kafka（avro）数据出错 Shammon FY
2023/04/18 Re: 退订 Biao Geng
2023/04/18 退订 ji_longzhang
2023/04/18 Re:Re: sink mysql id自增表数据会丢失 Jeff
2023/04/18 udf函数不能使用DataTypeHint("Row<t ARRAY<INT>>") Jeff
2023/04/17 退订杨伟伟
2023/04/17 Re: 退订 Shammon FY
2023/04/17 Re: 流数据转化为json Weihua Hu
2023/04/17 Flink Streaming API ElasticSearch Connector 长连接 Yuze Wei
2023/04/17 Re: 用Flink Table API和RocksDB不能正常升级状态数据结构 Shammon FY
2023/04/17 Re: 流数据转化为json Shammon FY
2023/04/17 Re: sink mysql id自增表数据会丢失 Shammon FY
2023/04/16 sink mysql id自增表数据会丢失 Jeff
2023/04/15 ValueError: unsupported pickle protocol: 5 casel.chen
2023/04/14 退订 lutty shi
2023/04/14 用Flink Table API和RocksDB不能正常升级状态数据结构 Elvis Chen
2023/04/14 Re: 退订 daniel sun
2023/04/14 流数据转化为json 小昌同学
2023/04/14 回复：flink sink web ui显示为Sink: Unnamed 小昌同学
2023/04/14 退订 zjw
2023/04/14 退订 huang huang
2023/04/14 Re: flink sink web ui显示为Sink: Unnamed Weihua Hu
2023/04/14 Re:flink sink web ui显示为Sink: Unnamed hjw
2023/04/14 flink sink web ui显示为Sink: Unnamed 小昌同学
2023/04/14 回复：打印不同流怎么进行区分小昌同学
2023/04/13 回复：打印不同流怎么进行区分 17610775726
2023/04/13 打印不同流怎么进行区分小昌同学
2023/04/13 Re: 退订 Shammon FY
2023/04/13 退订 lei-tian
2023/04/13 ogg json格式不支持database include和table include参数 casel.chen
2023/04/13 转发: 孟令平
2023/04/12 回复：监控flink的prometheus经常OOM 17610775726
2023/04/11 Re: Flink实时计算平台在k8s上以Application模式启动作业如何实时同步作业状态到平台？ Yang Wang
2023/04/11 Re: 监控flink的prometheus经常OOM Yang Wang
2023/04/09 Re: Re: PartitionNotFoundException Weihua Hu
2023/04/09 Re: Re: PartitionNotFoundException Shammon FY
2023/04/08 Re: 回复：Kerberos加密Yarn集群上的Flink任务写入其他未互信的加密HDFS是否可能 Geng Biao
2023/04/08 回复：Kerberos加密Yarn集群上的Flink任务写入其他未互信的加密HDFS是否可能 yihan
2023/04/08 Re: Kerberos加密Yarn集群上的Flink任务写入其他未互信的加密HDFS是否可能 Geng Biao
2023/04/08 Kerberos加密Yarn集群上的Flink任务写入其他未互信的加密HDFS是否可能 yihan
2023/04/06 WindowAssigner中windowStagger作用 yidan zhao
2023/04/06 Re: 退订 Shammon FY
2023/04/05 退订 Tony
2023/04/04 Re: 退订 Shammon FY
2023/04/03 退订柳懿珊
2023/04/03 [ANNOUNCE] Starting with Flink 1.18 Release Sync Qingsheng Ren
2023/04/02 Re: PartitionNotFoundException yidan zhao
2023/04/02 Re: PartitionNotFoundException Shammon FY
2023/03/29 Re: flink sql的codegen导致metaspace OOM疑问 Shammon FY
2023/03/29 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Dong Lin
2023/03/29 来自胡家发的邮件胡家发
2023/03/29 flink sql的codegen导致metaspace OOM疑问 tanjialiang
2023/03/28 找到多个default类型的ExecutorFactory导致提交flink sql作业失败 casel.chen
2023/03/28 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Shuo Cheng
2023/03/28 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Guowei Ma
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Yuxin Tan
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Guanghui Zhang
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Yun Tang
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Biao Liu
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Hang Ruan
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) yu zelin
2023/03/27 flink sql upsert mysql问题小昌同学
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Yanfei Lei
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Weihua Hu
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) yuxia
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Matthias Pohl
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Konstantin Knauf
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Jing Ge
2023/03/27 Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Leonard Xu
2023/03/27 [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating) Yu Li
2023/03/27 Re: [ANNOUNCE] Apache Flink 1.17.0 released Matthias Pohl
2023/03/26 Re:Re: flink1.16 sql gateway hive2 guanyq
2023/03/26 Re: flink1.16 sql gateway hive2 Shengkai Fang
2023/03/26 Re: flink1.16 sql gateway hive2 Shammon FY
2023/03/26 Re: flink watermark 乱序数据问题 Shammon FY
2023/03/25 flink1.16 sql gateway hive2 guanyq
2023/03/25 Re: 项目中引入 flink-sql-connector-oracle-cdc-2.3.0.jar 后启动报解析配置异常 Leonard Xu
2023/03/25 Re: [ANNOUNCE] Apache Flink 1.17.0 released Hang Ruan
2023/03/25 项目中引入 flink-sql-connector-oracle-cdc-2.3.0.jar 后启动报解析配置异常 casel.chen
2023/03/24 Re: [ANNOUNCE] Apache Flink 1.17.0 released Panagiotis Garefalakis
2023/03/24 Re: flink sql作业监控指标operator name和task name超长导致prometheus OOM问题 Weihua Hu
2023/03/24 Re: flink写入mysql数据异常 Shammon FY
2023/03/23 flink sql作业监控指标operator name和task name超长导致prometheus OOM问题 casel.chen
2023/03/23 回复：flink写入mysql数据异常孙冬燕
2023/03/23 回复： flink写入mysql数据异常小昌同学
2023/03/23 Re: flink写入mysql数据异常 Shammon FY
2023/03/23 回复：flink写入mysql数据异常孙冬燕
2023/03/23 回复： flink写入mysql数据异常小昌同学
2023/03/23 退订柳懿珊
2023/03/23 Re: flink写入mysql数据异常 Jane Chan
2023/03/23 Re: [ANNOUNCE] Apache Flink 1.17.0 released Matthias Pohl
2023/03/23 Re: [ANNOUNCE] Apache Flink 1.17.0 released Jing Ge
2023/03/23 回复： flink写入mysql数据异常小昌同学
2023/03/23 [ANNOUNCE] Apache Flink 1.17.0 released Leonard Xu
2023/03/23 Re: flink写入mysql数据异常 Jane Chan
2023/03/22 回复： flink写入mysql数据异常小昌同学
2023/03/22 flink写入mysql数据异常小昌同学
2023/03/22 Re:Re: Re: 我上报的一个sql bug没人处理怎么办？ Jeff
2023/03/22 Re: 退订 Shammon FY
2023/03/22 Re: 退订 Ran Tao
2023/03/22 退订 jianbo zhang
2023/03/22 (无主题) 李朋
2023/03/22 Re:Re: Re: 我上报的一个sql bug没人处理怎么办？ Jeff
2023/03/22 Re: Re: 我上报的一个sql bug没人处理怎么办？ tison
2023/03/22 Re: Re: 我上报的一个sql bug没人处理怎么办？ Jane Chan
2023/03/22 Re:Re: 我上报的一个sql bug没人处理怎么办？ Jeff
2023/03/22 Re: regular join每条流单独设置ttl Jane Chan
2023/03/22 Re: 我上报的一个sql bug没人处理怎么办？ Jane Chan
2023/03/21 Re:监控flink的prometheus经常OOM casel.chen
2023/03/21 监控flink的prometheus经常OOM casel.chen
2023/03/21 Re: 我上报的一个sql bug没人处理怎么办？ tison
2023/03/21 Re: 我上报的一个sql bug没人处理怎么办？ tison
2023/03/21 Re: 我上报的一个sql bug没人处理怎么办？ Shuo Cheng
2023/03/21 Re:我上报的一个sql bug没人处理怎么办？ Jeff
2023/03/21 Re: 我上报的一个sql bug没人处理怎么办？ Weihua Hu
2023/03/21 我上报的一个sql bug没人处理怎么办？ Jeff
2023/03/21 Re: Flink实时计算平台在k8s上以Application模式启动作业如何实时同步作业状态到平台？ Weihua Hu
2023/03/21 Re: Re: flink作业保存的状态文件目录在aliyun oss上打不开 Guojun Li
2023/03/21 Re: Re: flink作业保存的状态文件目录在aliyun oss上打不开 Shammon FY
2023/03/21 Re: Flink实时计算平台在k8s上以Application模式启动作业如何实时同步作业状态到平台？ Shammon FY
2023/03/21 Flink实时计算平台在k8s上以Application模式启动作业如何实时同步作业状态到平台？ casel.chen
2023/03/21 Re:Re: flink作业保存的状态文件目录在aliyun oss上打不开 casel.chen
2023/03/21 Re: prometheus监控flink作业经常OOM Shammon FY
2023/03/21 Re: flink作业保存的状态文件目录在aliyun oss上打不开 Shammon FY
2023/03/20 flink作业保存的状态文件目录在aliyun oss上打不开 casel.chen
2023/03/20 prometheus监控flink作业经常OOM casel.chen
2023/03/18 Re:Re: 实时数据同步对比监控有什么好的工具和方案吗？ casel.chen
2023/03/17 Re: 实时数据同步对比监控有什么好的工具和方案吗？ Shammon FY
2023/03/16 Re: 业务库刷数据瞬间cdc流量上涨打爆作业的问题有什么好的解决办法吗？ yue ma
2023/03/16 业务库刷数据瞬间cdc流量上涨打爆作业的问题有什么好的解决办法吗？ casel.chen
2023/03/16 实时数据同步对比监控有什么好的工具和方案吗？ casel.chen
2023/03/16 水位线对齐与空闲问题 haishui
2023/03/16 Re: Re: 无法设置任务名 Shammon FY
2023/03/15 Re: 无法设置任务名 Weihua Hu
2023/03/15 Re: Flink-Sql Watermarkers问题 ying lin
2023/03/14 回复：咨询yarn session 集群启动后在不重启的情况下如何更新一个jar包 17610775726
2023/03/14 Re: 咨询yarn session 集群启动后在不重启的情况下如何更新一个jar包 Shammon FY
2023/03/14 咨询yarn session 集群启动后在不重启的情况下如何更新一个jar包 wdmcode
2023/03/13 Re: flink k8s 部署启动报错 Weihua Hu
2023/03/13 回复： flink k8s 部署启动报错 Jason_H
2023/03/13 回复： flink k8s 部署启动报错 Jason_H
2023/03/13 Re: flink k8s 部署启动报错 Weihua Hu
2023/03/13 Re:Re: Re: Re: Re: flink on yarn 异常停电问题咨询 guanyq
2023/03/13 Re: Re: Re: Re: flink on yarn 异常停电问题咨询 Guojun Li
2023/03/13 flink k8s 部署启动报错 Jason_H
2023/03/13 Re: flink avro schema 升级变动，job如何平滑过渡 Shammon FY
2023/03/13 回复： Flink-Sql Watermarkers问题吴先生
2023/03/13 Re: GenericRowData与BinaryRowData的转换 Benchao Li
2023/03/13 Re: GenericRowData与BinaryRowData的转换 Shammon FY
2023/03/13 Re: Flink-Sql Watermarkers问题 Shammon FY
2023/03/13 Flink-Sql Watermarkers问题吴先生
2023/03/13 Re:Re: Re: flink on yarn关于yarn尝试重启flink job问题咨询 guanyq
2023/03/13 Re: Re: flink on yarn关于yarn尝试重启flink job问题咨询 Weihua Hu
2023/03/13 Re:Re: flink on yarn关于yarn尝试重启flink job问题咨询 guanyq
2023/03/13 Re: GenericRowData与BinaryRowData的转换 zilong xiao
2023/03/13 Re: flink on yarn关于yarn尝试重启flink job问题咨询 Weihua Hu
2023/03/13 flink on yarn关于yarn尝试重启flink job问题咨询 guanyq
2023/03/11 flink sql多条cdc数据流实时regular join如何减少作业状态？ casel.chen
2023/03/09 Re: flink avro schema 升级变动，job如何平滑过渡 Peihui He
2023/03/09 Re:Re: Re: Re: flink on yarn 异常停电问题咨询 guanyq
2023/03/09 Re: Re: Re: flink on yarn 异常停电问题咨询 Weihua Hu
2023/03/09 Re:Re: Re: flink on yarn 异常停电问题咨询 guanyq
2023/03/09 Re: Re: flink on yarn 异常停电问题咨询 Yanfei Lei
2023/03/09 Re:Re: flink on yarn 异常停电问题咨询 guanyq
2023/03/09 Re: flink on yarn 异常停电问题咨询 Shammon FY
2023/03/09 Re: flink问题咨询 Shammon FY
2023/03/09 flink on yarn 异常停电问题咨询 guanyq
2023/03/08 flink问题咨询陈隽尧
2023/03/08 Re: Re:Re: Re: 使用flinksql将kafka的数据同步mysql，在源kafka进行删除操作，mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。 Jane Chan
2023/03/08 Re: Flink异步Hbase导致Too many open files异常 Ran Tao
2023/03/08 Re: Flink异步Hbase导致Too many open files异常 Weihua Hu
2023/03/07 Re: Re: flink on K8S(operator) 如何获取 Accumulator Shammon FY
2023/03/07 Re:Re: flink on K8S(operator) 如何获取 Accumulator 李银苗
2023/03/06 Re: flink on K8S(operator) 如何获取 Accumulator Weihua Hu
2023/03/06 FlinkCEP GroupPattern 匹配结果异常问题傅宣登
2023/03/06 Re: Flink作业tm Connection timed out异常问题 Shammon FY
2023/03/06 Re: flinkSQL无法实现两个timestamp(3) 相减 Shammon FY
2023/03/06 flink cdc connector计划支持hudi change data capture吗？ casel.chen
2023/03/06 flink on K8S(operator) 如何获取 Accumulator wangwei
2023/03/06 flinkSQL无法实现两个timestamp(3) 相减唐世伟
2023/03/05 Re: Flink作业tm Connection timed out异常问题 Yuxin Tan
2023/03/05 Re: Flink作业tm Connection timed out异常问题 Yuxin Tan
2023/03/05 Flink????tm Connection timed out???????? crazy
2023/03/05 Re:Re:Re: Re: 使用flinksql将kafka的数据同步mysql，在源kafka进行删除操作，mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。陈佳豪
2023/03/05 Re:Re: Re: 使用flinksql将kafka的数据同步mysql，在源kafka进行删除操作，mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。陈佳豪
2023/03/04 Re: Re: 使用flinksql将kafka的数据同步mysql，在源kafka进行删除操作，mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。 Jane Chan