user-zh
文章
日期
较舊的信息
较新的信息
文章索引
Re: [急] flink sql写数据到带主键表时能确保相同主键的记录都被同一个taskmanager处理吗?
Shengkai Fang
Re:Re: [急] flink sql写数据到带主键表时能确保相同主键的记录都被同一个taskmanager处理吗?
casel.chen
Re: Re: [急] flink sql写数据到带主键表时能确保相同主键的记录都被同一个taskmanager处理吗?
Weihua Hu
Re: Re: [急] flink sql写数据到带主键表时能确保相同主键的记录都被同一个taskmanager处理吗?
Shuo Cheng
Re:Re: Re: [急] flink sql写数据到带主键表时能确保相同主键的记录都被同一个taskmanager处理吗?
casel.chen
Re: Re: Re: [急] flink sql写数据到带主键表时能确保相同主键的记录都被同一个taskmanager处理吗?
Shuo Cheng
Re:Re: [急] flink sql写数据到带主键表时能确保相同主键的记录都被同一个taskmanager处理吗?
casel.chen
Re:Re:[急] flink sql写数据到带主键表时能确保相同主键的记录都被同一个taskmanager处理吗?
casel.chen
Re: Flink SQL 实现数组元素变换的UDF
Shammon FY
Re:Flink SQL 实现数组元素变换的UDF
casel.chen
Flink on yarn 运行一段时间出现 TaskManager with id is no longer reachable
Fei Han
Re:Flink on yarn 运行一段时间出现 TaskManager with id is no longer reachable
lxk
Re: Flink on yarn 运行一段时间出现 TaskManager with id is no longer reachable
Shammon FY
regular join每条流单独设置ttl
Jason_H
Re: regular join每条流单独设置ttl
Jane Chan
Re: regular join每条流单独设置ttl
Jane Chan
Flink程序内存Dump不了
lxk
Re: Flink程序内存Dump不了
Guo Thompson
Re:Re: Flink程序内存Dump不了
lxk
Re: Re: Flink程序内存Dump不了
Weihua Hu
Re: Re: Flink程序内存Dump不了
Biao Geng
Re:Re: Re: Flink程序内存Dump不了
lxk
运行中的作业状态清除操作
Jason_H
Re: 运行中的作业状态清除操作
Shammon FY
flink connector kafka,单条 msg 为 7kb,poll 较慢
xuhaiLong
flink canal json格式忽略不识别的type
casel.chen
Re: flink canal json格式忽略不识别的type
Shengkai Fang
Re:Re: flink canal json格式忽略不识别的type
casel.chen
Re: Re: flink canal json格式忽略不识别的type
Weihua Hu
I want to subscribe users' questions
guanyuan chen
Re: I want to subscribe users' questions
Hang Ruan
Re: I want to subscribe users' questions
yuxia
Re: Kafka 数据源无法实现基于事件时间的窗口聚合
Weihua Hu
回复: Kafka 数据源无法实现基于事件时间的窗口聚合
drewfranklin
Re: Re: Kafka 数据源无法实现基于事件时间的窗口聚合
yidan zhao
idea构建flink源码失败
tiger
Re: idea构建flink源码失败
Weihua Hu
Re: idea构建flink源码失败
Ran Tao
flink提交jar包时报连接不上BlobServer
孙冬燕
Flink消费消息队列写入HDFS
Howie Yang
Re: Flink消费消息队列写入HDFS
weijie guo
Re: Flink SQL使用hive dialect异常
yuxia
[ANNOUNCE] Apache Flink 1.16.1 released
Martijn Visser
Re: [ANNOUNCE] Apache Flink 1.16.1 released
Konstantin Knauf
Re: [ANNOUNCE] Apache Flink 1.16.1 released
weijie guo
flink 访问hive 表,怎样实现读写权限校验?
melin li
Flink SQL 如何优化以及处理反压
lxk
回复: Flink SQL 如何优化以及处理反压
ssmq
Re: Flink SQL 如何优化以及处理反压
weijie guo
Re:Re: Flink SQL 如何优化以及处理反压
lxk
Re: Re: Flink SQL 如何优化以及处理反压
Guojun Li
[ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released
Yanfei Lei
Re: [ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released
Jing Ge
Re: [ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released
Yuan Mei
Re: [ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released
Yun Tang
Re: [ANNOUNCE] FRocksDB 6.20.3-ververica-2.0 released
Leonard Xu
flink sql-client kerberos认证不通过
xiaohui zhang
Dear All,关于State processor API,有一些疑惑
ying lin
Re: Dear All,关于State processor API,有一些疑惑
Hangxiang Yu
Re: Dear All,关于State processor API,有一些疑惑
ying lin
如何监控flink sql on native k8s作业是否过度申请资源?
casel.chen
Re: 如何监控flink sql on native k8s作业是否过度申请资源?
Weihua Hu
Re: 未知类异常: org/apache/flink/table/connector/sink/abilities/SupportsSchemaEvolutionWriting
Shammon FY
取消订阅
wangwj03
取消订阅
lei-tian
Re: 取消订阅
Jiangang Liu
[ANNOUNCE] Apache Flink Table Store 0.3.0 released
Jingsong Li
sql-client.sh 终止后, 进程不会被 kill
704669594
Re: sql-client.sh 终止后, 进程不会被 kill
Shengkai Fang
[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
较舊的信息
较新的信息