user-zh
文章
日期
较舊的信息
较新的信息
文章索引
[ANNOUNCE] Apache Flink Kubernetes Operator 1.3.1 released
Gyula Fóra
任务本地运行正常,提交到集群报错 - 图片挂掉,文字贴一下报错信息,非常抱歉打扰
WD.Z
Re: 任务本地运行正常,提交到集群报错 - 图片挂掉,文字贴一下报错信息,非常抱歉打扰
yidan zhao
Re: 任务本地运行正常,提交到集群报错 - 图片挂掉,文字贴一下报错信息,非常抱歉打扰
weijie guo
任务本地运行正常,提交到集群报错 - 图片挂掉了重发一下
WD.Z
任务本地运行正常,提交到集群报错
WD.Z
flink自带的web ui为什么不能提供一个触发生成保存点的按钮?
casel.chen
回复:flink自带的web ui为什么不能提供一个触发生成保存点的按钮?
朱文忠
flink-kubernetes-operator部署问题
圣 万
Re: flink-kubernetes-operator部署问题
Weihua Hu
使用 WindowDeduplicate 时,数据没有按照期望的时效写入sink 端
lk_hadoop
请问cancel的任务能够恢复running状态吗?
陈佳豪
回复:请问cancel的任务能够恢复running状态吗?
DannyLau
Re: 请问cancel的任务能够恢复running状态吗?
Weihua Hu
Re: 请问cancel的任务能够恢复running状态吗?
yidan zhao
Re: checkpoint首次触发时间疑问
Jiangang Liu
flink任务重启后监控指标从0开始重新统计
孙路昊
Re: flink任务重启后监控指标从0开始重新统计
XJ Li
Re:flink如何调用py模型
RS
为何雪花算法的udf 每次执行的结果都一样,如何能像UUID一样每次变化
799590...@qq.com.INVALID
如何查看Flink on Native K8s模式下失败作业的日志
hjw
Re:如何查看Flink on Native K8s模式下失败作业的日志
RS
Re:Re:如何查看Flink on Native K8s模式下失败作业的日志
hjw
退订
DannyLau
Re: 退订
Lijie Wang
[ANNOUNCE] Apache flink-connector-rabbitmq 3.0.0 released
Martijn Visser
[ANNOUNCE] Apache flink-connector-jdbc 3.0.0 released
Martijn Visser
[ANNOUNCE] Apache flink-connector-pulsar 3.0.0 released
Martijn Visser
来自Lynn Chen的邮件
Lynn Chen
退订
DannyLau
RE: Re: 【PyFlink】对于数据以Csv()格式写入kafka报错,以及使用python udf时无法启动udf
kung harold
关于flink sql调用python udf失败的问题
kung harold
flink sql connector options如何支持Map数据类型?
casel.chen
Re: flink sql connector options如何支持Map数据类型?
Weihua Hu
Re:Re: flink sql connector options如何支持Map数据类型?
casel.chen
Re:flink sql connector options如何支持Map数据类型?
RS
Re:Re:flink sql connector options如何支持Map数据类型?
casel.chen
Re:Re:Re:flink sql connector options如何支持Map数据类型?
RS
Re:Re:Re:Re:flink sql connector options如何支持Map数据类型?
casel.chen
[ANNOUNCE] Apache Flink Kubernetes Operator 1.3.0 released
Őrhidi Mátyás
Re: [ANNOUNCE] Apache Flink Kubernetes Operator 1.3.0 released
Biao Geng
Re: HiveServer2 Endpoint只支持Hive3.1以上版本吗
yuxia
flink-gelly官方文档
Jason_H
Re: flink-gelly官方文档
guozhi mang
回复: flink-gelly官方文档
Jason_H
Flink 中的类加载KafkaSerializerWrapper
wangshuai
Re: 使用flink 动态广播mysql数据报错
yidan zhao
关于Flink重启策略疑惑
李义
Re: 关于Flink重启策略疑惑
weijie guo
flink kubernetes operator生产环境配置
谭家良
提交任务不能指定第三方jar
melin li
Re: 提交任务不能指定第三方jar
yuxia
Re: 提交任务不能指定第三方jar
melin li
Re: 提交任务不能指定第三方jar
melin li
Re:Re: 提交任务不能指定第三方jar
RS
flink 1.16 lookup join重试策略问题
casel.chen
Re: flink 1.16 lookup join重试策略问题
Lincoln Lee
flink on native k8s模式调度能否根据节点磁盘和网络io指标进行调度?
casel.chen
flink sql是否支持延迟lookup join?
casel.chen
flink web ui 提交任务报错
朱文忠
1.15.2作业频繁(每 几十分钟 ~ 1小时)报 LocalTransportException: readAddress(..) failed: Connection timed out .
yidan zhao
Re: 1.15.2作业频繁(每 几十分钟 ~ 1小时)报 LocalTransportException: readAddress(..) failed: Connection timed out .
yidan zhao
Re: 1.15.2作业频繁(每 几十分钟 ~ 1小时)报 LocalTransportException: readAddress(..) failed: Connection timed out .
yidan zhao
flink executeAsync()
guanyq
flink sql滑动窗口问题
谭家良
flink on k8s节点网络io飙高问题如何解决?
casel.chen
Re:flink on k8s节点网络io飙高问题如何解决?
casel.chen
flink sql消费upsert-kafka源表如何指定从哪个位点开始消费?
casel.chen
回复:flink sql消费upsert-kafka源表如何指定从哪个位点开始消费?
JasonLee
Re:回复:flink sql消费upsert-kafka源表如何指定从哪个位点开始消费?
casel.chen
sql查询数据库不走索引
杨扬
Re: sql查询数据库不走索引
杨扬
Re: sql查询数据库不走索引
Shammon FY
FLINK postgresql CDC 报语法错误
bmw
Re:FLINK postgresql CDC 报语法错误
bmw
ElasticsearchSink 设置es 主分片数
allanqinjy
flink sql有办法获取到rowkind元数据字段吗?
casel.chen
flink sql作业无缝升级问题
casel.chen
Re: flink sql作业无缝升级问题
Jiangang Liu
Re: flink sql作业无缝升级问题
yidan zhao
Re:Re: flink sql作业无缝升级问题
casel.chen
Re: Re: flink sql作业无缝升级问题
yidan zhao
flink sql接cdc数据源按最新数据统计问题
casel.chen
Re: flink sql接cdc数据源按最新数据统计问题
Leonard Xu
Flink Kubernetes Operator何时会保留JobManager
hjw
请问flink sql可以被捕获异常吗?
陈佳豪
如果一个hive 数据库同时有hudi表和parquet,需要注册两个catalog?
melin li
Flink Kubernetes Operator何时会保留JobManager Pod
hjw
Re: Flink Kubernetes Operator何时会保留JobManager Pod
Biao Geng
Re:Re: Flink Kubernetes Operator何时会保留JobManager Pod
hjw
Flink Kubernetes Operator何时会保留JobManager Pod
hjw
怎样从flink执行计划json生成StreamGraph?
casel.chen
Re: 怎样从flink执行计划json生成StreamGraph?
yidan zhao
Re:Re: 怎样从flink执行计划json生成StreamGraph?
casel.chen
Re: Re: 怎样从flink执行计划json生成StreamGraph?
yidan zhao
回复: Re: 怎样从flink执行计划json生成StreamGraph?
仙路尽头谁为峰
Re:回复: Re: 怎样从flink执行计划json生成StreamGraph?
casel.chen
回复: 回复: Re: 怎样从flink执行计划json生成StreamGraph?
仙路尽头谁为峰
请问flink metrics如何获取任务状态?
陈佳豪
回复:请问flink metrics如何获取任务状态?
陈佳豪
回复:请问flink metrics如何获取任务状态?
m17610775726_1
Re:回复:请问flink metrics如何获取任务状态?
陈佳豪
Re:回复:请问flink metrics如何获取任务状态?
陈佳豪
如何扩展flink sql以实现延迟调用?
casel.chen
Re:如何扩展flink sql以实现延迟调用?
casel.chen
Re: 如何扩展flink sql以实现延迟调用?
Lincoln Lee
Re:Re: 如何扩展flink sql以实现延迟调用?
casel.chen
Re:Re: 如何扩展flink sql以实现延迟调用?
casel.chen
Flink jdbc base-url 格式限制探讨
melin li
[ANNOUNCE] Apache Flink 1.15.3 released
Fabian Paul
flink-kafka-connector 消费时获取不到topic-paitition
朱文忠
flink 1.15.3 已发布,但 maven repo 库中,暂无 1.15.3 的依赖
highfei2011
Pyflink提交
程龙
Re: Pyflink提交
Dian Fu
Re: Pyflink提交
Xingbo Huang
flink 新特性
guanyq
Re: flink 新特性
guozhi mang
支持oracle、sqlserver、db2 jdbc catalog
melin li
Re: 支持oracle、sqlserver、db2 jdbc catalog
melin li
回复:如何能正确的获取任务总写入量?
JasonLee
Re: 回复:Flink HIve 文件压缩报错
yuxia
如何使用flink sql优雅的处理大量嵌套if-else逻辑
casel.chen
Re: 如何使用flink sql优雅的处理大量嵌套if-else逻辑
macia kk
动态按需注册catalog
melin li
Optimize ApplicationDeployer API design
melin li
Re: Optimize ApplicationDeployer API design
Yang Wang
Re: Optimize ApplicationDeployer API design
melin li
Support Stored procedures
melin li
flink作业提交运行后如何监听作业状态发生变化?
casel.chen
Re:flink作业提交运行后如何监听作业状态发生变化?
RS
Re:Re:flink作业提交运行后如何监听作业状态发生变化?
casel.chen
Re: flink作业提交运行后如何监听作业状态发生变化?
TonyChen
回复:flink作业提交运行后如何监听作业状态发生变化?
JasonLee
Re: flink作业提交运行后如何监听作业状态发生变化?
Yang Wang
Re:Re: flink作业提交运行后如何监听作业状态发生变化?
casel.chen
Re: flink作业提交运行后如何监听作业状态发生变化?
TonyChen
如何扩展flink sql以支持CTAS/CDAS语句?
casel.chen
如何扩展flink sql以支持CTAS/CDAS语句?
casel.chen
Re: 如何扩展flink sql以支持CTAS/CDAS语句?
Shengkai Fang
Re:Re: 如何扩展flink sql以支持CTAS/CDAS语句?
casel.chen
如何正确扩展jdbc connector以支持更多的数据库方言?
casel.chen
debezium-json数据timestamp类型时区问题
Kyle Zhang
Re: debezium-json数据timestamp类型时区问题
Leonard Xu
Flink启动python任务异常:undefined symbol: _Py_LegacyLocaleDetected
RS
Re: Flink启动python任务异常:undefined symbol: _Py_LegacyLocaleDetected
Xingbo Huang
Re:Re: Flink启动python任务异常:undefined symbol: _Py_LegacyLocaleDetected
RS
Re:Re:Re: Flink启动python任务异常:undefined symbol: _Py_LegacyLocaleDetected
RS
Re: Re: Flink启动python任务异常:undefined symbol: _Py_LegacyLocaleDetected
Xingbo Huang
Re: flink1.15.2无论blob.server.port设置什么端口范围,都会报错
yidan zhao
Re: flink sql 类型转化遇到转化失败时候可以跳过这条数据嘛
Shuo Cheng
flink 1.16 kafka 流和自定义流collect后,watermark 消失
Peihui He
Re: flink 1.16 kafka 流和自定义流collect后,watermark 消失
Tony Wei
来自古月的邮件
古月
Re: 来自古月的邮件
JunRui Lee
flinksql join
Jason_H
Re: flinksql join
Zhiwen Sun
Re: flinksql join
Jason_H
Re: flinksql join
Jason_H
Re: flinksql join
Jason_H
Re:flinksql join
RS
Re: flinksql join
Jason_H
Re: flinksql join
Jason_H
Re: flinksql join
Jason_H
Re: flinksql join
Zhiwen Sun
[ACCOUNCE] Apache Flink Elasticsearch Connector 3.0.0 released
Chesnay Schepler
Re: [ACCOUNCE] Apache Flink Elasticsearch Connector 3.0.0 released
Martijn Visser
Re: [ACCOUNCE] Apache Flink Elasticsearch Connector 3.0.0 released
Leonard Xu
Re: [ACCOUNCE] Apache Flink Elasticsearch Connector 3.0.0 released
Ryan Skraba
batch mode如何同步等待执行结果
唐世伟
Re: batch mode如何同步等待执行结果
yuxia
Re: batch mode如何同步等待执行结果
唐世伟
Re: batch mode如何同步等待执行结果
weijie guo
FeatHub - 一个基于Flink的开源实时特征工程平台
Dong Lin
Re:FeatHub - 一个基于Flink的开源实时特征工程平台
kanata163
Re: FeatHub - 一个基于Flink的开源实时特征工程平台
Dong Lin
flink sql作业动态设置告警规则问题
casel.chen
Re: 设置slot是vcore的几倍会有什么影响
Yanfei Lei
Re: flink on k8s 提交作业,使用 oss 作为 checkpoint 地址,但找不到 oss
Lijie Wang
Re:flink-sql读取kafka Source并行度问题
Xuyang
flink cdc 全量拉取阶段, 会等所有的chunk 都拉取成功后, 才output到下游吗?
郑 致远
Re: flink cdc 全量拉取阶段, 会等所有的chunk 都拉取成功后, 才output到下游吗?
Guo Thompson
FlinkCDC可以读到MySQL变更数据,但是插不到新的MySQL表里
左岩
Re:回复: FlinkCDC可以读到MySQL变更数据,但是插不到新的MySQL表里
左岩
Re: 回复: FlinkCDC可以读到MySQL变更数据,但是插不到新的MySQL表里
Shengkai Fang
Re:Re: 回复: FlinkCDC可以读到MySQL变更数据,但是插不到新的MySQL表里
左岩
Re: FlinkCDC可以读到MySQL变更数据,但是插不到新的MySQL表里
Leonard Xu
flinkcdc 读不到mysql中数据
左岩
Re: flinkcdc 读不到mysql中数据
Leonard Xu
Re: flinkcdc 读不到mysql中数据
yinghua_zh
Re: flink1.14.5报错提示 “无法编译表程序。这是一个bug。请提交一个问题。”
ron
Flink CDC 打宽表
Fei Han
Re: Flink CDC 打宽表
Leonard Xu
Remote system has been silent for too long. (more than 48.0 hours)
casel.chen
Re: Remote system has been silent for too long. (more than 48.0 hours)
Weihua Hu
Re: Remote system has been silent for too long. (more than 48.0 hours)
Guo Thompson
Re:????????????????????????????
Xuyang
flink exactly once 写kafka,如果checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢?
郑 致远
Re:flink exactly once 写kafka,如果checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢?
Xuyang
回复: Re:flink exactly once 写kafka,如果checkpoint超时了导致kafka的transaction在commit之前也超时了, flink会怎么处理呢?
郑 致远
【SQL Gateway - HiveServer2】UnsupportedOperationException: Unrecognized TGetInfoType value: CLI_ODBC_KEYWORDS.
QiZhu Chan
较舊的信息
较新的信息