user-zh
文章
日期
较舊的信息
较新的信息
文章索引
Flink Streaming API ElasticSearch Connector 长连接
Yuze Wei
ValueError: unsupported pickle protocol: 5
casel.chen
sink mysql id自增表数据会丢失
Jeff
Re: sink mysql id自增表数据会丢失
Shammon FY
Re:Re: sink mysql id自增表数据会丢失
Jeff
Re: Re: sink mysql id自增表数据会丢失
Shammon FY
Re:Re: Re: sink mysql id自增表数据会丢失
王国成
Re: Re: Re: sink mysql id自增表数据会丢失
Shammon FY
用Flink Table API和RocksDB不能正常升级状态数据结构
Elvis Chen
Re: 用Flink Table API和RocksDB不能正常升级状态数据结构
Shammon FY
Re: [External] Re: 用Flink Table API和RocksDB不能正常升级状态数据结构
Elvis Chen
流数据转化为json
小昌同学
Re: 流数据转化为json
Shammon FY
udf函数不能使用DataTypeHint("Row<t ARRAY<INT>>")
Jeff
Re: 流数据转化为json
Weihua Hu
flink sink web ui显示为Sink: Unnamed
小昌同学
Re:flink sink web ui显示为Sink: Unnamed
hjw
回复:flink sink web ui显示为Sink: Unnamed
小昌同学
Re: flink sink web ui显示为Sink: Unnamed
Weihua Hu
打印不同流怎么进行区分
小昌同学
回复:打印不同流怎么进行区分
17610775726
回复:打印不同流怎么进行区分
小昌同学
ogg json格式不支持database include和table include参数
casel.chen
转发:
孟令平
Kerberos加密Yarn集群上的Flink任务写入其他未互信的加密HDFS是否可能
yihan
Re: Kerberos加密Yarn集群上的Flink任务写入其他未互信的加密HDFS是否可能
Geng Biao
回复:Kerberos加密Yarn集群上的Flink任务写入其他未互信的加密HDFS是否可能
yihan
Re: 回复:Kerberos加密Yarn集群上的Flink任务写入其他未互信的加密HDFS是否可能
Geng Biao
WindowAssigner中windowStagger作用
yidan zhao
[ANNOUNCE] Starting with Flink 1.18 Release Sync
Qingsheng Ren
来自胡家发的邮件
胡家发
flink sql的codegen导致metaspace OOM疑问
tanjialiang
Re: flink sql的codegen导致metaspace OOM疑问
Shammon FY
找到多个default类型的ExecutorFactory导致提交flink sql作业失败
casel.chen
flink sql upsert mysql问题
小昌同学
[ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Yu Li
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Leonard Xu
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Jing Ge
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Matthias Pohl
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
yuxia
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Weihua Hu
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Konstantin Knauf
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Yanfei Lei
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Yun Tang
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
yu zelin
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Hang Ruan
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Biao Liu
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Guanghui Zhang
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Yuxin Tan
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Guowei Ma
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Shuo Cheng
Re: [ANNOUNCE] Flink Table Store Joins Apache Incubator as Apache Paimon(incubating)
Dong Lin
Re: flink watermark 乱序数据问题
Shammon FY
项目中引入 flink-sql-connector-oracle-cdc-2.3.0.jar 后启动报解析配置异常
casel.chen
Re: 项目中引入 flink-sql-connector-oracle-cdc-2.3.0.jar 后启动报解析配置异常
Leonard Xu
flink sql作业监控指标operator name和task name超长导致prometheus OOM问题
casel.chen
Re: flink sql作业监控指标operator name和task name超长导致prometheus OOM问题
Weihua Hu
[ANNOUNCE] Apache Flink 1.17.0 released
Leonard Xu
Re: [ANNOUNCE] Apache Flink 1.17.0 released
Jing Ge
Re: [ANNOUNCE] Apache Flink 1.17.0 released
Matthias Pohl
Re: [ANNOUNCE] Apache Flink 1.17.0 released
Panagiotis Garefalakis
Re: [ANNOUNCE] Apache Flink 1.17.0 released
Hang Ruan
Re: [ANNOUNCE] Apache Flink 1.17.0 released
Matthias Pohl
flink写入mysql数据异常
小昌同学
回复: flink写入mysql数据异常
小昌同学
Re: flink写入mysql数据异常
Jane Chan
回复: flink写入mysql数据异常
小昌同学
Re: flink写入mysql数据异常
Jane Chan
回复: flink写入mysql数据异常
小昌同学
回复:flink写入mysql数据异常
孙冬燕
Re: flink写入mysql数据异常
Shammon FY
回复: flink写入mysql数据异常
小昌同学
回复:flink写入mysql数据异常
孙冬燕
Re: flink写入mysql数据异常
Shammon FY
监控flink的prometheus经常OOM
casel.chen
Re:监控flink的prometheus经常OOM
casel.chen
Re: 监控flink的prometheus经常OOM
Yang Wang
回复:监控flink的prometheus经常OOM
17610775726
Flink实时计算平台在k8s上以Application模式启动作业如何实时同步作业状态到平台?
casel.chen
Re: Flink实时计算平台在k8s上以Application模式启动作业如何实时同步作业状态到平台?
Shammon FY
Re: Flink实时计算平台在k8s上以Application模式启动作业如何实时同步作业状态到平台?
Weihua Hu
Re: Flink实时计算平台在k8s上以Application模式启动作业如何实时同步作业状态到平台?
Yang Wang
我上报的一个sql bug没人处理怎么办?
Jeff
Re: 我上报的一个sql bug没人处理怎么办?
Weihua Hu
Re:我上报的一个sql bug没人处理怎么办?
Jeff
Re: 我上报的一个sql bug没人处理怎么办?
Shuo Cheng
Re: 我上报的一个sql bug没人处理怎么办?
tison
Re: 我上报的一个sql bug没人处理怎么办?
tison
Re: 我上报的一个sql bug没人处理怎么办?
Jane Chan
Re:Re: 我上报的一个sql bug没人处理怎么办?
Jeff
Re: Re: 我上报的一个sql bug没人处理怎么办?
Jane Chan
Re: Re: 我上报的一个sql bug没人处理怎么办?
tison
Re:Re: Re: 我上报的一个sql bug没人处理怎么办?
Jeff
Re:Re: Re: 我上报的一个sql bug没人处理怎么办?
Jeff
flink作业保存的状态文件目录在aliyun oss上打不开
casel.chen
Re: flink作业保存的状态文件目录在aliyun oss上打不开
Shammon FY
Re:Re: flink作业保存的状态文件目录在aliyun oss上打不开
casel.chen
Re: Re: flink作业保存的状态文件目录在aliyun oss上打不开
Shammon FY
Re: Re: flink作业保存的状态文件目录在aliyun oss上打不开
Guojun Li
prometheus监控flink作业经常OOM
casel.chen
Re: prometheus监控flink作业经常OOM
Shammon FY
业务库刷数据瞬间cdc流量上涨打爆作业的问题有什么好的解决办法吗?
casel.chen
Re: 业务库刷数据瞬间cdc流量上涨打爆作业的问题有什么好的解决办法吗?
yue ma
实时数据同步对比监控有什么好的工具和方案吗?
casel.chen
Re: 实时数据同步对比监控有什么好的工具和方案吗?
Shammon FY
Re:Re: 实时数据同步对比监控有什么好的工具和方案吗?
casel.chen
水位线对齐与空闲问题
haishui
Re: 无法设置任务名
Weihua Hu
Re: Re: 无法设置任务名
Shammon FY
咨询yarn session 集群启动后在不重启的情况下如何更新一个jar包
wdmcode
Re: 咨询yarn session 集群启动后在不重启的情况下如何更新一个jar包
Shammon FY
回复:咨询yarn session 集群启动后在不重启的情况下如何更新一个jar包
17610775726
flink k8s 部署启动报错
Jason_H
Re: flink k8s 部署启动报错
Weihua Hu
回复: flink k8s 部署启动报错
Jason_H
回复: flink k8s 部署启动报错
Jason_H
Re: flink k8s 部署启动报错
Weihua Hu
Flink-Sql Watermarkers问题
吴先生
Re: Flink-Sql Watermarkers问题
Shammon FY
回复: Flink-Sql Watermarkers问题
吴先生
Re: Flink-Sql Watermarkers问题
ying lin
Re: GenericRowData与BinaryRowData的转换
zilong xiao
Re: GenericRowData与BinaryRowData的转换
Shammon FY
Re: GenericRowData与BinaryRowData的转换
Benchao Li
flink sql多条cdc数据流实时regular join如何减少作业状态?
casel.chen
flink on yarn 异常停电问题咨询
guanyq
Re: flink on yarn 异常停电问题咨询
Shammon FY
Re:Re: flink on yarn 异常停电问题咨询
guanyq
Re: Re: flink on yarn 异常停电问题咨询
Yanfei Lei
Re:Re: Re: flink on yarn 异常停电问题咨询
guanyq
Re: Re: Re: flink on yarn 异常停电问题咨询
Weihua Hu
Re:Re: Re: Re: flink on yarn 异常停电问题咨询
guanyq
Re: Re: Re: Re: flink on yarn 异常停电问题咨询
Guojun Li
Re:Re: Re: Re: Re: flink on yarn 异常停电问题咨询
guanyq
flink1.16 sql gateway hive2
guanyq
Re: flink1.16 sql gateway hive2
Shammon FY
Re: flink1.16 sql gateway hive2
Shengkai Fang
Re:Re: flink1.16 sql gateway hive2
guanyq
flink1.10.1版本,读取日志目录问题
guanyq
flink1.17.1版本
guanyq
flink1.17.1版本 MiniCluster is not yet running or has already been shut down.
guanyq
Re: flink1.17.1版本 MiniCluster is not yet running or has already been shut down.
Shammon FY
flink1.17.1版本 flink on yarn 提交无法获取配置文件
guanyq
flink on yarn关于yarn尝试重启flink job问题咨询
guanyq
Re: flink on yarn关于yarn尝试重启flink job问题咨询
Weihua Hu
Re:Re: flink on yarn关于yarn尝试重启flink job问题咨询
guanyq
Re: Re: flink on yarn关于yarn尝试重启flink job问题咨询
Weihua Hu
Re:Re: Re: flink on yarn关于yarn尝试重启flink job问题咨询
guanyq
flink问题咨询
陈隽尧
Re: flink问题咨询
Shammon FY
FlinkCEP GroupPattern 匹配结果异常问题
傅宣登
flink cdc connector计划支持hudi change data capture吗?
casel.chen
flinkSQL无法实现两个timestamp(3) 相减
唐世伟
Re: flinkSQL无法实现两个timestamp(3) 相减
Shammon FY
Flink????tm Connection timed out????????
crazy
Re: Flink作业tm Connection timed out异常问题
Yuxin Tan
Re: Flink作业tm Connection timed out异常问题
Yuxin Tan
Re: Flink作业tm Connection timed out异常问题
Shammon FY
flink sql
小昌同学
Re:flink sql
17610775726
Re: flink sql
小昌同学
flink on K8S(operator) 如何获取 Accumulator
wangwei
Re: flink on K8S(operator) 如何获取 Accumulator
Weihua Hu
Re:Re: flink on K8S(operator) 如何获取 Accumulator
李银苗
Re: Re: flink on K8S(operator) 如何获取 Accumulator
Shammon FY
Re: Flink异步Hbase导致Too many open files异常
Weihua Hu
Re: Flink异步Hbase导致Too many open files异常
Ran Tao
flink sql jdbc connector是否支持多流拼接?
casel.chen
Re: flink sql jdbc connector是否支持多流拼接?
Shengkai Fang
Re:flink sql jdbc connector是否支持多流拼接?
程龙
Flink内存问题
吴先生
Re: Flink内存问题
Shammon FY
回复: Flink内存问题
吴先生
Re: Flink内存问题
Weihua Hu
回复: Flink内存问题
吴先生
使用flinksql将kafka的数据同步mysql,在源kafka进行删除操作,mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。
陈佳豪
Re:使用flinksql将kafka的数据同步mysql,在源kafka进行删除操作,mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。
陈佳豪
Re: 使用flinksql将kafka的数据同步mysql,在源kafka进行删除操作,mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。
Jane Chan
Re:Re: 使用flinksql将kafka的数据同步mysql,在源kafka进行删除操作,mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。
陈佳豪
Re: Re: 使用flinksql将kafka的数据同步mysql,在源kafka进行删除操作,mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。
Jane Chan
Re:Re: Re: 使用flinksql将kafka的数据同步mysql,在源kafka进行删除操作,mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。
陈佳豪
Re:Re:Re: Re: 使用flinksql将kafka的数据同步mysql,在源kafka进行删除操作,mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。
陈佳豪
Re: Re:Re: Re: 使用flinksql将kafka的数据同步mysql,在源kafka进行删除操作,mysql收到op为d的数据进行删除操作但是与此同时会新增一条当前数据以前的旧数据。
Jane Chan
metrics.latency.interval指标应该如何查看?
陶浩然
flink sql接cdc数据源关联维表写入下游数据库发现漏数据
casel.chen
Re: flink sql接cdc数据源关联维表写入下游数据库发现漏数据
Shengkai Fang
managed memory????100%??????
????????????
Re: managed memory占用100%的问题
Junrui Lee
Re: managed memory占用100%的问题
Shammon FY
Re: 【Windowing TVF】 GROUP BY window_start, window_end 没有输出
Weihua Hu
Re:Flink Kafka Sink时间戳异常
haishui
flink avro schema 升级变动,job如何平滑过渡
Peihui He
Re: flink avro schema 升级变动,job如何平滑过渡
Shammon FY
Re: flink avro schema 升级变动,job如何平滑过渡
Peihui He
Re: flink avro schema 升级变动,job如何平滑过渡
Shammon FY
在计算Window Top-N时,Flink SQL 时间语义不生效
wei_yuze
Re: 在计算Window Top-N时,Flink SQL 时间语义不生效
Shuo Cheng
使用flink sql 将kafka的数据同步到mysql无法删除。
陈佳豪
Re: 使用flink sql 将kafka的数据同步到mysql无法删除。
Jane Chan
答复:
704669594
较舊的信息
较新的信息