user-zh
文章
日期
较舊的信息
较新的信息
文章索引
关于flinksql聚合函数实现的学习疑问
hdxg1101300...@163.com
Re: 关于flinksql聚合函数实现的学习疑问
Lincoln Lee
Re: 关于flinksql聚合函数实现的学习疑问
陈铜玖
Re:关于flinksql聚合函数实现的学习疑问
Xuyang
flink key by 逻辑疑问
Peihui He
Re: flink key by 逻辑疑问
yidan zhao
Re: flink key by 逻辑疑问
Shengkai Fang
Re:flink key by 逻辑疑问
Xuyang
Flink-1.15.0 在使用cumulate window报key group 不在范围内的错误
zhangbin
Re: Flink-1.15.0 在使用cumulate window报key group 不在范围内的错误
godfrey he
Re: Flink-1.15.0 在使用cumulate window报key group 不在范围内的错误
godfrey he
Flink异步IO使用问题
lxk7...@163.com
回复: Flink异步IO使用问题
lxk7...@163.com
Re: Flink异步IO使用问题
Weihua Hu
Re: flinksql关联hive维表java.lang.UnsupportedOperationException错误
Jingsong Li
Re: Re: flinksql关联hive维表java.lang.UnsupportedOperationException错误
Jingsong Li
Re: 1.13.5版本sql大小64k限制bug
Yun Tang
Re: 1.13.5版本sql大小64k限制bug
godfrey he
Re: 1.13.5版本sql大小64k限制bug
Lincoln Lee
Re: 1.13.5版本sql大小64k限制bug
xianbin mo
Kafka source 检测到分区变更时发生 WakeupException
邹璨
Re: Kafka source 检测到分区变更时发生 WakeupException
Qingsheng Ren
pyflink报错:Java gateway process exited before sending its port number
RS
Re: pyflink报错:Java gateway process exited before sending its port number
Dian Fu
Re:Re: pyflink报错:Java gateway process exited before sending its port number
RS
Some question with Flink state
lxk7...@163.com
Re: Some question with Flink state
Hangxiang Yu
Re: Re: Some question with Flink state
lxk7...@163.com
Re: Re: Some question with Flink state
Hangxiang Yu
Re: Re: Some question with Flink state
lxk7...@163.com
Re: Re: Some question with Flink state
lxk7...@163.com
Re:Re: Re: Some question with Flink state
Xuyang
Re: Re: Some question with Flink state
lxk7...@163.com
Re: Re: Some question with Flink state
lxk7...@163.com
Re:Re: Re: Some question with Flink state
Xuyang
Re: Re: Some question with Flink state
lxk7...@163.com
Re: Re: Some question with Flink state
lxk7...@163.com
Re:Re: Re: Some question with Flink state
Xuyang
Re: Re: Some question with Flink state
lxk7...@163.com
Re: Re: Some question with Flink state
lxk7...@163.com
Re: [Internet]Re: Re: Some question with Flink state
罗凯
Re: Re: [Internet]Re: Re: Some question with Flink state
lxk7...@163.com
Re:Re: Re: [Internet]Re: Re: Some question with Flink state
Xuyang
在自定义表聚合函数 TableAggregateFunction 使用 emitUpdateWithRetract 异常
赢峰
Re:在自定义表聚合函数 TableAggregateFunction 使用 emitUpdateWithRetract 异常
Xuyang
Re:Re:在自定义表聚合函数 TableAggregateFunction 使用 emitUpdateWithRetract 异常
sjf0115
Re:Re:Re:在自定义表聚合函数 TableAggregateFunction 使用 emitUpdateWithRetract 异常
sjf0115
Re:Re:Re:Re:在自定义表聚合函数 TableAggregateFunction 使用 emitUpdateWithRetract 异常
Xuyang
Re:Re:Re:Re:Re:在自定义表聚合函数 TableAggregateFunction 使用 emitUpdateWithRetract 异常
sjf0115
22/05/2022 22:28:33 自动保存草稿
赢峰
如何进行主页中文翻译任务
邢振宇
Re: 如何进行主页中文翻译任务
Zhilong Hong
flink rest 接口部分数据不返回,返回空,状态200正常。
yidan zhao
Re:flink rest 接口部分数据不返回,返回空,状态200正常。
Xuyang
Re: flink rest 接口部分数据不返回,返回空,状态200正常。
yidan zhao
Re: flink rest 接口部分数据不返回,返回空,状态200正常。
Shengkai Fang
Re: flink rest 接口部分数据不返回,返回空,状态200正常。
yidan zhao
Re: flink rest 接口部分数据不返回,返回空,状态200正常。
yidan zhao
Re: flink rest 接口部分数据不返回,返回空,状态200正常。
Weihua Hu
Re: flink rest 接口部分数据不返回,返回空,状态200正常。
yidan zhao
s3p 如果在本地调试
z y xing
Re: s3p 如果在本地调试
Weihua Hu
Re: s3p 如果在本地调试
邢振宇
[ANNOUNCE] Call for Presentations for ApacheCon Asia 2022 streaming track
Yu Li
Re:[ANNOUNCE] Call for Presentations for ApacheCon Asia 2022 streaming track
hamster
Upgrade help
yinghua_zh
????????Job??????TaskManager ??????oom?
????????
Re: 反复提交Job会导致TaskManager 元空间oom?
yu'an huang
??????????????Job??????TaskManager ??????oom?
????????
Re: 反复提交Job会导致TaskManager 元空间oom?
LuNing Wang
Re: 反复提交Job会导致TaskManager 元空间oom?
tison
Re:如何更新中文文档?
Xuyang
flink on k8s native开启ha后根据sp启动任务报错找不到job id 0000
shimin huang
Re: flink on k8s native开启ha后根据sp启动任务报错找不到job id 0000
Weihua Hu
Re: flink on k8s native开启ha后根据sp启动任务报错找不到job id 0000
shimin huang
BatchTableEnvironment读取parquet文件问题
贺星
Re: BatchTableEnvironment读取parquet文件问题
yuxia
回复:DataStream 转换 Table 后事件时间不对
renzhaojin
Re:回复:DataStream 转换 Table 后事件时间不对
赢峰
??????DataStream ???? Table ??????????????
??????~
DataStream 转换 Table 后事件时间不对
赢峰
BigDecimal数据转为指定精度的DecimalData,为什么要用
happygoing
Re:BigDecimal数据转为指定精度的DecimalData,为什么要用
Xuyang
oss checkpoint fail
json
转发:基于flink sql作业失败与取消状况下的作业参数设置咨询(flink-1.14.2)
徐战辉
Re: 转发:基于flink sql作业失败与取消状况下的作业参数设置咨询(flink-1.14.2)
yuxia
回复: 转发:基于flink sql作业失败与取消状况下的作业参数设置咨询(flink-1.14.2)
徐战辉
回复:基于flink sql作业失败与取消状况下的作业参数设置咨询(flink-1.14.2)
徐战辉
基于flink sql作业失败与取消状况下的作业参数设置咨询(flink-1.14.2)
徐战辉
Re:基于flink sql作业失败与取消状况下的作业参数设置咨询(flink-1.14.2)
RS
Flink Application + HA与HistoryServer的使用问题
谭家良
Re: Flink Application + HA与HistoryServer的使用问题
Yang Wang
回复: Flink Application + HA与HistoryServer的使用问题
谭家良
[ANNOUNCE] Apache Flink Table Store 0.1.0 released
Jingsong Lee
Re: [ANNOUNCE] Apache Flink Table Store 0.1.0 released
Becket Qin
flink sql无法读取Hive映射的HBase表
18579099...@163.com
Re: flink sql无法读取Hive映射的HBase表
Shengkai Fang
Re: flink sql无法读取Hive映射的HBase表
yuxia
Re: Re: flink sql无法读取Hive映射的HBase表
18579099...@163.com
Re: flink sql无法读取Hive映射的HBase表
yuxia
Re: Re: flink sql无法读取Hive映射的HBase表
18579099...@163.com
Re: Re: flink sql无法读取Hive映射的HBase表
Jingsong Li
Re: Re: flink sql无法读取Hive映射的HBase表
18579099...@163.com
Re: Re: flink sql无法读取Hive映射的HBase表
Jingsong Li
【Could we support distribute by For FlinkSql】
lpengdr...@163.com
Flink通过Phoenix写入Hbase
angus
回复: Flink通过Phoenix写入Hbase
angus
CsvReaderFormat类的位置
wangxzr
Re: CsvReaderFormat类的位置
Shengkai Fang
Re: confirm unsubscribe from user-zh@flink.apache.org
zh...@greatld.com
flink kubernetes application模式下作业镜像问题
casel.chen
Re: flink kubernetes application模式下作业镜像问题
mefor sy
Re: flink kubernetes application模式下作业镜像问题
yu'an huang
关于配置文件中的明文密码问题。
风
[ANNOUNCE] Apache Flink 1.15.0 released
Yun Gao
Re: [ANNOUNCE] Apache Flink 1.15.0 released
Martijn Visser
Pull request 的 CI build 不能自动触发
mefor sy
Re:Pull request 的 CI build 不能自动触发
Xuyang
Re: Pull request 的 CI build 不能自动触发
mefor sy
Table API filter scala表达方式提示类型不匹配
Arthur Li
Re: Table API filter scala表达方式提示类型不匹配
Arthur Li
Flink - 1.11.6 - FsStateBackend没有存储checkpoint
Arthur Li
Re: Flink - 1.11.6 - FsStateBackend没有存储checkpoint
Arthur Li
flink 1.14
guanyq
Re:flink 1.14
RS
Re: flink 1.14
yidan zhao
Flink native kubernetes 下没有足够的 slot 问题
Pan Junxun
Re: Flink native kubernetes 下没有足够的 slot 问题
Pan Junxun
Re: Flink native kubernetes 下没有足够的 slot 问题
huweihua
Re: Flink native kubernetes 下没有足够的 slot 问题
Pan Junxun
Re: Flink native kubernetes 下没有足够的 slot 问题
Pan Junxun
Re: Flink native kubernetes 下没有足够的 slot 问题
huweihua
Re: Flink native kubernetes 下没有足够的 slot 问题
Pan Junxun
Re: Flink native kubernetes 下没有足够的 slot 问题
Pan Junxun
?????? ??Flink Table Store????
??????
?????? ??Flink Table Store????
??????
?????? ??Flink Table Store????
??????
Flink Kubernetes Operator helm????????
??????
job????????????job??
????????
Re: job运行如何指定job名
ruiyun wan
?????? job????????????job??
????????
关于使用SQL Client提交执行目标为yarn-per-job的作业时无日志文件(jobmanager.log)的求助
ruiyun wan
Re: 关于使用SQL Client提交执行目标为yarn-per-job的作业时无日志文件(jobmanager.log)的求助
Qishang
Re: 关于使用SQL Client提交执行目标为yarn-per-job的作业时无日志文件(jobmanager.log)的求助
ruiyun wan
Re: 关于使用SQL Client提交执行目标为yarn-per-job的作业时无日志文件(jobmanager.log)的求助
Qishang
Re: 关于使用SQL Client提交执行目标为yarn-per-job的作业时无日志文件(jobmanager.log)的求助
Qishang
Re: 关于使用SQL Client提交执行目标为yarn-per-job的作业时无日志文件(jobmanager.log)的求助
ruiyun wan
????io????????????
San
????helm??Flink Kubernetes Operator ????
??????
Re: 安装helm的Flink Kubernetes Operator 失败
Biao Geng
Flink SQL??????Java code????debug
zhiyezou
Re:Flink SQL??????Java code????debug
Xuyang
flink ????????k8s????????jar??????????
????????
Re: flink 任务对接k8s的第三方jar包管理问题
zns
Re: flink 任务对接k8s的第三方jar包管理问题
Yang Wang
flink ????????k8s????????jar??????????
????????
Re: flink 任务对接k8s的第三方jar包管理问题
yu'an huang
flink ????
????????
FlinkSQL ????k8s??????????
??????
Re: FlinkSQL 对接k8s的提交问题
LuNing Wang
?????? FlinkSQL ????k8s??????????
??????
Re: FlinkSQL 对接k8s的提交问题
Yang Wang
FlinkSQL
??????
??Flink Table Store????
??????
Re: 对Flink Table Store咨询
tison
Re: 对Flink Table Store咨询
Jingsong Li
?????? ??Flink Table Store????
??????
Flink MySQL CDC 注册 schema registry 问题
casel.chen
关于Flink1.15文档,有一些小疑惑求助
林影
Re: 关于Flink1.15文档,有一些小疑惑求助
Jiangang Liu
Re: 关于Flink1.15文档,有一些小疑惑求助
林影
Flink on yarn ,并行度>1的情况下,怎么获取springboot的bean?
duwenwen
Re: Flink on yarn ,并行度>1的情况下,怎么获取springboot的bean?
Paul Lam
Re: Flink on yarn ,并行度>1的情况下,怎么获取springboot的bean?
tison
JobManager doesn't bring up new TaskManager during failure recovery
Zheng, Chenyu
JobManager doesn't bring up new TaskManager during failure recovery
Zheng, Chenyu
Re: JobManager doesn't bring up new TaskManager during failure recovery
Yang Wang
Re: JobManager doesn't bring up new TaskManager during failure recovery
Zheng, Chenyu
Re: JobManager doesn't bring up new TaskManager during failure recovery
Zheng, Chenyu
Re: JobManager doesn't bring up new TaskManager during failure recovery
Yang Wang
Re: JobManager doesn't bring up new TaskManager during failure recovery
Zheng, Chenyu
flink cdc 时间格式和时区问题
casel.chen
web ui中能查看到job失败的原因吗?
weishishuo...@163.com
Re: web ui中能查看到job失败的原因吗?
Hangxiang Yu
flink添加表的comment信息无效
草莓
flink-connector和flink-sql-connector的区别
weishishuo...@163.com
Re: flink-connector和flink-sql-connector的区别
Shengkai Fang
使用自定义函数报入参填写字段名报Cannot load user class: com.example.udf.SubStr,填写字符串正常
799590...@qq.com.INVALID
K8s ?????? Broken pipe (Write failed) ????
??????
flink??Thread Dump????
??????
Re: flink的Thread Dump日志
Zhanghao Chen
The file STDOUT does not exist on the TaskExecutor ????
??????
Re: The file STDOUT does not exist on the TaskExecutor 异常
Zhilong Hong
?????? The file STDOUT does not exist on the TaskExecutor ????
??????
Filnk: Job leader for job id xxxx lost leadership
magic
Re: Filnk: Job leader for job id xxxx lost leadership
Zhanghao Chen
Re: Filnk: Job leader for job id xxxx lost leadership
huweihua
Python callback server start failed
799590...@qq.com.INVALID
Re: Python callback server start failed
Dian Fu
Re: Re: Python callback server start failed
799590...@qq.com.INVALID
较舊的信息
较新的信息