user-zh
文章
日期
较舊的信息
较新的信息
文章索引
回复: Flink FailureRateRestartStrategy策略异常
刘 家锹
Re:回复: Flink FailureRateRestartStrategy策略异常
janke
Re:答复: 回复:如何从复杂的kafka消息体定义 table
mack143
Flink UI 经常打不开作业的拓扑图
xinzhuxiansheng
Re: Flink UI 经常打不开作业的拓扑图
胡伟华
Re: Flink UI 经常打不开作业的拓扑图
胡伟华
Re: Flink UI 经常打不开作业的拓扑图
yu'an huang
flink-connector-jdbc sink mysql是否存在乱序问题
Guo Thompson
Re: flink-connector-jdbc sink mysql是否存在乱序问题
yu'an huang
Fwd: flink-connector-jdbc sink mysql是否会存在乱序问题
Guo Thompson
flink状态恢复
enginegun
Re: flink状态恢复
Guo Thompson
Re: flink状态恢复
yidan zhao
flink状态恢复
小昌同学
Re: flink状态恢复
Hangxiang Yu
如何按比例丢弃kafka中消费的数据
jack zhang
Re: 如何按比例丢弃kafka中消费的数据
18703416...@163.com
Re: 如何按比例丢弃kafka中消费的数据
张昊 陈
Re: 如何按比例丢弃kafka中消费的数据
史延朋
Re:Re: 如何按比例丢弃kafka中消费的数据
chenkaibit
实时数据入库怎样过滤中间状态,保证最终一致
Lei Wang
Re: 实时数据入库怎样过滤中间状态,保证最终一致
18703416...@163.com
Re: 实时数据入库怎样过滤中间状态,保证最终一致
yidan zhao
回复: 实时数据入库怎样过滤中间状态,保证最终一致
Liu Join
Re: 实时数据入库怎样过滤中间状态,保证最终一致
Lei Wang
Re: 实时数据入库怎样过滤中间状态,保证最终一致
18703416...@163.com
Re: 实时数据入库怎样过滤中间状态,保证最终一致
Guo Thompson
flink状态共享
huangzhi...@iwgame.com
Re: flink状态共享
18703416...@163.com
Re: flink状态共享
yidan zhao
flink1.14 注册mysql connector报错
xiaoyue
Re: flink1.14 注册mysql connector报错
Tony Wei
Re: Re: flink1.14 注册mysql connector报错
xiaoyue
Re: Re: flink1.14 注册mysql connector报错
Tony Wei
Re: Re: flink1.14 注册mysql connector报错
xiaoyue
reserved key percentile_cont
ZHANG YU
Flink????????HDFS
Tony
Re: Flink数据写入HDFS
wenjie li
?????? Flink????????HDFS
Tony
Re: Flink数据写入HDFS
wenjie li
状态初始化
huangzhi...@iwgame.com
Re: 状态初始化
Jiangang Liu
Re: 状态初始化
Yun Tang
状态初始化
huangzhi...@iwgame.com
状态初始化
huangzhi...@iwgame.com
Re: 状态初始化
Jie Han
rocksdb backend设置后没有启用
swessia
Re: rocksdb backend设置后没有启用
胡伟华
Re:Re: rocksdb backend设置后没有启用
swessia
使用Apache Pulsar Connector发生NoClassDefFoundError
AaronFae
Re:使用Apache Pulsar Connector发生NoClassDefFoundError
高大余
Re:Re:使用Apache Pulsar Connector发生NoClassDefFoundError
AaronFae
flink Per-Job-Cluster 支持提交sql任务吗
shanwu...@rockontrol.com
Re:flink Per-Job-Cluster 支持提交sql任务吗
高大余
Re: flink Per-Job-Cluster 支持提交sql任务吗
丛鹏
?????? flink Per-Job-Cluster ????????sql??????
??????
Fiink-sql的官方函数的代码哪里可以看到
王宇航
??????Fiink-sql????????????????????????????
?Y??????????????????
hive 进行 overwrite 合并数据后文件变大?
RS
Re:hive 进行 overwrite 合并数据后文件变大?
周瑞
回复:hive 进行 overwrite 合并数据后文件变大?
Shuai Xia
Re:回复:hive 进行 overwrite 合并数据后文件变大?
RS
关于timestamp在eventTime和processTIme、以及各种不同API情况下的不同实现。
yidan zhao
关于“批”处理元素导致batch的event timestamp变化,后接window统计错乱的问题。
yidan zhao
Re: 关于“批”处理元素导致batch的event timestamp变化,后接window统计错乱的问题。
yidan zhao
[ANNOUNCE] Apache Flink 1.13.6 released
Konstantin Knauf
FlinkSQL vs DataStream API 对硬件的需求
Pinjie Huang
Re: FlinkSQL vs DataStream API 对硬件的需求
Jie Han
Re: FlinkSQL vs DataStream API 对硬件的需求
yue ma
flink 不触发checkpoint
董少杰
Re:flink 不触发checkpoint
RS
Re: flink 不触发checkpoint
Tony Wei
org.apache.flink.runtime.rpc.exceptions.FencingTokenException
casel.chen
cep 的困惑
翼 之道
Re: cep 的困惑
yue ma
关于将数据batch到一起处理再拆分后timestamp发生错乱的问题
yidan zhao
flinkcdc:slave with the same server_uuid/server_id as this slave has connected to the master;
maker_d...@foxmail.com
回复: flinkcdc:slave with the same server_uuid/server_id as this slave has connected to the master;
chengyanan1...@foxmail.com
flink sql jdbc sink事务提交问题
casel.chen
Re:flink sql jdbc sink事务提交问题
Michael Ran
Re:Re:flink sql jdbc sink事务提交问题
casel.chen
??????<??????>
????????
flink-netty-shuffle文件占满节点磁盘
智能平台
Re: flink-netty-shuffle文件占满节点磁盘
Yingjie Cao
flink创建视图后,SELECT语句后使用OPTIONS报错
liangjinghong
Re: flink创建视图后,SELECT语句后使用OPTIONS报错
godfrey he
转发: flink创建视图后,SELECT语句后使用OPTIONS报错
liangjinghong
Re: flink创建视图后,SELECT语句后使用OPTIONS报错
godfrey he
jdbc connector ??????????????????????????????????????????????????????????????
jianjianjianjianjianjianjianjian
Re: jdbc connector 写入异常数据后,不再写入新数据时,异常信息不断嵌套,且不会抛出
Caizhi Weng
回复:jdbc connector 写入异常数据后,不再写入新数据时,异常信息不断嵌套,且不会抛出
jianjianjianjianjianjianjianjian
Re:jdbc connector ??????????????????????????????????????????????????????????????
Michael Ran
[statefun] How to make the input/output topics live in different kafka clusters for flink stateful functions
casel.chen
请教设置了table.exec.state.ttl后,结果数据不更新问题
liangjinghong
Re: 请教设置了table.exec.state.ttl后,结果数据不更新问题
Caizhi Weng
flink on yarn HDFS_DELEGATION_TOKEN清除后,任务am attempt时失败
xieyi
flink on yarn HDFS_DELEGATION_TOKEN清除后,任务am attempt时失败
xieyi
回复:flink on yarn HDFS_DELEGATION_TOKEN清除后,任务am attempt时失败
xieyi
Flink sql 客户端实现
JianWen Huang
??????Flink sql ??????????
??????
Re: Flink sql 客户端实现
JianWen Huang
?????? Flink sql ??????????
??????
flink1.12.2??????1.13.5??flink sql??????savepoint????
If
flink是否支持 http请求并返回json数据
张锴
Re: flink是否支持 http请求并返回json数据
Caizhi Weng
Re: flink是否支持 http请求并返回json数据
张锴
回复: flink是否支持 http请求并返回json数据
yckkcy
Pyflink 1.14 ???? DDL????
??????
Re: Pyflink 1.14 维表 DDL报错
Caizhi Weng
请教三张以上时态表关联,加where条件后报错 mismatched type $6 TIMESTAMP(3)的问题
liangjinghong
Re: 请教三张以上时态表关联,加where条件后报错 mismatched type $6 TIMESTAMP(3)的问题
Caizhi Weng
sql-client 查询hive表报错 java.lang.ClassNotFoundException: org.apache.hadoop.mapred.JobConf
kingdomad
flink mysql cdc注册confluent schema registry
casel.chen
hbase NoSuchMethodError: org.apache.hadoop.hbase.client.HTable.getTableName()[B
潘明文
flinkcdc 2.1????
??????
如何给flink的输出削峰填谷?
Jing
Re: 如何给flink的输出削峰填谷?
Paul Lam
Re: 如何给flink的输出削峰填谷?
yidan zhao
Re: 如何给flink的输出削峰填谷?
18703416...@163.com
Flink Connector类冲突问题
Ada Wong
Re: Flink Connector类冲突问题
Ada Wong
(??????)
????????
TaskManager的Slot的释放时机
johnjlong
Re: TaskManager的Slot的释放时机
Zhilong Hong
数据库Table Schema 转换为 Flink Schema
WuKong
Re:数据库Table Schema 转换为 Flink Schema
Michael Ran
flink 1.13.2 ????hive????????????????NullPointerException
Asahi Lee
Re: flink 1.13.2 计算hive仓库数据时错误,NullPointerException
Caizhi Weng
flink执行任务失败,taskmanager内存不释放
Liu Join
Re: flink执行任务失败,taskmanager内存不释放
Caizhi Weng
FlinkKafkaProducer 问题
潘明文
回复:FlinkKafkaProducer 问题
selves_nan
Re:回复:FlinkKafkaProducer 问题
潘明文
回复:FlinkKafkaProducer 问题
selves_nan
Re:回复:FlinkKafkaProducer 问题
潘明文
Re:Re:回复:FlinkKafkaProducer 问题
潘明文
Re:Re:Re:回复:FlinkKafkaProducer 问题
潘明文
hbase 写性能
潘明文
flink任务提交到集群执行一段时间报错Java heap space
Liu Join
Re: flink任务提交到集群执行一段时间报错Java heap space
Caizhi Weng
回复: flink任务提交到集群执行一段时间报错Java heap space
Liu Join
Re: flink任务提交到集群执行一段时间报错Java heap space
Caizhi Weng
使用flinkcdc2.1.1读取MySQL数据报错
Liu Join
Flink mysql CDC 进程正常,但发现数据丢失了
Fei Han
flink算子级别资源使用设置
casel.chen
Re: flink算子级别资源使用设置
venn
Re: flink算子级别资源使用设置
Chang Li
flink window支持回撤流吗?
casel.chen
问题原因分析(task stuck for 180 seconds)
yidan zhao
Flink mysql cdc凌晨同步报错
Fei Han
Re:Flink mysql cdc凌晨同步报错
Michael Ran
Flink 1.12 Blink planner timestamp类型转换异常
张健
Flink 1.12 Blink planner timestamp类型转换异常
张健
Flink 1.12 Blink planner timestamp类型转换异常
张健
(无主题)
生如夏花
(无主题)
王健
Re: (无主题)
Shengkai Fang
(无主题)
zehir.tong
(无主题)
zehir.tong
Re:(无主题)
Xuyang
(无主题)
zhufangliang
(无主题)
李朋
(无主题)
Paul
Re: (无主题)
Weihua Hu
回复:(无主题)
海风
(无主题)
willluzheng
Re: (无主题)
Xuannan Su
Re: 谁能解释一下 GlobalStreamExchangeMode 这几种交换模式的不同和使用场景吗?
Chang Li
Re: Re: 关于streamFileSink在checkpoint下生成文件问题
Chang Li
Re: 关于streamFileSink在checkpoint下生成文件问题
Chang Li
cumulate window可以在retract流上使用吗?
casel.chen
flink sql动态累计窗口实现问题
casel.chen
cumulate窗口不支持偏移offset参数吗?
casel.chen
sql-gateway和jdbc-driver还维护吗?
Ada Wong
Re: sql-gateway和jdbc-driver还维护吗?
Ada Wong
?????? sql-gateway??jdbc-driver??????????
??????
Re: sql-gateway和jdbc-driver还维护吗?
Ada Wong
Re: sql-gateway和jdbc-driver还维护吗?
godfrey he
回复:sql-gateway和jdbc-driver还维护吗?
Fei Han
如何确定分配内存的大小
许友昌
Re: 如何确定分配内存的大小
Caizhi Weng
Re: 如何确定分配内存的大小
Chang Li
Re: 如何确定分配内存的大小
cc vmaster
Re: Flink on Native K8s 部署模式下Tm和Jm容器配置Hosts问题
Yang Wang
Re: Flink on Native K8s 部署模式下Tm和Jm容器配置Hosts问题
JianWen Huang
Re: Flink on Native K8s 部署模式下Tm和Jm容器配置Hosts问题
Yang Wang
??????????
??????
Re: 批模式疑问
Caizhi Weng
?????? ??????????
??????
??????????
????
??????????
????
Re: 退订
Biao Geng
关于时间窗口的问题
18765295...@163.com
flink sql 如何提高下游并发度?
Jeff
Re: flink sql 如何提高下游并发度?
Caizhi Weng
Re:Re: flink sql 如何提高下游并发度?
RS
回复: flink sql 如何提高下游并发度?
JasonLee
回复: flink sql 如何提高下游并发度?
许友昌
Re: 回复: flink sql 如何提高下游并发度?
venn
Re: flink sql 如何提高下游并发度?
chang li
较舊的信息
较新的信息