user-zh@flink.apache.org, 2019-10

You are viewing a plain text version of this content. The canonical link for it is here.

- Dynamic stream handling - posted by Ever <43...@qq.com> on 2019/10/01 14:58:26 UTC, 1 replies.
- How to write stream data to other Hadoop Cluster by StreamingFileSink - posted by Jun Zhang <82...@qq.com> on 2019/10/05 05:44:59 UTC, 1 replies.
- flink table api中 registerTableSink 如何指定sink的并行度 - posted by 周虓岗 <zh...@163.com> on 2019/10/06 11:25:07 UTC, 0 replies.
- Flink 1.8 版本如何进行 TaskManager 的资源控制 - posted by 龙逸尘 <ly...@gmail.com> on 2019/10/07 08:49:41 UTC, 2 replies.
- FLINK WEEKLY 2019/40 - posted by Zili Chen <wa...@gmail.com> on 2019/10/08 01:29:53 UTC, 0 replies.
- flink StreamingFileSink to HDFS 修改文件名字 - posted by XW Marvin <ma...@gmail.com> on 2019/10/08 09:10:11 UTC, 0 replies.
- 文件重命名 - posted by yanggang_it_job <ya...@163.com> on 2019/10/08 09:39:49 UTC, 3 replies.
- flink to hdfs StreamingFileSink.forBulkFormat file rename - posted by XW Marvin <ma...@gmail.com> on 2019/10/08 10:42:50 UTC, 0 replies.
- Flink SQL ：Unknown or invalid SQL statement. - posted by Henry <he...@163.com> on 2019/10/09 00:49:10 UTC, 2 replies.
- 回复: Re: Flink SQL ：Unknown or invalid SQL statement. - posted by "pengchenglins@163.com" <pe...@163.com> on 2019/10/09 03:19:17 UTC, 1 replies.
- Re: [DISCUSS] Drop Python 2 support for 1.10 - posted by Dian Fu <di...@gmail.com> on 2019/10/10 02:26:49 UTC, 0 replies.
- 基于savepoint 调小并发的问题 - posted by 陈赋赟 <as...@163.com> on 2019/10/10 03:42:41 UTC, 1 replies.
- flink1.9 webui exception日志显示问题 - posted by 李杰 <ar...@gmail.com> on 2019/10/10 06:31:32 UTC, 0 replies.
- flink checkpoint超时问题 - posted by lg <sc...@163.com> on 2019/10/10 08:18:12 UTC, 1 replies.
- 回复: flink1.9 webui exception日志显示问题 - posted by 戴嘉诚 <a7...@gmail.com> on 2019/10/10 08:26:33 UTC, 1 replies.
- Flink集群迁移savepoint还保留原集群地址问题讨论 - posted by 蒋涛涛 <jt...@gmail.com> on 2019/10/10 09:13:16 UTC, 3 replies.
- 大数据集群开启了kerberos认证 TM上kafka连接不上 - posted by andrew <15...@163.com> on 2019/10/10 10:00:14 UTC, 0 replies.
- flink 缓存本地文件被删除疑问 - posted by 戴嘉诚 <a7...@gmail.com> on 2019/10/11 03:00:03 UTC, 2 replies.
- 回复: flink 缓存本地文件被删除疑问 - posted by 戴嘉诚 <a7...@gmail.com> on 2019/10/11 05:21:46 UTC, 4 replies.
- 回复: 回复: flink1.9 webui exception日志显示问题 - posted by 戴嘉诚 <a7...@gmail.com> on 2019/10/11 06:56:00 UTC, 0 replies.
- 关于使用RocksDBStateBackend 启用state.backend.rocksdb.ttl.compaction.filter.enabled 配置的问题 - posted by claylin <10...@qq.com> on 2019/10/11 08:16:39 UTC, 1 replies.
- 回复: 回复: flink 缓存本地文件被删除疑问 - posted by 戴嘉诚 <a7...@gmail.com> on 2019/10/11 08:23:46 UTC, 0 replies.
- 回复：使用flink-sql实现mysql维表的join的ddl和dml的示列 - posted by 迎风浪子 <57...@qq.com> on 2019/10/11 10:45:28 UTC, 1 replies.
- Re: 使用flink-sql实现mysql维表的join的ddl和dml的示列 - posted by Jark Wu <im...@gmail.com> on 2019/10/11 11:23:09 UTC, 3 replies.
- 回复：关于使用RocksDBStateBackend 启用state.backend.rocksdb.ttl.compaction.filter.enabled 配置的问题 - posted by claylin <10...@qq.com> on 2019/10/11 11:44:41 UTC, 0 replies.
- Flink 1.9 Failed to take leadership with session id 异常 - posted by 王佩 <wa...@cmcm.com> on 2019/10/12 11:16:45 UTC, 0 replies.
- Re: Kafka 与 extractly-once - posted by Congxian Qiu <qc...@gmail.com> on 2019/10/12 12:48:25 UTC, 0 replies.
- flink 1.6.1 RichAsyncFunction 异步请求外部系统导致下游数据大量重复 - posted by 曾耀武 <51...@qq.com> on 2019/10/13 04:55:20 UTC, 0 replies.
- Flink StreamingFileSink.forBulkFormat to HDFS - posted by yanggang_it_job <ya...@163.com> on 2019/10/13 10:11:37 UTC, 1 replies.
- Re: flink 1.6.1 RichAsyncFunction 异步请求外部系统导致下游数据大量重复 - posted by Jark Wu <im...@gmail.com> on 2019/10/14 03:23:51 UTC, 1 replies.
- FLINK WEEKLY 2019/41 - posted by Zili Chen <wa...@gmail.com> on 2019/10/14 06:32:03 UTC, 0 replies.
- 回复： flink 1.6.1 RichAsyncFunction 异步请求外部系统导致下游数据大量重复 - posted by 曾耀武 <51...@qq.com> on 2019/10/14 10:10:51 UTC, 1 replies.
- group.id更改，通过savepoint启动的Flink任务，Kafka consumer是否仍然可以获取到保存在状态中的start position？ - posted by ju...@sina.cn on 2019/10/14 14:50:46 UTC, 0 replies.
- Flink 1.9 SQL/TableAPI 设置uid及State 更新问题 - posted by 去冒险吧 <12...@qq.com> on 2019/10/16 02:24:35 UTC, 2 replies.
- 如何修改checkpoint生成的_metadata文件中的hdfs路径 - posted by 蒋涛涛 <jt...@gmail.com> on 2019/10/16 10:55:27 UTC, 1 replies.
- 回复： Flink 1.9 SQL/TableAPI 设置uid及State 更新问题 - posted by 去冒险吧 <12...@qq.com> on 2019/10/17 02:43:14 UTC, 1 replies.
- blink SQL从kafka中获取rowtime - posted by Zijie Lu <ws...@gmail.com> on 2019/10/17 11:49:20 UTC, 3 replies.
- flink权限问题 - posted by jinhai wang <ji...@gmail.com> on 2019/10/17 11:57:49 UTC, 1 replies.
- 如何限制blink中资源使用上限（perjob模式） - posted by 蒋涛涛 <jt...@gmail.com> on 2019/10/19 07:55:44 UTC, 1 replies.
- [ANNOUNCE] Apache Flink 1.9.1 released - posted by Jark Wu <im...@gmail.com> on 2019/10/19 13:07:40 UTC, 3 replies.
- Flink 消费Kafka Window不触发计算 - posted by 王佩 <wa...@cmcm.com> on 2019/10/20 02:38:29 UTC, 0 replies.
- 回复：Flink 消费Kafka Window不触发计算 - posted by Ever <43...@qq.com> on 2019/10/20 17:38:11 UTC, 2 replies.
- Flink提jar包部署到Yarn上报错 - posted by "zhangjunjie1130@163.com" <zh...@163.com> on 2019/10/21 03:05:11 UTC, 2 replies.
- 回复: Flink提jar包部署到Yarn上报错 - posted by "hery168@163.com" <he...@163.com> on 2019/10/21 03:27:14 UTC, 0 replies.
- FLINK WEEKLY 2019/42 - posted by Zili Chen <wa...@gmail.com> on 2019/10/21 08:51:04 UTC, 0 replies.
- flink1.7.2版本taskmanager.log页面显示中文为乱码 - posted by chengdh90 <ch...@163.com> on 2019/10/21 17:50:27 UTC, 0 replies.
- Flink DataStream Micro-Batch - posted by 王佩 <wa...@cmcm.com> on 2019/10/22 05:25:24 UTC, 1 replies.
- Flink DataStream Broadcast variable - posted by 王佩 <wa...@cmcm.com> on 2019/10/22 05:28:09 UTC, 1 replies.
- [metrics] metrics 中 Availability 和 Checkpointing 这两组没有显示 - posted by Blake <bl...@qq.com> on 2019/10/22 09:37:13 UTC, 0 replies.
- Flink DataStream ElasticsearchSink Checkpoint Error - posted by 王佩 <wa...@cmcm.com> on 2019/10/23 00:38:09 UTC, 1 replies.
- Flink Source间歇性无数据如何处理（问题描述见详情） - posted by DD司机 <v5...@dingtalk.com.INVALID> on 2019/10/23 01:22:26 UTC, 0 replies.
- 回复： Flink Source间歇性无数据如何处理（问题描述见详情） - posted by Ever <43...@qq.com> on 2019/10/23 01:35:16 UTC, 2 replies.
- 关于jdk版本 - posted by huangrunxingxing <hu...@163.com> on 2019/10/24 06:15:30 UTC, 3 replies.
- 回复：关于jdk版本 - posted by huangrunxingxing <hu...@163.com> on 2019/10/24 13:58:58 UTC, 0 replies.
- flink1.9.1编译hadoop版本3.0.0-cdh6.0.1，on yarn报错 - posted by homex wu <wh...@gmail.com> on 2019/10/25 01:42:57 UTC, 2 replies.
- 为什么在KeyedStream上进行任何transformation都会变回DataStream - posted by Utopia <ge...@gmail.com> on 2019/10/25 08:05:44 UTC, 2 replies.
- Flink 的 log 文件夹下产生了 34G 日志 - posted by Henry <he...@163.com> on 2019/10/28 07:54:18 UTC, 4 replies.
- FLINK WEEKLY 2019/43 - posted by Zili Chen <wa...@gmail.com> on 2019/10/28 11:10:01 UTC, 0 replies.
- 请问如何将已有字段设置为rowtime属性 - posted by 苏欣 <se...@live.com> on 2019/10/29 03:27:26 UTC, 0 replies.
- flink1.9.1 kafka表读取问题 - posted by hb <34...@163.com> on 2019/10/29 06:41:41 UTC, 0 replies.
- 回复：flink1.9.1 kafka表读取问题 - posted by 如影随形 <12...@qq.com> on 2019/10/29 06:47:34 UTC, 3 replies.
- How to use two continuously window with EventTime in sql - posted by 刘建刚 <li...@gmail.com> on 2019/10/29 07:39:16 UTC, 1 replies.
- flink1.9.1 on yarn sql 部署问题 - posted by hb <34...@163.com> on 2019/10/30 02:30:00 UTC, 1 replies.
- flink run jar throw java.lang.ClassNotFoundException: com.mysql.jdbc.Driver - posted by Alex Wang <he...@gmail.com> on 2019/10/30 03:40:36 UTC, 3 replies.
- 如何过滤异常的timestamp？ - posted by 邢瑞斌 <xi...@gmail.com> on 2019/10/30 09:57:36 UTC, 4 replies.
- 怎样把 state 定时写到外部存储 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2019/10/31 02:15:39 UTC, 0 replies.
- Flink State 过期清除 TTL 问题 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2019/10/31 02:25:13 UTC, 1 replies.
- 回复：怎样把 state 定时写到外部存储 - posted by Jun Zhang <82...@qq.com> on 2019/10/31 02:28:34 UTC, 0 replies.