user-zh
文章
日期
较舊的信息
较新的信息
文章索引
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
Re: Re: Python callback server start failed
Dian Fu
Re: Re: Python callback server start failed
799590...@qq.com.INVALID
Re: Re: Python callback server start failed
Dian Fu
flink发布集群端运行,如何在sink或source中使用springboot的bean
676360...@qq.com.INVALID
回复: flink发布集群端运行,如何在sink或source中使用springboot的bean
wch...@163.com
flinkcdc??oracle ????
??????
conf??????flink????????????
??????
conf??????flink????????????
??????
Re: conf目录中flink配置文件参数
Shengkai Fang
(无主题)
王健
Re: (无主题)
Shengkai Fang
(无主题)
zehir.tong
(无主题)
zehir.tong
Re:(无主题)
Xuyang
(无主题)
zhufangliang
(无主题)
李朋
(无主题)
Paul
Re: (无主题)
Weihua Hu
回复:(无主题)
海风
(无主题)
willluzheng
Re: (无主题)
Xuannan Su
Flink OLAP 与 Trino TPC-DS 对比
LuNing Wang
Re: Flink OLAP 与 Trino TPC-DS 对比
LuNing Wang
Re: Flink OLAP 与 Trino TPC-DS 对比
Zhilong Hong
Re: Flink OLAP 与 Trino TPC-DS 对比
LuNing Wong
Re: Flink OLAP 与 Trino TPC-DS 对比
LuNing Wong
Re: Flink OLAP 与 Trino TPC-DS 对比
LuNing Wang
Re: Flink OLAP 与 Trino TPC-DS 对比
Zhilong Hong
Re: Flink OLAP 与 Trino TPC-DS 对比
Yu Li
Re: Flink OLAP 与 Trino TPC-DS 对比
LuNing Wang
Re: Flink OLAP 与 Trino TPC-DS 对比
Zhilong Hong
flink on native k8s NodePort方式启动任务后返回的jobmanager web ui的地址不是集群中的ip
shimin huang
Re: flink on native k8s NodePort方式启动任务后返回的jobmanager web ui的地址不是集群中的ip
shimin huang
Re: flink on native k8s NodePort方式启动任务后返回的jobmanager web ui的地址不是集群中的ip
huweihua
退订
王健
Re: flink on native k8s NodePort方式启动任务后返回的jobmanager web ui的地址不是集群中的ip
shimin huang
Re: flink on native k8s NodePort方式启动任务后返回的jobmanager web ui的地址不是集群中的ip
shimin huang
Re: flink on native k8s NodePort方式启动任务后返回的jobmanager web ui的地址不是集群中的ip
huweihua
Re: flink on native k8s NodePort方式启动任务后返回的jobmanager web ui的地址不是集群中的ip
shimin huang
flink sink ES7 ??????Invalid lambda deserialization
????????
Re:flink sink ES7 报错:Invalid lambda deserialization
wangzhen
Re: flink sink ES7 报错:Invalid lambda deserialization
Shengkai Fang
Re: flink sink ES7 报错:Invalid lambda deserialization
Shengkai Fang
[flink-yarn]&[flink-metrics]&[influxdb] Yarn session模式下提交多个Job,只有首次提交的Job有Metrics数据上报
QiZhu Chan
Re: [flink-yarn]&[flink-metrics]&[influxdb] Yarn session模式下提交多个Job,只有首次提交的Job有Metrics数据上报
huweihua
flink on k8s NodePort方式提交本人返回的jm的url和容器ip不一致,导致无法访问
shimin huang
Re: flink on k8s NodePort方式提交本人返回的jm的url和容器ip不一致,导致无法访问
shimin huang
Re: flink on k8s NodePort方式提交本人返回的jm的url和容器ip不一致,导致无法访问
huweihua
Re: flink on k8s NodePort方式提交本人返回的jm的url和容器ip不一致,导致无法访问
shimin huang
Flink Kubernetes Operator
casel.chen
Re:Flink Kubernetes Operator
casel.chen
Re: Flink Kubernetes Operator
Yang Wang
Native Kubernetes ????????????????
??????
Re: Native Kubernetes 模式提交任务异常
yu'an huang
Re: Native Kubernetes 模式提交任务异常
yidan zhao
?????? Native Kubernetes ????????????????
??????
Re: Native Kubernetes 模式提交任务异常
huweihua
Re: Native Kubernetes 模式提交任务异常
huweihua
JobManager自定义log4j.properties不生效问题
QQ
Re: JobManager自定义log4j.properties不生效问题
huweihua
回复:JobManager自定义log4j.properties不生效问题
gangzi
Re: JobManager自定义log4j.properties不生效问题
huweihua
flinksql执行时提示自定义UDF无法加载的
799590...@qq.com.INVALID
Re: flinksql执行时提示自定义UDF无法加载的
Zhanghao Chen
flink命令行参数不生效问题
gangzi
Re: flink命令行参数不生效问题
Zhanghao Chen
Re: flink命令行参数不生效问题
QQ
Re: flink命令行参数不生效问题
Zhanghao Chen
日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
段晓雄
Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
yidan zhao
RE: Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
段晓雄
Re: Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
Zhanghao Chen
RE: Re: Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
段晓雄
Re: Re: Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
Zhanghao Chen
RE: Re: Re: Re: 日志里提示 The state is cleared because of state ttl. This will result in incorrect result 如何解决?
段晓雄
flink jdbc connector不支持source
casel.chen
Re: flink jdbc connector不支持source
Qingsheng Ren
yarn api 提交报错
周涛
Re:yarn api 提交报错
Mang Zhang
Re:Re:yarn api 提交报错
周涛
Re:Re:Re:yarn api 提交报错
Mang Zhang
答复: Re:Re:yarn api 提交报错
Geng Biao
flink sql 任务中jm Blob server 总是在凌晨报 java.io.exception :unknow opreation 71
su wenwen
Re:flink sql 任务中jm Blob server 总是在凌晨报 java.io.exception :unknow opreation 71
Mang Zhang
k8s session cluster flink1.13.6创建后提示的地址啥用。
yidan zhao
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
Zhanghao Chen
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
yu'an huang
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
yidan zhao
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
yidan zhao
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
yidan zhao
Re: k8s session cluster flink1.13.6创建后提示的地址啥用。
Zhanghao Chen
flink table store
yidan zhao
Re: flink table store
LuNing Wang
Re: flink table store
Xianxun Ye
Re: flink table store
Leonard Xu
Re: flink table store
tison
Re: flink table store
Paul Lam
flink1.1.36用SQL方式如何设置输出到hive表为upsert模式?
799590...@qq.com.INVALID
Re: flink1.1.36用SQL方式如何设置输出到hive表为upsert模式?
LuNing Wang
[ANNOUNCE] Apache Flink Kubernetes Operator 0.1.0 released
Gyula Fóra
flink 1.15
guanyq
Re: flink 1.15
Zhanghao Chen
如何条件查询不扫描全表
汪赟
Re: 如何条件查询不扫描全表
Shengkai Fang
Could you please give me a hand about json object in flink sql
wang
Re:Could you please give me a hand about json object in flink sql
Mang Zhang
How can I set job parameter in flink sql
wang
How can I set job parameter in flink sql
wang
Re: How can I set job parameter in flink sql
yuxia
Re:Re: How can I set job parameter in flink sql
wang
Does kafka key is supported in kafka sink table
wang
Re: Does kafka key is supported in kafka sink table
Dhavan Vaidya
Re: Does kafka key is supported in kafka sink table
Shengkai Fang
GlobalCommitter in Flink's two-phase commit
di wu
Re: GlobalCommitter in Flink's two-phase commit
Jing Ge
Re: Disable the chain of the Sink operator
Shammon FY
Re: Disable the chain of the Sink operator
wudi
Re: Disable the chain of the Sink operator
weijie guo
Re: Disable the chain of the Sink operator
Chesnay Schepler
Re: Disable the chain of the Sink operator
wudi
Re: Disable the chain of the Sink operator
Shammon FY
Re: Disable the chain of the Sink operator
wudi
LinkedMap ClassCastException issue
wang
Re: LinkedMap ClassCastException issue
Shengkai Fang
Does flink sql support UDTAGG
wang
Re:Does flink sql support UDTAGG
Xuyang
Re:Re:Does flink sql support UDTAGG
wang
Re: Re:Does flink sql support UDTAGG
Weihua Hu
Watermark generating mechanism in Flink SQL
wang
Re: Watermark generating mechanism in Flink SQL
Matthias Pohl
Whether Flink SQL window operations support "Allow Lateness and SideOutput"?
wang
Re: Whether Flink SQL window operations support "Allow Lateness and SideOutput"?
Weihua Hu
flink jdbc source oom
Peihui He
Re: flink jdbc source oom
r pp
Re: flink jdbc source oom
Lincoln Lee
Re:Re: flink jdbc source oom
Michael Ran
Re: Re: flink jdbc source oom
r pp
Re: Re: flink jdbc source oom
r pp
Re: flink jdbc source oom
Guo Thompson
flink on k8s场景,大家一般如何解决访问hdfs的问题呢。
yidan zhao
Re:flink on k8s场景,大家一般如何解决访问hdfs的问题呢。
casel.chen
Re: flink on k8s场景,大家一般如何解决访问hdfs的问题呢。
LuNing Wang
flink on k8s是否有替代yarn.ship-files的参数
shimin huang
Re: flink on k8s是否有替代yarn.ship-files的参数
Geng Biao
Re: flink on k8s是否有替代yarn.ship-files的参数
shimin huang
Re: flink on k8s是否有替代yarn.ship-files的参数
yu'an huang
Re: flink on k8s是否有替代yarn.ship-files的参数
shimin huang
Re: flink on k8s是否有替代yarn.ship-files的参数
shimin huang
Hash join exceeded maximum number of recursions, without reducing partitions enough to be memory resident. Probably cause: Too many duplicate keys.
Asahi Lee
计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
yj h
Re: 计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
r pp
Re: 计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
yj h
Re: 计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
r pp
Re: 计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
yue ma
Re: 计算UV时使用了PurgingTrigger仍旧发生taskManger OOM的问题
yj h
The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
Kaiqiang XIE谢开强
Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
胡伟华
Re:Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
Kaiqiang XIE谢开强
Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
Geng Biao
Re:Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
Kaiqiang XIE谢开强
Re:Re:Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
Kaiqiang XIE谢开强
Re: The number of requested virtual cores for application master 1 exceeds the maximum number of virtual cores 0 available in the Yarn Cluster.
胡伟华
Flink本地集群监控问题
Kaiqiang
Re: Flink本地集群监控问题
Ning Xu
Re:Re: Flink本地集群监控问题
Kaiqiang XIE谢开强
flink1.12. The error message is maybe misguided
丛鹏
Re: flink1.12. The error message is maybe misguided
胡伟华
Re: flink1.12. The error message is maybe misguided
丛鹏
Re: flink1.12. The error message is maybe misguided
丛鹏
Flink ad-hoc方向问题
LuNing Wang
Re: Flink ad-hoc方向问题
Xintong Song
问题咨询: Too more data in this partition: 2147483648
Kevin Lee
使用问题咨询:Postgres 数据库作为 Catalog 时如何设置一些其他参数
17610801...@163.com
Re: 使用问题咨询:Postgres 数据库作为 Catalog 时如何设置一些其他参数
史延朋
flink-sql,对于kafka 的一些额外参数如何配置
Michael Ran
Re:flink-sql,对于kafka 的一些额外参数如何配置
RS
??????flink-sql??????kafka ??????????????????????
??????
Re:回复:flink-sql,对于kafka 的一些额外参数如何配置
Michael Ran
FLINK 实时写入HBASE性能问题
潘明文
维度表变化,关联结果全部更新在Flink SQL该如何实现
JianWen Huang
Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
zns
Re:Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
casel.chen
Re: Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
JianWen Huang
Re:Re: Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
RS
Re:Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
Michael Ran
Re: 维度表变化,关联结果全部更新在Flink SQL该如何实现
wushijjian5
设定kafka消费结束位置
李航飞
设定kafka消费结束位置
李航飞
Table Api Connectors kafka bounded
李航飞
Re:Table Api Connectors kafka bounded
RS
较舊的信息
较新的信息