user-zh@flink.apache.org, 2020-05

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

- Re: Flink Task Manager GC overhead limit exceeded - posted by "shao.hongxiao" <17...@163.com> on 2020/05/01 00:34:48 UTC, 1 replies.
- Re: Python UDF from Java - posted by jincheng sun <su...@gmail.com> on 2020/05/01 00:49:01 UTC, 0 replies.
- flink sql 处理时间时区问题 - posted by hb <34...@163.com> on 2020/05/01 09:26:35 UTC, 5 replies.
- Broadcast stream causing GC overhead limit exceeded - posted by Eleanore Jin <el...@gmail.com> on 2020/05/03 01:38:54 UTC, 3 replies.
- Re: execution.checkpointing.tolerable-failed-checkpoints 无效 - posted by Congxian Qiu <qc...@gmail.com> on 2020/05/03 14:10:02 UTC, 0 replies.
- toAppendStream 类型不匹配问题 - posted by 祝尚 <17...@163.com> on 2020/05/03 17:00:47 UTC, 0 replies.
- Re: toAppendStream 类型不匹配问题 - posted by Jark Wu <im...@gmail.com> on 2020/05/04 03:22:13 UTC, 0 replies.
- 回复：toAppendStream 类型不匹配问题 - posted by "Sun.Zhu" <17...@163.com> on 2020/05/04 04:50:24 UTC, 0 replies.
- Export user metrics with Flink Prometheus endpoint - posted by Eleanore Jin <el...@gmail.com> on 2020/05/06 01:02:22 UTC, 0 replies.
- Re: 关于 generic type 的问题 - posted by Jingsong Li <ji...@gmail.com> on 2020/05/06 02:21:09 UTC, 0 replies.
- 回复: Re:FlinkSQL Retraction 问题原理咨询 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/05/06 02:36:35 UTC, 1 replies.
- Re: Flink监控: promethues获取到有的metrics没有包含flink 对应的job_name或者job_id - posted by Yun Tang <my...@live.com> on 2020/05/06 03:34:05 UTC, 0 replies.
- Re: Re:FlinkSQL Retraction 问题原理咨询 - posted by Jingsong Li <ji...@gmail.com> on 2020/05/06 03:35:49 UTC, 2 replies.
- What is the RocksDB local directory in flink checkpointing? - posted by LakeShen <sh...@gmail.com> on 2020/05/06 04:06:48 UTC, 2 replies.
- 回复：What is the RocksDB local directory in flink checkpointing? - posted by 范瑞 <83...@qq.com> on 2020/05/06 04:31:10 UTC, 0 replies.
- Flink 查询hive表初始化 Savepoint - posted by 王良 <ma...@qq.com> on 2020/05/06 08:40:54 UTC, 3 replies.
- 回复： flink 1.10内存设置 - posted by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/05/06 09:41:00 UTC, 1 replies.
- Re: flink 1.10内存设置 - posted by Xintong Song <to...@gmail.com> on 2020/05/06 10:05:13 UTC, 1 replies.
- Re: Re:Re:回复：flink1.9,state process api 读取MapState，出错 - posted by Congxian Qiu <qc...@gmail.com> on 2020/05/06 10:38:41 UTC, 0 replies.
- flink-提交jar 隔断时间自己重启问题 - posted by 祁森伟 <15...@163.com> on 2020/05/06 11:43:55 UTC, 0 replies.
- flink窗口函数AggregateFunction中，merge的作用和应用场景 - posted by Zhefu PENG <pe...@gmail.com> on 2020/05/06 12:34:29 UTC, 6 replies.
- 回复：flink窗口函数AggregateFunction中，merge的作用和应用场景 - posted by 1193216154 <11...@qq.com> on 2020/05/06 12:49:14 UTC, 0 replies.
- 回复：[基础定义] 有状态计算 & 无状态计算 - posted by dixingxing85 <di...@163.com> on 2020/05/06 15:56:43 UTC, 0 replies.
- 在已有 Hadoop 外搭建 standalone 模式 HA flink 集群 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/05/07 04:23:11 UTC, 0 replies.
- 回复: 在已有 Hadoop 外搭建 standalone 模式 HA flink 集群 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/05/07 04:30:52 UTC, 0 replies.
- 回复：在已有 Hadoop 外搭建 standalone 模式 HA flink 集群 - posted by Andrew <87...@qq.com> on 2020/05/07 04:31:01 UTC, 1 replies.
- 回复：flink-提交jar 隔断时间自己重启问题 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2020/05/07 06:05:43 UTC, 0 replies.
- Streaming SQL 的 Source/Sink 在 Append Mode/Upsert Mode 上的疑问 - posted by Luan Cooper <gc...@gmail.com> on 2020/05/07 12:39:24 UTC, 6 replies.
- flink on kubernetes 作业卡主现象咨询 - posted by a511955993 <a5...@163.com> on 2020/05/07 13:51:02 UTC, 1 replies.
- flink 1.10 使用 createTemporaryTable 注册表，SQL 使用 order by 报错 - posted by Hito Zhu <qr...@gmail.com> on 2020/05/08 01:52:38 UTC, 2 replies.
- 回复：flink on kubernetes 作业卡主现象咨询 - posted by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/05/08 02:06:07 UTC, 2 replies.
- exception：beyond the 'PHYSICAL' memory limit - posted by "tiantingting5435@163.com" <ti...@163.com> on 2020/05/08 05:16:39 UTC, 3 replies.
- flink-1.10 on yarn日志输出问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/05/08 07:43:40 UTC, 2 replies.
- 关于flink1.10.0使用HiveModule的问题 - posted by like <li...@163.com> on 2020/05/08 08:13:23 UTC, 2 replies.
- 回复：关于flink1.10.0使用HiveModule的问题 - posted by like <li...@163.com> on 2020/05/08 09:19:19 UTC, 1 replies.
- flink1.10 po extends ParentPo，print时候，无法print parent属性的字段 - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/08 09:47:19 UTC, 0 replies.
- 禁止在webui上停止job - posted by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/05/09 03:20:51 UTC, 0 replies.
- 回复：禁止在webui上停止job - posted by Zhonghan Tang <13...@163.com> on 2020/05/09 03:22:07 UTC, 0 replies.
- 可撤回流是否可以进行双流 Join？ - posted by LakeShen <sh...@gmail.com> on 2020/05/09 03:28:25 UTC, 3 replies.
- Re:Re:Re: flink-1.10 checkpoint 偶尔报 NullPointerException - posted by chenkaibit <ch...@163.com> on 2020/05/09 04:09:15 UTC, 0 replies.
- Flink-1.10-SQL TopN语法问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/05/09 05:51:51 UTC, 2 replies.
- 回复：flink-1.10 checkpoint 偶尔报 NullPointerException - posted by faaron zheng <fa...@gmail.com> on 2020/05/09 06:36:30 UTC, 0 replies.
- flink on yarn消费开启kerberos的kafka - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/05/09 08:00:04 UTC, 0 replies.
- 回复：flink on yarn消费开启kerberos的kafka - posted by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/05/09 08:06:00 UTC, 1 replies.
- flink lookup join 关联出多条记录的语义问题 - posted by 867127831 <86...@qq.com> on 2020/05/09 11:10:14 UTC, 4 replies.
- 回复： flink lookup join 关联出多条记录的语义问题 - posted by 867127831 <86...@qq.com> on 2020/05/09 12:21:13 UTC, 0 replies.
- flink1.9,FSstatebackend,checkpoint相关问题 - posted by guanyq <dl...@163.com> on 2020/05/10 23:33:50 UTC, 0 replies.
- flink1.9,FSstatebackend,checkpoint失败 - posted by guanyq <dl...@163.com> on 2020/05/11 00:21:03 UTC, 2 replies.
- How to get the applicationid internally when the Flink is running on yarn? - posted by 462329521 <46...@qq.com> on 2020/05/11 01:33:38 UTC, 0 replies.
- sql topN ArrayIndexOutOfBoundsException - posted by 1101300123 <hd...@163.com> on 2020/05/11 02:59:44 UTC, 0 replies.
- flink1.9 Blink sql 丢失主键+去重和时态表联合使用吞吐量低 - posted by 宇张 <zh...@akulaku.com> on 2020/05/11 03:14:28 UTC, 3 replies.
- MySQL写入并行度参数设置问题 - posted by "Senior.Hu" <46...@qq.com> on 2020/05/11 06:36:32 UTC, 1 replies.
- Flink SessionWindow在窗口创建的时候输出一条数据 - posted by "gang.gou" <go...@163.com> on 2020/05/11 07:06:44 UTC, 2 replies.
- 对flink源码中watermark对齐逻辑的疑惑 - posted by 1193216154 <11...@qq.com> on 2020/05/11 07:16:45 UTC, 2 replies.
- Flink PB序列化疑惑 - posted by chanamper <ch...@163.com> on 2020/05/11 07:57:11 UTC, 0 replies.
- Re: Flink Session Window在窗口创建的时候输出一条数据 - posted by Benchao Li <li...@gmail.com> on 2020/05/11 08:11:41 UTC, 1 replies.
- 回复： Re: flink-1.10 on yarn日志输出问题 - posted by 1101300123 <hd...@163.com> on 2020/05/11 10:11:07 UTC, 2 replies.
- Flink 严重背压问题排查 - posted by "aven.wu" <da...@163.com> on 2020/05/11 13:43:21 UTC, 1 replies.
- Prometheus pushgateway 监控 Flink metrics的问题 - posted by 李佳宸 <li...@gmail.com> on 2020/05/12 00:57:14 UTC, 1 replies.
- 1.10 使用 flinkSQL 的row_number()函数实现top1 出现数组越界，求助社区大佬 - posted by 1101300123 <hd...@163.com> on 2020/05/12 01:25:18 UTC, 3 replies.
- 回复： Flink 严重背压问题排查 - posted by 1101300123 <hd...@163.com> on 2020/05/12 01:45:36 UTC, 0 replies.
- 回复：Prometheus pushgateway 监控 Flink metrics的问题 - posted by 972684638 <da...@qq.com> on 2020/05/12 02:21:53 UTC, 0 replies.
- 回复： flink on kubernetes 作业卡主现象咨询 - posted by "shao.hongxiao" <17...@163.com> on 2020/05/12 07:39:54 UTC, 0 replies.
- Prometheus Pushgateway 监控 Flink 问题 - posted by 李佳宸 <li...@gmail.com> on 2020/05/12 10:25:10 UTC, 2 replies.
- flink10读取kafka报错 - posted by PCL <pe...@163.com> on 2020/05/12 13:43:09 UTC, 0 replies.
- 回复：flink10读取kafka报错 - posted by 忝忝向仧 <15...@qq.com> on 2020/05/12 14:36:17 UTC, 1 replies.
- 回复：Re:Prometheus Pushgateway 监控 Flink 问题 - posted by 972684638 <da...@qq.com> on 2020/05/12 15:24:10 UTC, 0 replies.
- 在使用flink1.7.2写入ES6的时候，有时会报错：request retries exceeded max retry timeout [30000] - posted by Jim Chen <ch...@gmail.com> on 2020/05/13 06:53:27 UTC, 1 replies.
- 回复: Re：flink10读取kafka报错 - posted by pengchenglin <pe...@163.com> on 2020/05/13 08:12:41 UTC, 0 replies.
- 回复: 在使用flink1.7.2写入ES6的时候，有时会报错：request retries exceeded max retry timeout [30000] - posted by "aven.wu" <da...@163.com> on 2020/05/13 08:26:35 UTC, 0 replies.
- 回复：在使用flink1.7.2写入ES6的时候，有时会报错：request retries exceeded max retry timeout [30000] - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/13 13:07:06 UTC, 0 replies.
- flink1.10 ddl metric 不显示 - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/13 13:09:24 UTC, 2 replies.
- [ANNOUNCE] Apache Flink 1.10.1 released - posted by Yu Li <ca...@gmail.com> on 2020/05/13 18:00:02 UTC, 8 replies.
- [CVE-2020-1960] Apache Flink JMX information disclosure vulnerability - posted by Chesnay Schepler <ch...@apache.org> on 2020/05/13 18:07:38 UTC, 0 replies.
- 回复： 1.10 使用 flinkSQL 的row_number()函数实现top1 出现数组越界，求助社区大佬 - posted by 1101300123 <hd...@163.com> on 2020/05/14 01:47:26 UTC, 0 replies.
- SQL DDL怎样使用Long类型的时间戳作为事件时间 - posted by "zzhbwh@foxmail.com" <zz...@foxmail.com> on 2020/05/14 02:01:46 UTC, 4 replies.
- Flink SQL解析问题 - posted by "Senior.Hu" <46...@qq.com> on 2020/05/14 07:30:10 UTC, 2 replies.
- flink1.10 ES sink 配置输出object字段问题 - posted by XiaChang <13...@163.com> on 2020/05/14 07:36:41 UTC, 1 replies.
- 关于SQLClient 支持的表类型 - posted by AlfredFeng <al...@qq.com> on 2020/05/14 08:07:22 UTC, 0 replies.
- Flink Weekly | 每周社区动态更新 - 2020/05/14 - posted by forideal <fs...@163.com> on 2020/05/14 11:57:31 UTC, 0 replies.
- save point容灾方案咨询 - posted by 请叫我雷锋 <85...@qq.com> on 2020/05/14 13:42:35 UTC, 5 replies.
- flink 历史数据join - posted by 小黑 <qq...@dingtalk.com.INVALID> on 2020/05/15 03:14:28 UTC, 5 replies.
- 回复：flink 历史数据join - posted by jimandlice <ji...@163.com> on 2020/05/15 03:38:43 UTC, 11 replies.
- 有什么方式可以获得各个task占用内存情况呢 - posted by Jeff <zi...@126.com> on 2020/05/15 06:52:19 UTC, 2 replies.
- 怎么排查taskmanager频繁挂掉的原因? - posted by Jeff <zi...@126.com> on 2020/05/15 07:05:28 UTC, 0 replies.
- 回复：怎么排查taskmanager频繁挂掉的原因? - posted by "shao.hongxiao" <17...@163.com> on 2020/05/15 07:14:20 UTC, 3 replies.
- 求教flink自定义python udf时TIMESTAMP类型问题 - posted by 元灵 <li...@126.com> on 2020/05/15 07:33:25 UTC, 0 replies.
- Flink1.10.1关于CliFronted命令行解析顺序引发的BUG - posted by 111 <xi...@163.com> on 2020/05/15 09:18:53 UTC, 1 replies.
- Flink-SQL on yarn 的bug - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/05/15 09:35:45 UTC, 1 replies.
- 回复：flink1.10 ddl metric 不显示 - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/16 03:08:07 UTC, 0 replies.
- flink build-in 的 udf 的源码 - posted by venn <wx...@163.com> on 2020/05/16 07:53:05 UTC, 3 replies.
- 回复: 回复：flink1.10 ddl metric 不显示 - posted by venn <wx...@163.com> on 2020/05/16 08:03:10 UTC, 0 replies.
- 回复：回复：flink1.10 ddl metric 不显示 - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/16 11:37:25 UTC, 0 replies.
- flink barrier对齐理解 - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/17 03:29:33 UTC, 3 replies.
- 回复：flink barrier对齐理解 - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/17 05:16:26 UTC, 2 replies.
- 使用sql时候，设置了idle过期时间，但是状态还是一直变大 - posted by claylin <10...@qq.com> on 2020/05/17 09:31:52 UTC, 1 replies.
- 回复：使用sql时候，设置了idle过期时间，但是状态还是一直变大 - posted by claylin <10...@qq.com> on 2020/05/17 09:41:13 UTC, 2 replies.
- 回复： save point容灾方案咨询 - posted by 请叫我雷锋 <85...@qq.com> on 2020/05/17 11:24:10 UTC, 0 replies.
- 回复：save point容灾方案咨询 - posted by 1048262223 <10...@qq.com> on 2020/05/17 13:17:24 UTC, 0 replies.
- 回复：回复：使用sql时候，设置了idle过期时间，但是状态还是一直变大 - posted by claylin <10...@qq.com> on 2020/05/17 14:23:43 UTC, 1 replies.
- flink sql使用维表关联时报Temporal table join currently only supports 'FOR SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()' - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/05/18 01:44:42 UTC, 6 replies.
- 回复: flink sql使用维表关联时报Temporal table join currently only supports 'FOR SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()' - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/05/18 01:48:09 UTC, 4 replies.
- 回复: flink build-in 的 udf 的源码 - posted by venn <wx...@163.com> on 2020/05/18 02:27:59 UTC, 0 replies.
- run flink on edge vs hub - posted by Eleanore Jin <el...@gmail.com> on 2020/05/18 02:39:27 UTC, 1 replies.
- 回复： flink sql使用维表关联时报Temporal table join currently only supports 'FOR SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()' - posted by 111 <xi...@163.com> on 2020/05/18 07:23:42 UTC, 1 replies.
- 数组越界 - posted by allanqinjy <al...@163.com> on 2020/05/18 08:36:22 UTC, 2 replies.
- 回复：数组越界 - posted by 1048262223 <10...@qq.com> on 2020/05/18 08:38:16 UTC, 2 replies.
- 回复: 回复： flink sql使用维表关联时报Temporal table join currently only supports 'FOR SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME()' - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/05/18 08:43:26 UTC, 0 replies.
- 回复： Flink SQL解析问题 - posted by "Senior.Hu" <46...@qq.com> on 2020/05/18 09:01:24 UTC, 0 replies.
- Flink Time Session Window 作业输出停止 - posted by 李佳宸 <li...@gmail.com> on 2020/05/18 09:38:21 UTC, 0 replies.
- flink sql提交读取hive的批作业出现异常“scala MatchError : MAP” - posted by 邹云鹤 <ke...@163.com> on 2020/05/19 03:15:17 UTC, 3 replies.
- 回复： flink sql提交读取hive的批作业出现异常“scala MatchError : MAP” - posted by 邹云鹤 <ke...@163.com> on 2020/05/19 04:09:25 UTC, 1 replies.
- Blink Planner构造Remote Env - posted by jun su <su...@gmail.com> on 2020/05/19 07:27:24 UTC, 1 replies.
- flink1.10怎么获得flink-shaded-hadoop包以支持hadoop3.2.1? - posted by Jeff <zi...@126.com> on 2020/05/20 02:09:10 UTC, 3 replies.
- 回复：flink1.10怎么获得flink-shaded-hadoop包以支持hadoop3.2.1? - posted by 111 <xi...@163.com> on 2020/05/20 02:21:57 UTC, 0 replies.
- Flink convert Table to DataSet[Row] - posted by 张锴 <zk...@gmail.com> on 2020/05/20 05:26:33 UTC, 8 replies.
- 关于FlinkSQL slot数量过多的问题 - posted by 111 <xi...@163.com> on 2020/05/20 06:13:24 UTC, 1 replies.
- 回复：关于FlinkSQL slot数量过多的问题 - posted by 111 <xi...@163.com> on 2020/05/20 06:50:15 UTC, 0 replies.
- TM太多，作业运行失败问题 - posted by a5...@163.com on 2020/05/20 07:50:24 UTC, 3 replies.
- Flink 1.10-SQL解析复杂json问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/05/20 07:51:23 UTC, 2 replies.
- sinktable更新部分字段问题 - posted by naturalfree <na...@126.com> on 2020/05/20 08:07:53 UTC, 2 replies.
- sql client定义指向elasticsearch索引密码问题 - posted by naturalfree <na...@126.com> on 2020/05/20 08:10:48 UTC, 2 replies.
- flink1.10.x 解析 arrar 问题 - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/20 08:25:00 UTC, 3 replies.
- 回复：TM太多，作业运行失败问题 - posted by a5...@163.com on 2020/05/20 08:50:40 UTC, 1 replies.
- 这种复杂数据直接解析成null了 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/05/20 10:06:14 UTC, 3 replies.
- 回复： flink1.10.x 解析 arrar 问题 - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/20 11:23:45 UTC, 1 replies.
- Flink Weekly | 每周社区动态更新 - 2020/05/20 - posted by 王雷 <fl...@gmail.com> on 2020/05/20 14:19:30 UTC, 0 replies.
- flink如何正则读取hdfs下的文件 - posted by 阿华田 <a1...@163.com> on 2020/05/21 02:57:10 UTC, 4 replies.
- 回复：flink如何正则读取hdfs下的文件 - posted by jimandlice <ji...@163.com> on 2020/05/21 02:58:47 UTC, 3 replies.
- flink sql jdbc 只要含有group by 语句就会报错No operations allowed after statement closed. - posted by "shao.hongxiao" <17...@163.com> on 2020/05/21 03:25:09 UTC, 2 replies.
- 回复： flink sql jdbc 只要含有group by 语句就会报错No operations allowed after statement closed. - posted by "shao.hongxiao" <17...@163.com> on 2020/05/21 03:41:13 UTC, 0 replies.
- 关于flink-streaming cogroup 算子 window 支持sideout 问题 - posted by "zhaiaosen@58.com" <zh...@58.com> on 2020/05/21 03:50:41 UTC, 1 replies.
- 回复： flink如何正则读取hdfs下的文件 - posted by 阿华田 <a1...@163.com> on 2020/05/21 06:56:23 UTC, 0 replies.
- 使用rocksdb backend 内存溢出的问题疑问 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/05/21 07:10:42 UTC, 3 replies.
- 按照官网进行flink-shell操作，出现无法解决的错误：Only BatchTableSource and InputFormatTableSource are supported in BatchTableEnvironment. - posted by 张锴 <zk...@gmail.com> on 2020/05/21 07:23:51 UTC, 5 replies.
- 回复: 使用rocksdb backend 内存溢出的问题疑问 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/05/21 07:37:57 UTC, 0 replies.
- flink 写入 Kafka 开启 eos 报错 - posted by 仙剑……情动人间 <15...@qq.com> on 2020/05/21 09:17:03 UTC, 0 replies.
- flink proctime error - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/21 13:07:42 UTC, 5 replies.
- flink 写入 kafka 并实现 eos 语义，kafka报错 - posted by yanlishuai <ya...@163.com> on 2020/05/21 14:28:45 UTC, 0 replies.
- flink正则读取hdfs目录下的文件 - posted by 阿华田 <a1...@163.com> on 2020/05/22 02:37:35 UTC, 1 replies.
- 本地测试 flink 1.10 hbase sql create table 在反序列化byte之后得到的对象conf配置为null，导致无法连接hbase集群 - posted by "shao.hongxiao" <17...@163.com> on 2020/05/22 02:43:42 UTC, 1 replies.
- 本地测试 flink 1.10 hbase sql create table 在反序列化byte之后得到的对象conf配置为null，导致无法连接hbase集群 - posted by "shao.hongxiao" <17...@163.com> on 2020/05/22 03:48:49 UTC, 2 replies.
- flink-table sink 与sql-cli结合案例 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/05/22 06:07:42 UTC, 0 replies.
- Flink 1.10 本机模式（DefaultActionSuspension.resume()是怎么被调用的，想知道这个调用的过程） - posted by <th...@yahoo.com.INVALID> on 2020/05/22 06:33:25 UTC, 0 replies.
- Session Window使用event time延迟特别高 - posted by 李佳宸 <li...@gmail.com> on 2020/05/22 07:17:38 UTC, 1 replies.
- 回复：sql client定义指向elasticsearch索引密码问题 - posted by naturalfree <na...@126.com> on 2020/05/22 08:08:16 UTC, 0 replies.
- 疑问：flink sql 不同job消费同一个kafka表(指定了groupId)时输出相同数据？ - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/05/22 08:21:18 UTC, 1 replies.
- DDL定义@timestamp字段问题提示org.apache.flink.table.api.SqlParserException - posted by oliver <zz...@foxmail.com> on 2020/05/22 09:30:44 UTC, 2 replies.
- How to control the banlence by using FlinkKafkaConsumer.setStartFromTimestamp(timestamp) - posted by Jary Zhen <ja...@gmail.com> on 2020/05/22 10:16:23 UTC, 1 replies.
- flink+prometheus继承问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/05/22 12:08:37 UTC, 0 replies.
- 回复：本地测试 flink 1.10 hbase sql create table 在反序列化byte之后得到的对象conf配置为null，导致无法连接hbase集群 - posted by "shao.hongxiao" <17...@163.com> on 2020/05/23 00:01:36 UTC, 1 replies.
- 回复：flink 写入 Kafka 开启 eos 报错 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2020/05/23 13:25:44 UTC, 0 replies.
- 回复：关于flink-streaming cogroup 算子 window 支持sideout 问题 - posted by Yun Gao <yu...@aliyun.com.INVALID> on 2020/05/23 13:32:19 UTC, 0 replies.
- 退出邮件组 - posted by huadong sun <su...@gmail.com> on 2020/05/24 01:24:03 UTC, 1 replies.
- 使用广播流要怎么保证广播流比数据流先到？ - posted by 462329521 <46...@qq.com> on 2020/05/24 03:32:17 UTC, 3 replies.
- 回复：使用广播流要怎么保证广播流比数据流先到？ - posted by 1048262223 <10...@qq.com> on 2020/05/24 06:07:46 UTC, 0 replies.
- 關於LocalExecutionEnvironment使用MiniCluster的配置 - posted by 月月 <yu...@gmail.com> on 2020/05/24 13:11:36 UTC, 3 replies.
- 关于水位线Watermark的理解 - posted by smq <37...@qq.com> on 2020/05/24 13:43:09 UTC, 3 replies.
- 回复：关于水位线Watermark的理解 - posted by smq <37...@qq.com> on 2020/05/24 14:22:51 UTC, 1 replies.
- 回复：使用广播流要怎么保证广播流比数据流先到？ - posted by kris wu <46...@qq.com> on 2020/05/24 15:38:12 UTC, 1 replies.
- Could not find a suitable table factory for 'TableSourceFactory' - posted by macia kk <pr...@gmail.com> on 2020/05/24 16:11:16 UTC, 8 replies.
- Flink SQL 新手问题，RowTime field should not be null, please convert it to a non-null long value - posted by Enzo wang <sr...@gmail.com> on 2020/05/25 01:52:15 UTC, 3 replies.
- 回复：Flink SQL 新手问题，RowTime field should not be null, please convert it to a non-null long value - posted by 1048262223 <10...@qq.com> on 2020/05/25 02:00:47 UTC, 0 replies.
- RichMapFunction的问题 - posted by "xuefli@outlook.com" <xu...@outlook.com> on 2020/05/25 03:28:55 UTC, 2 replies.
- 回复：RichMapFunction的问题 - posted by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/05/25 03:51:32 UTC, 0 replies.
- flink在source中定义了eventtime和watermark，可以在sink时从context中获取eventtime吗 - posted by Jie Wong <bi...@gmail.com> on 2020/05/25 09:19:04 UTC, 0 replies.
- 回复: RichMapFunction的问题 - posted by "xuefli@outlook.com" <xu...@outlook.com> on 2020/05/25 13:02:42 UTC, 0 replies.
- Flink SQL 嵌套 nested Json 解析 - posted by macia kk <pr...@gmail.com> on 2020/05/25 17:26:02 UTC, 6 replies.
- 回复: Re:Re: RichMapFunction的问题 - posted by "xuefli@outlook.com" <xu...@outlook.com> on 2020/05/26 01:38:00 UTC, 0 replies.
- 回复： Flink SQL 嵌套 nested Json 解析 - posted by claylin <10...@qq.com> on 2020/05/26 02:03:51 UTC, 1 replies.
- Re: pyflink 问题请教 - posted by jincheng sun <su...@gmail.com> on 2020/05/26 03:18:31 UTC, 0 replies.
- 用Sql输出到oracle - posted by Kyle Zhang <sh...@gmail.com> on 2020/05/26 03:42:18 UTC, 3 replies.
- flink 读写hive问题 - posted by Enzo wang <sr...@gmail.com> on 2020/05/26 08:42:12 UTC, 6 replies.
- 请教一个flink CEP的问题 - posted by Jun Zhang <82...@qq.com> on 2020/05/26 09:35:16 UTC, 0 replies.
- 使用滚动窗口的 Flink SQL State 一直增加 - posted by 瓜牛 <we...@qq.com> on 2020/05/26 10:07:00 UTC, 3 replies.
- 全局state - posted by star <31...@qq.com> on 2020/05/26 10:42:13 UTC, 1 replies.
- 回复：使用滚动窗口的 Flink SQL State 一直增加 - posted by 瓜牛 <we...@qq.com> on 2020/05/26 12:41:04 UTC, 0 replies.
- flink 1.10webui不显示print内容 - posted by smq <37...@qq.com> on 2020/05/26 13:39:45 UTC, 3 replies.
- 回复：flink 1.10webui不显示print内容 - posted by Lijie Wang <wa...@126.com> on 2020/05/26 14:14:33 UTC, 4 replies.
- 回复：全局state - posted by 1048262223 <10...@qq.com> on 2020/05/26 16:03:02 UTC, 4 replies.
- Flink SQL FIRST_VALUE 是append 模式吗？ - posted by macia kk <pr...@gmail.com> on 2020/05/26 17:19:30 UTC, 7 replies.
- 回复： flink 1.10webui不显示print内容 - posted by smq <37...@qq.com> on 2020/05/26 23:34:00 UTC, 1 replies.
- Flink sql 跨库 - posted by Zhou Zach <wa...@163.com> on 2020/05/27 02:55:48 UTC, 13 replies.
- native kubernetes在不同kubernetes版本构建失败问题 - posted by a5...@163.com on 2020/05/27 03:21:27 UTC, 4 replies.
- Flink read hive partition table failed - posted by Zhou Zach <wa...@163.com> on 2020/05/27 03:37:53 UTC, 0 replies.
- 回复：native kubernetes在不同kubernetes版本构建失败问题 - posted by a5...@163.com on 2020/05/27 04:51:36 UTC, 2 replies.
- 回复：sinktable更新部分字段问题 - posted by naturalfree <na...@126.com> on 2020/05/27 05:07:29 UTC, 0 replies.
- flink集群启动显示正在运行instance多,StandaloneSessionClusterEntrypoint启动后被kill - posted by smq <37...@qq.com> on 2020/05/27 05:39:39 UTC, 0 replies.
- 回复：flink集群启动显示正在运行instance多,StandaloneSessionClusterEntrypoint启动后被kill - posted by Lijie Wang <wa...@126.com> on 2020/05/27 05:52:13 UTC, 3 replies.
- 回复：回复：全局state - posted by star <31...@qq.com> on 2020/05/27 07:45:40 UTC, 0 replies.
- flink-python 配置文件问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/05/27 09:50:21 UTC, 1 replies.
- Table API 有类似于 SQL API 的 TO_TIMESTAMP 函数吗 - posted by macia kk <pr...@gmail.com> on 2020/05/27 16:45:26 UTC, 4 replies.
- flink 1.9 1.10 on yarn在cdh上怎么搭建一个客户端 - posted by 王飞 <wa...@163.com> on 2020/05/28 01:09:43 UTC, 0 replies.
- 回复：flink 1.9 1.10 on yarn在cdh上怎么搭建一个客户端 - posted by 111 <xi...@163.com> on 2020/05/28 01:13:52 UTC, 2 replies.
- flink 如何自定义connector - posted by Peihui He <pe...@gmail.com> on 2020/05/28 01:16:12 UTC, 3 replies.
- 向flink push代码 - posted by 宇张 <zh...@akulaku.com> on 2020/05/28 02:10:00 UTC, 5 replies.
- 回复： flink 如何自定义connector - posted by 111 <xi...@163.com> on 2020/05/28 02:13:23 UTC, 4 replies.
- flink sql 写 hive分区表失败 - posted by Zhou Zach <wa...@163.com> on 2020/05/28 04:57:09 UTC, 4 replies.
- 疑问：flink sql 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表的offset提交 - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/05/28 07:14:31 UTC, 7 replies.
- 关于kubernetes native配置的疑问 - posted by a5...@163.com on 2020/05/28 07:47:38 UTC, 2 replies.
- flink-sql watermark问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/05/28 08:22:40 UTC, 6 replies.
- recursive.file.enumeration使用问题 - posted by 阿华田 <a1...@163.com> on 2020/05/28 08:36:43 UTC, 0 replies.
- 回复：recursive.file.enumeration使用问题 - posted by 阿华田 <a1...@163.com> on 2020/05/28 08:38:58 UTC, 0 replies.
- 回复: flink-sql watermark问题 - posted by "112039604@qq.com" <11...@qq.com> on 2020/05/28 08:42:31 UTC, 0 replies.
- flink写入hbase 报错如下还会导致反压任务变慢 - posted by air23 <wa...@163.com> on 2020/05/28 08:57:35 UTC, 2 replies.
- 回复: 疑问：flink sql 当一个env下多个insert语句共享一个view时，是否会影响view中kafka源表的offset提交 - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/05/28 09:02:43 UTC, 2 replies.
- 回复：关于kubernetes native配置的疑问 - posted by a5...@163.com on 2020/05/28 09:48:49 UTC, 0 replies.
- FlinkKafkaConsumer消费kafka中avro格式的消息，直接用AvroDeserializationSchema总是运行失败，自己实现了一个AbstracteserializationSchema运行成功了。 - posted by hyangvv <hy...@163.com> on 2020/05/28 17:14:29 UTC, 0 replies.
- Re: FlinkKafkaConsumer消费kafka中avro格式的消息，直接用AvroDeserializationSchema总是运行失败，自己实现了一个AbstracteserializationSchema运行成功了。 - posted by Leonard Xu <xb...@gmail.com> on 2020/05/29 04:31:55 UTC, 1 replies.
- flink1.10 on yarn 问题 - posted by air23 <wa...@163.com> on 2020/05/29 05:38:22 UTC, 5 replies.
- pyflink Table Api连接外部系统问题 - posted by 刘亚坤 <ws...@163.com> on 2020/05/29 06:16:48 UTC, 0 replies.
- flink sql的json解析udf - posted by star <31...@qq.com> on 2020/05/29 06:33:43 UTC, 1 replies.
- 回复: Re: flink1.10 on yarn 问题 - posted by "wangweiguang@stevegame.cn" <wa...@stevegame.cn> on 2020/05/29 06:49:40 UTC, 0 replies.
- flink 访问hadoop集群问题 - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/29 07:06:21 UTC, 1 replies.
- 回复: flink 访问hadoop集群问题 - posted by "wangweiguang@stevegame.cn" <wa...@stevegame.cn> on 2020/05/29 07:19:31 UTC, 0 replies.
- 回复：flink sql的json解析udf - posted by star <31...@qq.com> on 2020/05/29 07:21:48 UTC, 0 replies.
- 回复： flink 访问hadoop集群问题 - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/29 07:35:36 UTC, 0 replies.
- 回复：flink 访问hadoop集群问题 - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/29 07:43:55 UTC, 0 replies.
- flink-1.10.0 hive-1.2.1 No operators defined in streaming topology - posted by 了不起的盖茨比 <57...@qq.com> on 2020/05/29 07:48:09 UTC, 1 replies.
- Kafka Consumer反序列化错问题 - posted by Even <45...@qq.com> on 2020/05/29 08:16:44 UTC, 3 replies.
- 回复：Kafka Consumer反序列化错问题 - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/05/29 08:33:19 UTC, 0 replies.
- flink sql的hbase connector问题 - posted by op <52...@qq.com> on 2020/05/29 08:44:56 UTC, 1 replies.
- 回复：flink sql的hbase connector问题 - posted by 111 <xi...@163.com> on 2020/05/29 08:47:47 UTC, 0 replies.
- 回复： flink-1.10.0 hive-1.2.1 No operators defined in streaming topology - posted by kcz <57...@qq.com> on 2020/05/29 09:19:47 UTC, 0 replies.
- 回复： Kafka Consumer反序列化错问题 - posted by Even <45...@qq.com> on 2020/05/29 10:44:49 UTC, 0 replies.
- Re: 关于flink sql 滚动窗口无法输出结果集合 - posted by Benchao Li <li...@gmail.com> on 2020/05/30 03:55:52 UTC, 0 replies.
- 提交flink代码无法创建taskmanager flink web界面一致停留在created状态，日志报错如下 - posted by 程龙 <13...@163.com> on 2020/05/30 11:13:51 UTC, 2 replies.