You are viewing a plain text version of this content. The canonical link for it is here.
- 回复: 回复: 本地checkpoint 文件190G了 - posted by "2421307858@qq.com" <24...@qq.com> on 2019/12/01 07:54:16 UTC, 0 replies.
- Re: 回复: 回复: 本地checkpoint 文件190G了 - posted by Yun Tang <my...@live.com> on 2019/12/01 15:41:40 UTC, 0 replies.
- Re: checkpoint、state - posted by Congxian Qiu <qc...@gmail.com> on 2019/12/02 02:30:10 UTC, 0 replies.
- 小白求助,FlinkSQL处理速度上不来 - posted by "wydhcws@gmail.com" <wy...@gmail.com> on 2019/12/02 04:13:18 UTC, 0 replies.
- yarn-cluster 提交任务的问题 - posted by 李军 <ho...@163.com> on 2019/12/02 05:58:57 UTC, 0 replies.
- 连续keyBy后sum - posted by hahaha sc <sh...@gmail.com> on 2019/12/02 07:19:53 UTC, 0 replies.
- perjob yarn页面链接flink出错 - posted by pengchenglin <pe...@163.com> on 2019/12/02 07:54:51 UTC, 0 replies.
- eh - posted by 改改 <vf...@dingtalk.com.INVALID> on 2019/12/02 09:17:18 UTC, 0 replies.
- 回复:yarn-cluster 提交任务的问题 - posted by Jun Zhang <82...@qq.com> on 2019/12/02 09:36:29 UTC, 0 replies.
- MiniCluster启动报actor初始化异常 - posted by 叶贤勋 <yx...@163.com> on 2019/12/03 09:49:35 UTC, 0 replies.
- bin/flink savepoint jobId 出错 - posted by guoshuai <re...@163.com> on 2019/12/04 01:54:17 UTC, 1 replies.
- 如何 远程通知 flink 开启任务 - posted by 李军 <ho...@163.com> on 2019/12/04 02:06:25 UTC, 0 replies.
- 回复: 如何 远程通知 flink 开启任务 - posted by "aven.wu" <da...@163.com> on 2019/12/04 02:48:14 UTC, 0 replies.
- 答复: 如何 远程通知 flink 开启任务 - posted by zhao liang <zh...@gmail.com> on 2019/12/04 03:03:06 UTC, 0 replies.
- 回复: 回复: 回复: flink on yarn 的 kerberos 认证问题 - posted by venn <wx...@163.com> on 2019/12/04 06:41:33 UTC, 0 replies.
- 如何用SQL表达对设备离在线监控 - posted by "Yuan,Youjun" <yu...@baidu.com> on 2019/12/04 10:49:31 UTC, 0 replies.
- 回复:如何用SQL表达对设备离在线监控 - posted by 1193216154 <11...@qq.com> on 2019/12/04 13:39:23 UTC, 0 replies.
- 如果用flink sql持续查询过去30分钟登录网站的人数? - posted by 陈帅 <ca...@gmail.com> on 2019/12/04 15:40:03 UTC, 2 replies.
- Re: [DISCUSS] Drop Kafka 0.8/0.9 - posted by Jark Wu <im...@gmail.com> on 2019/12/05 02:19:43 UTC, 5 replies.
- 回复: 如果用flink sql持续查询过去30分钟登录网站的人数? - posted by "Yuan,Youjun" <yu...@baidu.com> on 2019/12/05 02:40:51 UTC, 2 replies.
- 回复: 回复:如何用SQL表达对设备离在线监控 - posted by "Yuan,Youjun" <yu...@baidu.com> on 2019/12/05 06:05:57 UTC, 1 replies.
- 想问一下Flink SQL 1.9版本支持维表join吗 - posted by 陈赋赟 <as...@163.com> on 2019/12/05 06:15:42 UTC, 0 replies.
- 回复:想问一下Flink SQL 1.9版本支持维表join吗 - posted by 猫猫 <16...@qq.com> on 2019/12/05 06:17:28 UTC, 3 replies.
- 回复: 回复: 回复:如何用SQL表达对设备离在线监控 - posted by 1193216154 <11...@qq.com> on 2019/12/05 06:43:28 UTC, 0 replies.
- 回复: 回复: 回复: 回复:如何用SQL表达对设备离在线监控 - posted by "Yuan,Youjun" <yu...@baidu.com> on 2019/12/05 08:06:43 UTC, 2 replies.
- flink[table]-在table-sql-api下失败的数据能否转移到其它sink端? - posted by 猫猫 <16...@qq.com> on 2019/12/06 00:36:34 UTC, 0 replies.
- flink消费kafka得问题 - posted by cs <58...@qq.com> on 2019/12/06 05:56:19 UTC, 1 replies.
- yarn-session模式通过python api消费kafka数据报错 - posted by 改改 <vf...@dingtalk.com.INVALID> on 2019/12/06 06:36:11 UTC, 2 replies.
- 关于flink和hadoop版本的问题 - posted by "cljbest@163.com" <cl...@163.com> on 2019/12/06 08:13:54 UTC, 1 replies.
- [flink-sql]使用tableEnv.sqlUpdate(ddl);方式创表,如何指定rowtime? - posted by 猫猫 <16...@qq.com> on 2019/12/06 09:52:02 UTC, 1 replies.
- 回复: perjob yarn页面链接flink出错 - posted by pengchenglin <pe...@163.com> on 2019/12/06 11:41:29 UTC, 0 replies.
- flink1.9.0 standalone模式高可用配置问题 - posted by pengchenglin <pe...@163.com> on 2019/12/06 11:47:55 UTC, 0 replies.
- 回复: flink1.9.0 standalone模式高可用配置问题 - posted by pengchenglin <pe...@163.com> on 2019/12/06 12:10:05 UTC, 0 replies.
- FLINK WEEKLY 2019/48 - posted by tison <wa...@gmail.com> on 2019/12/06 17:27:30 UTC, 0 replies.
- flink,50000条数据写入mysql太慢怎么办啊,除了多线程还有其他方法吗,已经是批量写入了 - posted by sun <13...@qq.com> on 2019/12/07 03:53:28 UTC, 1 replies.
- 回复: flink,50000条数据写入mysql太慢怎么办啊,除了多线程还有其他方法吗,已经是批量写入了 - posted by sun <13...@qq.com> on 2019/12/07 04:33:59 UTC, 1 replies.
- Flink实时数仓落Hive一般用哪种方式好? - posted by 陈帅 <ca...@gmail.com> on 2019/12/08 02:04:14 UTC, 8 replies.
- Flink RetractStream如何转成AppendStream? - posted by 陈帅 <ca...@gmail.com> on 2019/12/08 02:07:59 UTC, 7 replies.
- flink on k8s 如何指定用户程序的入口 - posted by "aven.wu" <da...@163.com> on 2019/12/09 06:13:26 UTC, 0 replies.
- 回复:yarn-session模式通过python api消费kafka数据报错 - posted by 改改 <vf...@dingtalk.com.INVALID> on 2019/12/10 02:06:07 UTC, 1 replies.
- Re: Re: Flink State 过期清除 TTL 问题 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2019/12/10 02:16:38 UTC, 2 replies.
- HDFS_DELEGATION_TOKEN自动过期问题 - posted by hss <10...@qq.com> on 2019/12/10 03:03:17 UTC, 1 replies.
- 回复: Flink实时数仓落Hive一般用哪种方式好? - posted by hiliuxg <73...@qq.com> on 2019/12/10 03:14:51 UTC, 0 replies.
- 窗口去重 - posted by Jimmy Wong <wa...@163.com> on 2019/12/10 08:39:40 UTC, 0 replies.
- 回复: 窗口去重 - posted by "Yuan,Youjun" <yu...@baidu.com> on 2019/12/11 01:04:16 UTC, 0 replies.
- 分流 - posted by 李军 <ho...@163.com> on 2019/12/11 02:02:46 UTC, 0 replies.
- flink1.9.1 Metrics 上报 PrometheusPushGateway问题 - posted by hb <34...@163.com> on 2019/12/11 02:40:24 UTC, 0 replies.
- 回复: 窗口去重 - posted by Jimmy Wong <wa...@163.com> on 2019/12/11 03:19:45 UTC, 0 replies.
- flink savepoint checkpoint - posted by "lucas.wu" <lu...@xiaoying.com> on 2019/12/11 03:55:55 UTC, 3 replies.
- 回复:窗口去重 - posted by 梁溪 <lx...@163.com> on 2019/12/11 04:08:38 UTC, 3 replies.
- flink持续查询过去30分钟登录网站的人数 - posted by 陈帅 <ca...@gmail.com> on 2019/12/11 13:31:09 UTC, 2 replies.
- 回复: flink持续查询过去30分钟登录网站的人数 - posted by "Yuan,Youjun" <yu...@baidu.com> on 2019/12/12 01:28:18 UTC, 0 replies.
- Flink1.9.1的SQL向前不兼容的问题 - posted by 李佟 <li...@iie.ac.cn> on 2019/12/12 01:55:16 UTC, 1 replies.
- countWindow使用的问题 - posted by cs <58...@qq.com> on 2019/12/12 11:07:16 UTC, 0 replies.
- Flink 1.9.1版本sql与1.8.x兼容性问题 - posted by 李佟 <li...@iie.ac.cn> on 2019/12/12 12:36:24 UTC, 0 replies.
- 回复:countWindow使用的问题 - posted by Jimmy Wong <wa...@163.com> on 2019/12/12 13:00:20 UTC, 1 replies.
- Table API问题 - posted by ch...@kedacom.com on 2019/12/13 02:39:00 UTC, 1 replies.
- join - posted by zgq25302111 <zg...@126.com> on 2019/12/14 09:16:20 UTC, 0 replies.
- flink如何动态修改窗口大小和类型? - posted by 陈帅 <ca...@gmail.com> on 2019/12/14 10:43:51 UTC, 5 replies.
- flink-cluster restart with no job,the job manager's log always have exceptions--job not found - posted by 599677425 <ki...@qq.com> on 2019/12/15 07:48:42 UTC, 0 replies.
- Flink运行一段时间后出现异常重启 - posted by chanamper <ch...@163.com> on 2019/12/15 13:55:11 UTC, 0 replies.
- [flink-SQL-API]如何将kafka中的json数据注册为表? - posted by 猫猫 <16...@qq.com> on 2019/12/16 03:21:27 UTC, 0 replies.
- jobmanager异常日志 - posted by pengchenglin <pe...@163.com> on 2019/12/16 06:48:50 UTC, 1 replies.
- FlinkSQL中关于TIMESTAMPDIFF函数官网E.g的疑问 - posted by 1530130567 <15...@qq.com> on 2019/12/16 07:51:02 UTC, 2 replies.
- FLINK 1.9 + YARN+ SessionWindows + 大数据量 + 运行一段时间后 OOM - posted by USERNAME <or...@126.com> on 2019/12/17 09:49:22 UTC, 3 replies.
- [SQL] [TableAPI] Table.sqlQuery(sql) 和 tableSink 的 table schema 类型不匹配 - posted by "aven.wu" <da...@163.com> on 2019/12/17 13:20:01 UTC, 0 replies.
- Flink Table Schema中Types.SQL_TTIMESTAMP类型json表示问题 - posted by 陈帅 <ca...@gmail.com> on 2019/12/18 00:23:51 UTC, 0 replies.
- flink sql confluent schema avro topic注册成表 - posted by 陈帅 <ca...@gmail.com> on 2019/12/18 00:26:11 UTC, 2 replies.
- 关于直接设置Watermark和flatmap后再设置的疑问 - posted by 猫猫 <16...@qq.com> on 2019/12/18 01:27:07 UTC, 1 replies.
- flink命令行提交的问题 - posted by cs <58...@qq.com> on 2019/12/18 07:58:00 UTC, 0 replies.
- 回复: 关于直接设置Watermark和flatmap后再设置的疑问 - posted by 猫猫 <16...@qq.com> on 2019/12/18 08:03:52 UTC, 0 replies.
- 回复:(补充图片链接) 关于直接设置Watermark和flatmap后再设置的疑问 - posted by 猫猫 <16...@qq.com> on 2019/12/18 08:11:59 UTC, 0 replies.
- Re: (补充图片链接) 关于直接设置Watermark和flatmap后再设置的疑问 - posted by Dino Zhang <vi...@gmail.com> on 2019/12/18 08:35:24 UTC, 0 replies.
- flink跨集群kerberos认证问题 - posted by 李现 <st...@gmail.com> on 2019/12/18 15:05:13 UTC, 3 replies.
- Re: [DISCUSS] What parts of the Python API should we focus on next ? - posted by jincheng sun <su...@gmail.com> on 2019/12/19 03:05:10 UTC, 2 replies.
- yarn per job 模式这个报错原因是什么?随机出现 - posted by "rockeycui@163.com" <ro...@163.com> on 2019/12/20 07:04:47 UTC, 2 replies.
- 使用flink 做维表关联 - posted by "lucas.wu" <lu...@xiaoying.com> on 2019/12/20 09:37:20 UTC, 1 replies.
- using thin jar to replace fat jar on yarn cluster mode - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2019/12/23 02:09:37 UTC, 4 replies.
- Flink On K8s, build docker image very slowly, is there some way to make it faster? - posted by LakeShen <sh...@gmail.com> on 2019/12/23 06:45:42 UTC, 2 replies.
- CEP匹配乱序数据的问题 - posted by qishang zhong <zh...@gmail.com> on 2019/12/23 13:37:15 UTC, 1 replies.
- [ANNOUNCE] 每周社区更新-51 (20191216-20191222) - posted by Hequn Cheng <ch...@gmail.com> on 2019/12/24 02:37:36 UTC, 0 replies.
- Flink1.9.1,TableApi如何读取Kafka08Json的数据 - posted by Chennet Steven <st...@live.com> on 2019/12/24 07:52:43 UTC, 0 replies.
- 回复: Flink1.9.1,TableApi如何读取Kafka08Json的数据 - posted by Chennet Steven <st...@live.com> on 2019/12/24 09:08:17 UTC, 0 replies.
- 关于flink窗口是否正确关闭的问题 - posted by 1530130567 <15...@qq.com> on 2019/12/24 12:46:25 UTC, 2 replies.
- The assigned slot bae00218c818157649eb9e3c533b86af_11 was removed - posted by hiliuxg <73...@qq.com> on 2019/12/24 14:05:56 UTC, 2 replies.
- 回复: 关于flink窗口是否正确关闭的问题 - posted by 1530130567 <15...@qq.com> on 2019/12/25 01:56:51 UTC, 0 replies.
- 关于Window ProcessFunction数据丢失问题 - posted by 1530130567 <15...@qq.com> on 2019/12/25 02:39:20 UTC, 1 replies.
- Flink1.9批任务yn和ys对任务的影响 - posted by faaron zheng <fa...@gmail.com> on 2019/12/25 03:09:06 UTC, 5 replies.
- 实现一个两阶段提交的ETL,数据从kafka到mysql,遇到的问题 - posted by 卢伟楠 <gl...@gmail.com> on 2019/12/25 04:17:41 UTC, 0 replies.
- flink checkpoint配置hdfs问题 - posted by LJY <th...@163.com> on 2019/12/25 07:23:39 UTC, 0 replies.
- 回复:flink checkpoint配置hdfs问题 - posted by 唐军亮 <ta...@huitongjy.com> on 2019/12/25 07:26:42 UTC, 0 replies.
- 关于 FLink historyserver没有completed-jobs的问题 - posted by 起子 <qi...@dian.so> on 2019/12/25 07:57:04 UTC, 1 replies.
- Flink实现Kafka到Mysql的 End-To-End Exactly-Once中遇到的问题 - posted by 卢伟楠 <gl...@gmail.com> on 2019/12/25 08:09:03 UTC, 1 replies.
- flink 维表关联 - posted by "lucas.wu" <lu...@xiaoying.com> on 2019/12/25 09:13:30 UTC, 3 replies.
- Rewind offset to a previous position and ensure certainty. - posted by 邢瑞斌 <xi...@gmail.com> on 2019/12/25 12:26:45 UTC, 2 replies.
- 回复: flink 维表关联 - posted by 叶贤勋 <yx...@163.com> on 2019/12/26 01:47:50 UTC, 0 replies.
- 回复:Flink1.9批任务yn和ys对任务的影响 - posted by faaron zheng <fa...@gmail.com> on 2019/12/26 03:23:26 UTC, 2 replies.
- Flink 1.9 SQL Kafka Connector,Json format,how to deal with not json message? - posted by LakeShen <sh...@gmail.com> on 2019/12/26 03:43:53 UTC, 1 replies.
- source并行度不同导致任务没有数据落地 - posted by "zhaorui_9303@163.com" <zh...@163.com> on 2019/12/26 04:03:10 UTC, 1 replies.
- flink sql 1.9.0如何创建elasticsearch动态索引表 - posted by 文浩 <83...@qq.com> on 2019/12/26 08:11:55 UTC, 0 replies.
- slot询问 - posted by 戴嘉诚 <a7...@gmail.com> on 2019/12/27 09:10:56 UTC, 1 replies.
- StreamTableEnvironment.registerDatastream() 开放用户自定义的schemaDescriptionh和DeserializationSchema - posted by "aven.wu" <da...@163.com> on 2019/12/27 11:56:29 UTC, 2 replies.
- Re: Error:java: 无效的标记: --add-exports=java.base/sun.net.util=ALL-UNNAMED - posted by Jark Wu <im...@gmail.com> on 2019/12/30 07:32:11 UTC, 0 replies.
- clean package maven dependency - posted by 陈赋赟 <as...@163.com> on 2019/12/30 10:06:31 UTC, 0 replies.
- Flink Weekly | 每周社区动态更新 - 2019/12/31 - posted by zhisheng <zh...@gmail.com> on 2019/12/31 01:15:01 UTC, 0 replies.
- 回复: StreamTableEnvironment.registerDatastream() 开放用户自定义的schemaDescriptionh和DeserializationSchema - posted by "aven.wu" <da...@163.com> on 2019/12/31 06:09:14 UTC, 0 replies.
- -yD Kerberos 认证问题 - posted by sl...@aliyun.com.INVALID on 2019/12/31 06:18:58 UTC, 1 replies.
- 回复: -yD Kerberos 认证问题 - posted by sl...@aliyun.com.INVALID on 2019/12/31 08:25:05 UTC, 0 replies.
- 如何获取算子处理一条数据记录的时间 - posted by 张江 <zj...@163.com> on 2019/12/31 09:14:09 UTC, 0 replies.
- flink内存分配的问题 - posted by cs <58...@qq.com> on 2019/12/31 09:53:31 UTC, 1 replies.
- 回复: flink内存分配的问题 - posted by cs <58...@qq.com> on 2019/12/31 12:51:50 UTC, 0 replies.
- How to get kafka record's timestamp in job - posted by 刘建刚 <li...@gmail.com> on 2019/12/31 14:37:17 UTC, 0 replies.