user-zh
文章
日期
较舊的信息
较新的信息
文章索引
回复: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
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
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
较舊的信息
较新的信息