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

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

- pyflink的where该如何使用？如何筛选？ - posted by 洗你的头 <12...@qq.com> on 2020/11/01 02:08:18 UTC, 3 replies.
- Re: flink mysql cdc + hive streaming疑问 - posted by Jark Wu <im...@gmail.com> on 2020/11/01 03:04:45 UTC, 9 replies.
- Re: Flink反压定位算子 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/01 12:31:09 UTC, 0 replies.
- 回复：Flink反压定位算子 - posted by 范瑞 <83...@qq.com> on 2020/11/01 12:41:33 UTC, 0 replies.
- 回复: flink mysql cdc + hive streaming疑问 - posted by Zhang Yuxiao <yx...@outlook.com> on 2020/11/02 01:08:17 UTC, 0 replies.
- Re: 回复: flink任务挂掉后自动重启 - posted by zhisheng <zh...@gmail.com> on 2020/11/02 01:34:28 UTC, 7 replies.
- Re: flink 1.11.2 keyby 更换partition - posted by Peihui He <pe...@gmail.com> on 2020/11/02 02:01:20 UTC, 4 replies.
- 回复： pyflink的where该如何使用？如何筛选？ - posted by 洗你的头 <12...@qq.com> on 2020/11/02 02:12:40 UTC, 2 replies.
- Re: flink1.11 kafka connector - posted by zhisheng <zh...@gmail.com> on 2020/11/02 02:18:43 UTC, 0 replies.
- Re: flink1.11 elasticsearch connector - posted by zhisheng <zh...@gmail.com> on 2020/11/02 02:22:49 UTC, 0 replies.
- Re:回复：flink1.11连接mysql问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/11/02 02:28:04 UTC, 0 replies.
- 回复: Re:回复：flink1.11连接mysql问题 - posted by 史正超 <sh...@outlook.com> on 2020/11/02 03:30:37 UTC, 0 replies.
- 回复： flink1.11连接mysql问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/11/02 03:33:09 UTC, 1 replies.
- Re: flink-cdc-mysql 使用时遇到的问题 - posted by yangxusun9 <ya...@163.com> on 2020/11/02 03:44:20 UTC, 2 replies.
- Re: JDBC 并发写入量大时挂掉 - posted by LittleFall <15...@qq.com> on 2020/11/02 03:45:39 UTC, 0 replies.
- 回复: flink-cdc-mysql 使用时遇到的问题 - posted by 史正超 <sh...@outlook.com> on 2020/11/02 03:49:06 UTC, 0 replies.
- Re: flink任务挂掉后自动重启 - posted by silence <sl...@aliyun.com.INVALID> on 2020/11/02 04:46:57 UTC, 6 replies.
- Re: 【咨询JM磁盘磁盘打满问题】 - posted by Congxian Qiu <qc...@gmail.com> on 2020/11/02 05:44:52 UTC, 0 replies.
- 回复: 回复： flink1.11连接mysql问题 - posted by 史正超 <sh...@outlook.com> on 2020/11/02 06:20:54 UTC, 1 replies.
- 回复: 回复： pyflink的where该如何使用？如何筛选？ - posted by Evan <ch...@foxmail.com> on 2020/11/02 06:45:28 UTC, 0 replies.
- 使用BroadcastStream后checkpoint失效 - posted by restart <ne...@outlook.com> on 2020/11/02 06:53:07 UTC, 5 replies.
- 回复：退订 - posted by 531374489 <53...@qq.com> on 2020/11/02 07:58:04 UTC, 0 replies.
- 使用flink-CDC checkpoint超时问题 - posted by 丁浩浩 <18...@163.com> on 2020/11/02 08:08:00 UTC, 3 replies.
- Re: 退订 - posted by Jary Zhen <ja...@gmail.com> on 2020/11/02 08:08:13 UTC, 13 replies.
- kafka table connector eventTime的问题 - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/11/02 09:13:53 UTC, 2 replies.
- 大家好 kafka table connector eventTime的问题 - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/11/02 09:35:18 UTC, 2 replies.
- flink sql client IDEA中运行报错 - posted by xiongzhu <18...@163.com> on 2020/11/02 10:04:56 UTC, 0 replies.
- Temporal table join currently only supports 'FOR SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME() - posted by 史正超 <sh...@outlook.com> on 2020/11/02 11:40:32 UTC, 1 replies.
- FlinkSLQ双流join使用LAST_VALUE + INTERVAL JOIN时遇到问题 - posted by xiao cai <fl...@163.com> on 2020/11/02 11:56:53 UTC, 3 replies.
- Re:Flink Jdbc sink写入多表如何实现 - posted by hailongwang <18...@163.com> on 2020/11/02 16:21:12 UTC, 0 replies.
- Re:flink实时流中如何实时获取当前时间 - posted by hailongwang <18...@163.com> on 2020/11/02 16:24:36 UTC, 0 replies.
- 社区贡献求助 - posted by zihaodeng <28...@qq.com> on 2020/11/02 18:31:39 UTC, 2 replies.
- flink sql kafka connector with avro confluent schema registry support - posted by 陈帅 <ca...@gmail.com> on 2020/11/03 00:44:02 UTC, 1 replies.
- 回复: Re:flink实时流中如何实时获取当前时间 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/11/03 01:06:07 UTC, 0 replies.
- Re: 【PyFlink】对于数据以Csv()格式写入kafka报错，以及使用python udf时无法启动udf - posted by jing <m1...@163.com> on 2020/11/03 01:22:45 UTC, 6 replies.
- Re: flink在source中定义了eventtime和watermark，可以在sink时从context中获取eventtime吗 - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/11/03 02:07:58 UTC, 0 replies.
- Flink中是否可动态Task调度 - posted by zxyoung <xy...@163.com> on 2020/11/03 02:11:16 UTC, 1 replies.
- flink sql cdc任务提交报错 - posted by flink小猪 <18...@163.com> on 2020/11/03 02:41:57 UTC, 3 replies.
- flink输出流类型 - posted by Dream-底限 <zh...@akulaku.com> on 2020/11/03 03:52:47 UTC, 0 replies.
- 回复: Temporal table join currently only supports 'FOR SYSTEM_TIME AS OF' left table's proctime field, doesn't support 'PROCTIME() - posted by 史正超 <sh...@outlook.com> on 2020/11/03 06:01:19 UTC, 0 replies.
- 回复：回复： pyflink的where该如何使用？如何筛选？ - posted by 洗你的头 <12...@qq.com> on 2020/11/03 06:44:23 UTC, 0 replies.
- BroadcastProcessFunction对比KeyedBroadcastProcessFunction - posted by 赵一旦 <hi...@gmail.com> on 2020/11/03 07:54:06 UTC, 0 replies.
- yarn部署模式kerberos问题 - posted by "amenhub@163.com" <am...@163.com> on 2020/11/03 08:17:04 UTC, 2 replies.
- RT，如何动态提交管理Flink Job - posted by 林影 <br...@gmail.com> on 2020/11/03 09:46:27 UTC, 0 replies.
- TUMBLE函数不支持回撤流 - posted by 夜思流年梦 <li...@163.com> on 2020/11/03 09:46:48 UTC, 2 replies.
- 回复: TUMBLE函数不支持回撤流 - posted by 史正超 <sh...@outlook.com> on 2020/11/03 10:34:26 UTC, 0 replies.
- flink-1.11.2提交到yarn一直处于CREATED中 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/11/04 03:04:35 UTC, 5 replies.
- 回复：Re:Re: flink-1.10 checkpoint 偶尔报 NullPointerException - posted by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/11/04 03:30:53 UTC, 0 replies.
- 回复： flink-1.11.2提交到yarn一直处于CREATED中 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/11/04 03:44:54 UTC, 1 replies.
- Re: Re:Re: flink-1.10 checkpoint 偶尔报 NullPointerException - posted by Congxian Qiu <qc...@gmail.com> on 2020/11/04 05:28:54 UTC, 0 replies.
- 不同的算子能共用一个状态吗？ - posted by "hl9902@126.com" <hl...@126.com> on 2020/11/04 06:48:07 UTC, 3 replies.
- Re: Re: flink on yarn日志问题 - posted by bradyMk <zh...@126.com> on 2020/11/04 07:13:57 UTC, 1 replies.
- cdc代码报错 - posted by "hl9902@126.com" <hl...@126.com> on 2020/11/04 08:43:41 UTC, 3 replies.
- Re: flink 1.11 on k8s native session cluster模式报找不到configmap - posted by Fy <fa...@163.com> on 2020/11/04 09:27:46 UTC, 1 replies.
- flink1.11.0 sql自定义UDAF包含复合类型时报Incompatible types - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/11/04 09:29:37 UTC, 1 replies.
- 回复: flink1.11.0 sql自定义UDAF包含复合类型时报Incompatible types - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/11/04 09:50:15 UTC, 0 replies.
- union all 丢失部分数据 - posted by 夜思流年梦 <li...@163.com> on 2020/11/04 10:20:23 UTC, 3 replies.
- 退订订阅 - posted by wangleigis <wa...@163.com> on 2020/11/04 10:59:45 UTC, 1 replies.
- 提交flink sql任务报错 - posted by 丁浩浩 <18...@163.com> on 2020/11/04 11:20:38 UTC, 1 replies.
- 回复: union all 丢失部分数据 - posted by 史正超 <79...@qq.com> on 2020/11/04 11:27:57 UTC, 1 replies.
- flink 1.11.1 web ui 页面查看source算子的detail数据，recoreds sent等度量状态永远为0 - posted by Asahi Lee <97...@qq.com> on 2020/11/04 12:03:02 UTC, 3 replies.
- 1.11.1 报OutOfMemoryError: Metaspace. 错误 - posted by Asahi Lee <97...@qq.com> on 2020/11/04 12:08:37 UTC, 1 replies.
- flink 1.11 cdc: 如何将DataStream 要如何转成flink sql cdc里的table？ - posted by jindy_liu <28...@qq.com> on 2020/11/05 02:07:36 UTC, 3 replies.
- 关于flink任务挂掉报警的监控指标选择 - posted by bradyMk <zh...@126.com> on 2020/11/05 02:15:01 UTC, 2 replies.
- flink 1.11.2 cep rocksdb 性能调优 - posted by Peihui He <pe...@gmail.com> on 2020/11/05 03:05:41 UTC, 1 replies.
- 回复: cdc代码报错 - posted by "hl9902@126.com" <hl...@126.com> on 2020/11/05 03:35:18 UTC, 0 replies.
- Re: UDAF函数在over窗口使用问题 - posted by Tianwang Li <li...@gmail.com> on 2020/11/05 05:20:03 UTC, 0 replies.
- flink tm cpu cores设置 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/11/05 05:30:46 UTC, 11 replies.
- flink-1.11 写 hive 报错 - posted by nashcen <24...@qq.com> on 2020/11/05 07:49:57 UTC, 1 replies.
- JobManager responsible for xxx lost the leadership. - posted by 赵一旦 <hi...@gmail.com> on 2020/11/05 08:03:11 UTC, 2 replies.
- 回复：1.11.1 报OutOfMemoryError: Metaspace. 错误 - posted by Asahi Lee <97...@qq.com> on 2020/11/05 08:07:35 UTC, 0 replies.
- flink sql读写带kerberos认证的kafka问题请教 - posted by "amenhub@163.com" <am...@163.com> on 2020/11/05 08:19:30 UTC, 0 replies.
- flink1.11的cdc功能对消息顺序性的处理 - posted by 18392099563 <18...@163.com> on 2020/11/05 08:35:55 UTC, 2 replies.
- flink 1.11.0 chk超时 - posted by liangji <ji...@gmail.com> on 2020/11/05 08:57:23 UTC, 3 replies.
- Re: Re: sql-cli执行sql报错 - posted by zhisheng <zh...@gmail.com> on 2020/11/05 09:53:13 UTC, 0 replies.
- Flink1.11.0 sql org.apache.flink.connector.jdbc.dialect.MySQLDialect发现疑似bug - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/11/05 10:58:29 UTC, 0 replies.
- 回复: Flink1.11.0 sql org.apache.flink.connector.jdbc.dialect.MySQLDialect发现疑似bug - posted by 史正超 <sh...@outlook.com> on 2020/11/05 11:30:43 UTC, 1 replies.
- keyBy的数据均衡性 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/05 12:13:40 UTC, 2 replies.
- 回复：keyBy的数据均衡性 - posted by 范瑞 <83...@qq.com> on 2020/11/05 12:29:13 UTC, 0 replies.
- 关于cluster.evenly-spread-out-slots参数的底层原理 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/05 14:18:30 UTC, 2 replies.
- 回复: flink1.11的cdc功能对消息顺序性的处理 - posted by 史正超 <sh...@outlook.com> on 2020/11/05 15:36:44 UTC, 0 replies.
- flink savepoint - posted by 张锴 <zk...@gmail.com> on 2020/11/06 02:33:48 UTC, 6 replies.
- 请教一下目前flink submit能不能指定额外的依赖jar - posted by silence <sl...@aliyun.com.INVALID> on 2020/11/06 02:34:27 UTC, 7 replies.
- 请教大神们关于flink-sql中数据赋值问题 - posted by site <si...@163.com> on 2020/11/06 03:41:53 UTC, 2 replies.
- Re: Re:Re: Flink StreamingFileSink滚动策略 - posted by bradyMk <zh...@126.com> on 2020/11/06 03:47:33 UTC, 2 replies.
- KeyBy如何映射到物理分区 - posted by zxyoung <xy...@163.com> on 2020/11/06 08:46:46 UTC, 1 replies.
- flink cdc时间问题 - posted by 赵帅 <zh...@2b13c.com> on 2020/11/06 09:14:10 UTC, 0 replies.
- 回复：请教一下目前flink submit能不能指定额外的依赖jar - posted by 18...@163.com on 2020/11/06 19:15:38 UTC, 0 replies.
- flink savepoint 异常 - posted by 张锴 <zk...@gmail.com> on 2020/11/07 08:07:12 UTC, 1 replies.
- flink内存超用问题 - posted by "元始(Bob Hu)" <65...@qq.com> on 2020/11/07 15:57:55 UTC, 2 replies.
- flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象 - posted by Asahi Lee <97...@qq.com> on 2020/11/09 02:46:00 UTC, 3 replies.
- 通过Yarn提交Application模式的job TaskManager无法输出日志 - posted by "xiaozhennan1995@gmail.com" <xi...@gmail.com> on 2020/11/09 05:40:42 UTC, 0 replies.
- flink侧输出算子堵住的问题 - posted by "ZT.Ren" <18...@163.com> on 2020/11/09 07:47:12 UTC, 1 replies.
- native K8s模式下，pod系统占用内存 - posted by caozhen <ca...@163.com> on 2020/11/09 08:56:04 UTC, 1 replies.
- 回复： flink 1.11.2 如何获取blink计划下的BatchTableEnvironment对象 - posted by Asahi Lee <97...@qq.com> on 2020/11/09 09:09:10 UTC, 1 replies.
- Flink-sql 读取hive报错,invalid type code: 9C. - posted by john <50...@qq.com> on 2020/11/09 14:50:28 UTC, 0 replies.
- Flink 读取Hive，报错：Could not read the user code wrapper: invalid type code: 9C。 - posted by 蒋龙 <jo...@icloud.com.INVALID> on 2020/11/10 00:19:39 UTC, 1 replies.
- Flink与Yarn的状态一致性问题 - posted by "amenhub@163.com" <am...@163.com> on 2020/11/10 01:58:55 UTC, 13 replies.
- Flink sql tinyint类型使用in 报错 - posted by 丁浩浩 <18...@163.com> on 2020/11/10 03:41:47 UTC, 6 replies.
- 请问有哪些功能，是 stream api 可以做到，而 table api 无法做到的呢？ - posted by LittleFall <15...@qq.com> on 2020/11/10 06:42:39 UTC, 7 replies.
- flink sql LATERAL TABLE - posted by 赵帅 <zh...@2b13c.com> on 2020/11/10 06:47:42 UTC, 1 replies.
- flink sql lateral table问题 - posted by 赵帅 <zh...@2b13c.com> on 2020/11/10 07:14:33 UTC, 0 replies.
- Flink SQL传递性 - posted by "amenhub@163.com" <am...@163.com> on 2020/11/10 07:28:14 UTC, 1 replies.
- flink cdc 当mysql表字段修改之后提示没有找到这个字段 - posted by 丁浩浩 <18...@163.com> on 2020/11/10 07:36:15 UTC, 1 replies.
- Re: SQL从1.9迁移到1.11的问题 - posted by Danny Chan <da...@apache.org> on 2020/11/10 07:39:21 UTC, 1 replies.
- Re: 讨论分析：数据类型对于shuffle时数据传输IO速度的影响（数十倍的差距） - posted by 赵一旦 <hi...@gmail.com> on 2020/11/10 12:06:51 UTC, 0 replies.
- Flink sql查询NULL值错误 - posted by 丁浩浩 <18...@163.com> on 2020/11/10 12:14:44 UTC, 3 replies.
- 自定义的 MySQLSink 怎么保证一定会写到数据库呢？ - posted by "wanglei2@geekplus.com" <wa...@geekplus.com> on 2020/11/10 13:16:31 UTC, 0 replies.
- flinksql 输出到kafka用的fixed的方式结果都输出到一个topic分区了，这个是什么原因 - posted by leiyanrui <11...@qq.com> on 2020/11/10 13:45:59 UTC, 4 replies.
- 所有的taskmanager都在一台节点上运行 - posted by "liyakun@huimin100.cn" <li...@huimin100.cn> on 2020/11/10 14:27:45 UTC, 1 replies.
- 背压问题排查疑问求解 - posted by restart <ne...@outlook.com> on 2020/11/11 02:37:25 UTC, 3 replies.
- Flink sql cdc 锁超时 - posted by 丁浩浩 <18...@163.com> on 2020/11/11 03:28:02 UTC, 1 replies.
- flink1.11 读取kafka avro格式数据发序列化失败 - posted by 奔跑的小飞袁 <s_...@126.com> on 2020/11/11 03:40:03 UTC, 0 replies.
- 回复：flink1.11 读取kafka avro格式数据发序列化失败 - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/11/11 03:56:32 UTC, 2 replies.
- 怎样实现超过一定时间没有收到消息就发出报警的功能？ - posted by Lei Wang <le...@gmail.com> on 2020/11/11 05:54:22 UTC, 6 replies.
- flink 1.11.1 使用sql ，使用hbase作为维表进行temporal join时无法获取数据 - posted by 鱼子酱 <38...@qq.com> on 2020/11/11 06:29:11 UTC, 1 replies.
- Flink cdc mysql 字段是datetime类型时0000-00-00 00:00:00会被flink转成1970-01-01T00:00 - posted by 丁浩浩 <18...@163.com> on 2020/11/11 06:37:06 UTC, 1 replies.
- slot数量与并行度的大小关系 - posted by "hl9902@126.com" <hl...@126.com> on 2020/11/11 06:58:42 UTC, 4 replies.
- 有没有办法把flink Row类转换为Object - posted by "ZT.Ren" <18...@163.com> on 2020/11/11 07:22:54 UTC, 1 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 2.2.1 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2020/11/11 08:57:26 UTC, 0 replies.
- 回复: Flink cdc mysql 字段是datetime类型时0000-00-00 00:00:00会被flink转成1970-01-01T00:00 - posted by 史正超 <sh...@outlook.com> on 2020/11/11 09:10:55 UTC, 0 replies.
- 1.11版本的yarn-session如何指定taskmanager数量 - posted by kingdomad <ki...@163.com> on 2020/11/11 09:14:41 UTC, 4 replies.
- flink sql hbase维表关联性能上不去 - posted by "kandy.wang" <ka...@163.com> on 2020/11/11 09:52:36 UTC, 0 replies.
- UDTAGG在SQL中可以使用么，语法是什么 - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/11/11 12:26:54 UTC, 1 replies.
- ElasticsearchApiCallBridge相关类构造函数问题 - posted by Luna Wong <gf...@gmail.com> on 2020/11/11 13:16:28 UTC, 1 replies.
- flink 1.11.1 使用mysql作为维表进行temporal join时,偶尔会报超时异常导致数据更新失败,请教解决方案 - posted by xiexinyuan341 <xi...@163.com> on 2020/11/12 02:52:43 UTC, 4 replies.
- 关于filesystem connector的一点疑问 - posted by admin <17...@163.com> on 2020/11/12 03:58:22 UTC, 7 replies.
- flink sql 函数FIRST_VALUE调用报错 - posted by me <me...@lishiyu.cn> on 2020/11/12 09:56:39 UTC, 4 replies.
- Re: Re: flink1.9.1任务已经fail掉了，但在yarn上这个application还是在running - posted by "amenhub@163.com" <am...@163.com> on 2020/11/12 10:48:13 UTC, 0 replies.
- 回复: Flink与Yarn的状态一致性问题 - posted by hdxg1101300123 <hd...@163.com> on 2020/11/12 12:07:01 UTC, 0 replies.
- batch模式broadcast hash join为什么会有数据丢失 - posted by 键 <19...@qq.com> on 2020/11/12 12:59:11 UTC, 0 replies.
- flink-1.11.2 执行checkpoint失败 - posted by 史正超 <sh...@outlook.com> on 2020/11/12 13:16:37 UTC, 2 replies.
- 回复：flink-1.11.2 执行checkpoint失败 - posted by 601049502 <60...@qq.com> on 2020/11/13 01:44:56 UTC, 0 replies.
- 回复: 回复：flink-1.11.2 执行checkpoint失败 - posted by 史正超 <sh...@outlook.com> on 2020/11/13 01:50:44 UTC, 1 replies.
- 回复：回复: 回复：flink-1.11.2 执行checkpoint失败 - posted by ﹏〆﹎゛独家记忆 <60...@qq.com> on 2020/11/13 01:55:21 UTC, 0 replies.
- 回复: flink-1.11.2 执行checkpoint失败 - posted by 史正超 <sh...@outlook.com> on 2020/11/13 01:59:48 UTC, 2 replies.
- flink 1.11.2 cdc: cdc sql 结果表的sink顺序问题，不同并行度下从save point中恢复job时，会导致sink结果不对！！ - posted by jindy_liu <28...@qq.com> on 2020/11/13 05:12:26 UTC, 15 replies.
- Re: flink-1.11 使用 application 模式时 jobid 问题 - posted by zhisheng <zh...@gmail.com> on 2020/11/13 07:39:05 UTC, 2 replies.
- Re: flink本地编译源码失败 - posted by leiyanrui <11...@qq.com> on 2020/11/13 08:20:02 UTC, 0 replies.
- flink 任务动态编译异常 - posted by iwodetianna <iw...@aliyun.com.INVALID> on 2020/11/13 08:26:49 UTC, 0 replies.
- pyflink 1.11 运行pyflink作业时报错 - posted by whh_960101 <wh...@163.com> on 2020/11/13 09:06:29 UTC, 3 replies.
- 确认订阅user-zh@flink.apache.org - posted by 黑色 <xi...@qq.com> on 2020/11/13 10:12:40 UTC, 1 replies.
- Flink cdc 多表关联处理延迟很大 - posted by 丁浩浩 <18...@163.com> on 2020/11/13 11:01:17 UTC, 10 replies.
- 回复: Re:回复: flink-1.11.2 执行checkpoint失败 - posted by 史正超 <sh...@outlook.com> on 2020/11/14 03:27:57 UTC, 0 replies.
- 邮件退订 - posted by wangleigis <wa...@163.com> on 2020/11/14 03:54:34 UTC, 1 replies.
- flink sql ddl连接kafka,flink sql使用事件时间无法正常触发时间窗口 - posted by 李世钰 <me...@lishiyu.cn> on 2020/11/14 07:03:59 UTC, 1 replies.
- flink1.11 sql ddl 连接kafka读取数据，使用事件时间窗口，无法触发，相同的sql使用系统时间触发没有问题 - posted by 李世钰 <me...@lishiyu.cn> on 2020/11/14 08:34:54 UTC, 1 replies.
- flink 1.11.2 如何配置时区 - posted by Asahi Lee <97...@qq.com> on 2020/11/14 08:58:23 UTC, 1 replies.
- 回复：flink 1.11.2 如何配置时区 - posted by Asahi Lee <97...@qq.com> on 2020/11/14 09:21:28 UTC, 0 replies.
- Re: Flink中readFile中如何只读取增量文件 - posted by hepingtao <he...@aliyun.com.INVALID> on 2020/11/15 00:35:18 UTC, 2 replies.
- 关于去重（Deduplication） - posted by macia kk <pr...@gmail.com> on 2020/11/15 11:22:08 UTC, 4 replies.
- jobmanager与taskmanager之间用rpc通信，为什么taskmanager之间用netty通信？ - posted by Jeff <zi...@126.com> on 2020/11/15 13:40:37 UTC, 0 replies.
- flink 1.11.2运行时出错 - posted by 曹武 <14...@163.com> on 2020/11/16 01:31:03 UTC, 0 replies.
- flink sql hive streaming报错，不知道是不是bug - posted by Excalibur <97...@qq.com> on 2020/11/16 02:48:13 UTC, 2 replies.
- 回复：flink sql hive streaming报错，不知道是不是bug - posted by Excalibur <97...@qq.com> on 2020/11/16 03:07:53 UTC, 0 replies.
- 回复：Flink中readFile中如何只读取增量文件 - posted by hectorhedev <he...@aliyun.com.INVALID> on 2020/11/16 03:48:20 UTC, 0 replies.
- 回复: Flink中readFile中如何只读取增量文件 - posted by Hector He <he...@live.com> on 2020/11/16 03:56:07 UTC, 0 replies.
- flink-1.11.2 job启动不起来， - posted by 史正超 <sh...@outlook.com> on 2020/11/16 05:30:00 UTC, 2 replies.
- flink算子类在多个subtask中是各自初始化1个实例对象吗？ - posted by "hl9902@126.com" <hl...@126.com> on 2020/11/16 05:55:45 UTC, 1 replies.
- Flink sql 无法用!= - posted by 丁浩浩 <18...@163.com> on 2020/11/16 06:20:47 UTC, 2 replies.
- changlog-json的去重方法 - posted by DovEゞ <24...@qq.com> on 2020/11/16 06:27:05 UTC, 0 replies.
- Reduce等函数的对下reuse问题 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/16 06:40:55 UTC, 2 replies.
- Blink 1.11 create view是不是没有办法把rowtime带下去？ - posted by 周虓岗 <zh...@163.com> on 2020/11/16 06:48:35 UTC, 3 replies.
- Flink sql-client/sql-gateway 支持multiple insert - posted by 朱广彬 <zh...@gmail.com> on 2020/11/16 08:38:48 UTC, 0 replies.
- pyflink利用sql ddl连接hbase-1.4.x出错Configuring the input format (null) failed: Cannot create connection to HBase - posted by ghostviper <ch...@gmail.com> on 2020/11/16 09:02:48 UTC, 1 replies.
- flink-1.11.2 的内存溢出问题 - posted by 史正超 <sh...@outlook.com> on 2020/11/16 09:53:33 UTC, 2 replies.
- pyflink利用sql ddl连接hbase-1.4.x出错 - posted by ghostviper <ch...@gmail.com> on 2020/11/16 10:04:05 UTC, 0 replies.
- flink 1.11.1 使用flinksql，jdbc ，后台数据库设置主键的情况下，upsert不生效 - posted by 鱼子酱 <38...@qq.com> on 2020/11/16 10:04:23 UTC, 5 replies.
- flink 1.11.1 使用flinksql，jdbc ，设置主键的情况下，upsert不生效 - posted by 鱼子酱 <38...@qq.com> on 2020/11/16 10:05:19 UTC, 0 replies.
- 回复: flink-1.11.2 的内存溢出问题 - posted by 史正超 <sh...@outlook.com> on 2020/11/16 10:38:21 UTC, 3 replies.
- Flink JSON反序列化DECIMAL精度丢失 - posted by Luna Wong <gf...@gmail.com> on 2020/11/16 10:38:58 UTC, 1 replies.
- zookeeper更换leader对flink的影响 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/16 10:39:29 UTC, 1 replies.
- Re: Flink mysqlCDC ,然后jdbc sink 到mysql 乱序问题 - posted by jindy_liu <28...@qq.com> on 2020/11/16 10:47:02 UTC, 0 replies.
- Flink未来会弃用TableSourceFactory吗 - posted by Luna Wong <gf...@gmail.com> on 2020/11/16 11:54:36 UTC, 2 replies.
- 回复：回复: flink-1.11.2 的内存溢出问题 - posted by Andrew <87...@qq.com> on 2020/11/17 01:30:40 UTC, 0 replies.
- 回复: Re:flink 1.11.1 使用flinksql，jdbc ，后台数据库设置主键的情况下，upsert不生效 - posted by 史正超 <sh...@outlook.com> on 2020/11/17 02:20:57 UTC, 0 replies.
- 回复: 回复: flink-1.11.2 的内存溢出问题 - posted by 史正超 <sh...@outlook.com> on 2020/11/17 02:42:39 UTC, 0 replies.
- 使用flink1.11.1的debezium-changelog目前是否不支持Watermark - posted by shimin huang <hu...@gmail.com> on 2020/11/17 02:53:17 UTC, 1 replies.
- flink keyedState 能不能存储泛型或抽象类型 - posted by Lei Wang <le...@gmail.com> on 2020/11/17 03:55:32 UTC, 1 replies.
- java.lang.IncompatibleClassChangeError: Implementing class (using blink-planner) - posted by norman <no...@cisco.com.INVALID> on 2020/11/17 06:22:46 UTC, 0 replies.
- 从 savepoint 中恢复应用时发生 KafkaException: Unexpected error in InitProducerIdResponse - posted by chang chan <gi...@gmail.com> on 2020/11/17 07:36:07 UTC, 0 replies.
- ByteArrayDeserializer is not an instance of org.apache.kafka.common.serialization.Deserializer - posted by kingdomad <ki...@163.com> on 2020/11/17 08:47:08 UTC, 3 replies.
- py4j.protocol.Py4JJavaError: An error occurred while calling o21.select. : org.apache.flink.table.api.ValidationException: Undefined function: createTime - posted by anfeng <an...@akulaku.com> on 2020/11/17 09:07:45 UTC, 1 replies.
- Re: pyflink1.11 window groupby出错 - posted by anfeng <an...@akulaku.com> on 2020/11/17 09:27:41 UTC, 3 replies.
- 请教这种数据格式怎么配置event time呢 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/17 15:43:29 UTC, 2 replies.
- flink1.11 TableEnvironment 不支持注册 Aggregate Function？ - posted by lingchanhu <li...@163.com> on 2020/11/18 01:49:40 UTC, 6 replies.
- flink web ui 页面按钮控制 - posted by 祁洁 <12...@qq.com> on 2020/11/18 03:01:20 UTC, 1 replies.
- 使用jdbccatalog读取pg数据时，sql语句中的where条件没办法带到数据库执行吗？ - posted by 潘建军 <jj...@icloud.com.INVALID> on 2020/11/18 03:41:07 UTC, 0 replies.
- 自定义分区提交策略之合并小文件的问题 - posted by admin <17...@163.com> on 2020/11/18 03:41:24 UTC, 0 replies.
- 回复：Flink cdc 多表关联处理延迟很大 - posted by flink小猪 <18...@163.com> on 2020/11/18 05:37:26 UTC, 0 replies.
- 求助：Flink DataStream 的 windowoperator 后面apply 方法不执行 - posted by huang botao <bo...@gmail.com> on 2020/11/18 08:29:54 UTC, 5 replies.
- Flink任务启动偶尔报错PartitionNotFoundException，会自动恢复。 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/18 08:52:57 UTC, 5 replies.
- 转发：flink web ui 页面按钮控制 - posted by 祁洁 <12...@qq.com> on 2020/11/18 09:12:08 UTC, 0 replies.
- 使用window function后checkpoint fail，报错Operation category WRITE is not supported in state standby - posted by kingdomad <ki...@163.com> on 2020/11/18 09:19:29 UTC, 1 replies.
- 回复： flink web ui 页面按钮控制 - posted by 祁洁 <12...@qq.com> on 2020/11/18 09:20:25 UTC, 0 replies.
- Re: Re: 回复：回复：回复：flinksql指定kafka多topic - posted by 赵一旦 <hi...@gmail.com> on 2020/11/18 09:47:59 UTC, 1 replies.
- Flink cdc扫描过程报错Query execution was interrupted, maximum statement execution time exceeded - posted by 丁浩浩 <18...@163.com> on 2020/11/18 10:26:40 UTC, 1 replies.
- es线程死锁问题 - posted by "359502980@qq.com" <35...@qq.com> on 2020/11/18 12:45:14 UTC, 0 replies.
- 如何加载mysql数据到flink任务内存 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/11/18 15:58:52 UTC, 1 replies.
- flink on yarn 任务FAILED后没有错误日志输出到yarn log - posted by air23 <wa...@163.com> on 2020/11/19 03:39:06 UTC, 1 replies.
- flink1.11.1任务重启偶现org.apache.kafka.common.KafkaException: Failed to construct kafka consumer异常 - posted by m13162790856 <m1...@163.com> on 2020/11/19 07:33:25 UTC, 3 replies.
- Flink 1.10 和 Flink 1.11 中 keyBy 算子聚合多个字段的问题 - posted by sherlock zw <zw...@LIVE.COM> on 2020/11/19 11:34:09 UTC, 2 replies.
- flink sql cdc sum 结果出现NULL - posted by "kandy.wang" <ka...@163.com> on 2020/11/19 14:41:10 UTC, 9 replies.
- 关于global window - posted by j l <sp...@gmail.com> on 2020/11/19 18:19:09 UTC, 1 replies.
- 答复: Flink 1.10 和 Flink 1.11 中 keyBy 算子聚合多个字段的问题 - posted by sherlock zw <zw...@LIVE.COM> on 2020/11/20 03:18:16 UTC, 1 replies.
- FlinkSQL 支持DDL时补全字段并进行默认值设置吗? - posted by 孟小鹏 <me...@qq.com> on 2020/11/20 03:37:27 UTC, 2 replies.
- 关于CatalogPartitionSpec类的一些想法 - posted by Jun Zhang <82...@qq.com> on 2020/11/20 06:35:12 UTC, 1 replies.
- 关于 Flink on K8S Deploy Job Cluster 部署问题 - posted by WeiXubin <18...@163.com> on 2020/11/20 07:20:58 UTC, 2 replies.
- Flink实时两个stream进行union，结果只有其中一个流的数据发送到了下游 - posted by Yang Peng <ya...@gmail.com> on 2020/11/20 07:59:46 UTC, 0 replies.
- Re: flink on yarn 任务FAILED后没有错误日志输出到yarn log - posted by caozhen <ca...@163.com> on 2020/11/20 09:53:03 UTC, 2 replies.
- 回复：flink-1.11.1 Table API /SQL 无法写入hive orc表 - posted by 迎风浪子 <57...@qq.com> on 2020/11/20 10:44:00 UTC, 0 replies.
- Flink Standalone HA问题 - posted by Fei Han <ha...@aliyun.com.INVALID> on 2020/11/21 03:51:24 UTC, 1 replies.
- flink1.11.2 sql读取datahub sls - posted by 二白 <28...@qq.com> on 2020/11/22 04:18:53 UTC, 0 replies.
- 用flink 1.11.2 查询hive表自关联(self inner join) 结果不正确 - posted by macdoor <ma...@gmail.com> on 2020/11/22 18:37:33 UTC, 2 replies.
- flink 1.11.2 SQL Client self inner join 结果不正确 - posted by macdoor <ma...@gmail.com> on 2020/11/22 18:40:30 UTC, 1 replies.
- 加载外部配置文件 - posted by 范未太 <fw...@163.com> on 2020/11/23 01:55:03 UTC, 0 replies.
- FlinkSQL CDC 窗口分组聚合求助 - posted by jy l <lj...@gmail.com> on 2020/11/23 02:28:30 UTC, 5 replies.
- maven overlapp 情况下shade选择 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/23 02:32:25 UTC, 0 replies.
- flink zeppelin的type参数(append/update/single)和flink的动态表有关系嘛 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/23 05:11:11 UTC, 1 replies.
- JdbcUpsertTableSink输出的时候报‘Duplicate entry’问题 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/23 06:15:01 UTC, 12 replies.
- pyflink 1.11.1 调用包含第三方依赖库的udf时报错 - posted by "fengmuqiang@ruqimobility.com" <fe...@ruqimobility.com> on 2020/11/23 08:10:38 UTC, 1 replies.
- flink sql 通过group by 滑窗计算的结果sink到kafka后有重复数据 - posted by dpzhoufengdev <dp...@163.com> on 2020/11/23 08:27:23 UTC, 2 replies.
- flink读mysql分库分表 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/11/23 09:22:06 UTC, 1 replies.
- 关于Catalog的建议 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/23 11:41:24 UTC, 4 replies.
- statementset下source怎么完全复用 - posted by Jeff <zi...@126.com> on 2020/11/23 14:23:11 UTC, 0 replies.
- flink sql 中是否可以使用 mysql 的存储过程和函数？ - posted by macdoor <ma...@gmail.com> on 2020/11/23 17:41:49 UTC, 1 replies.
- 回复：flink sql 通过group by 滑窗计算的结果sink到kafka后有重复数据 - posted by dpzhoufengdev <dp...@163.com> on 2020/11/24 01:42:37 UTC, 0 replies.
- Flink SQL 对延迟数据怎么处理？ - posted by jy l <lj...@gmail.com> on 2020/11/24 02:03:13 UTC, 1 replies.
- 关于flink实时写入hbase用flush方法频繁报操作超时问题 - posted by bradyMk <zh...@126.com> on 2020/11/24 02:32:55 UTC, 2 replies.
- Flink SQL Row里嵌套Array该如何用DDL定义? - posted by zilong xiao <ac...@gmail.com> on 2020/11/24 02:49:02 UTC, 8 replies.
- Flink SQL的灵异事件----查询语句中增加表中的某个字段时就没法正常查询了。 - posted by jy l <lj...@gmail.com> on 2020/11/24 03:27:05 UTC, 2 replies.
- flink使用hive udf函数 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/11/24 03:54:36 UTC, 1 replies.
- ProcessingTime下的watermark - posted by Kyle Zhang <sh...@gmail.com> on 2020/11/24 05:33:43 UTC, 1 replies.
- flink table api 或者 sql 使用自定义含有的state方法 - posted by 戴嘉诚 <a7...@gmail.com> on 2020/11/24 06:43:32 UTC, 0 replies.
- FlinkSQL导致Prometheus内存暴涨 - posted by Luna Wong <gf...@gmail.com> on 2020/11/24 07:19:40 UTC, 3 replies.
- flink on native k8s deploy issue - posted by 吴松 <wu...@funstory.ai> on 2020/11/24 07:51:20 UTC, 2 replies.
- SQL Cli中找不到DeserializationSchemaFactory - posted by jy l <lj...@gmail.com> on 2020/11/24 10:52:03 UTC, 1 replies.
- flink 自定义AggregateFunction 如何识别HyperLogLog对象？ - posted by "kandy.wang" <ka...@163.com> on 2020/11/24 12:32:12 UTC, 0 replies.
- 测试用例调试问题 - posted by zilong xiao <ac...@gmail.com> on 2020/11/24 13:36:17 UTC, 0 replies.
- Flink CDC 遇到关于不发生packet造成的卡顿问题该如何解决 - posted by yujianbo <15...@163.com> on 2020/11/24 15:53:50 UTC, 0 replies.
- Re: Flink CDC 遇到关于不发生packet造成的卡顿问题该如何解决 - posted by Jark Wu <im...@gmail.com> on 2020/11/24 16:21:43 UTC, 6 replies.
- (无主题) - posted by gfjia <gf...@163.com> on 2020/11/25 01:41:44 UTC, 0 replies.
- slot问题 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/11/25 02:32:33 UTC, 2 replies.
- 关于standalone集群中JobManager进程卡顿的问题 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/25 02:53:31 UTC, 0 replies.
- Flink Sink function 的 close(）在程序停止时一定会被调用到吗？ - posted by Lei Wang <le...@gmail.com> on 2020/11/25 03:55:26 UTC, 0 replies.
- flink sql时间戳字段类型转换问题 - posted by 陈帅 <ca...@gmail.com> on 2020/11/25 04:03:18 UTC, 1 replies.
- delete - posted by Xev Orm <or...@gmail.com> on 2020/11/25 04:23:58 UTC, 0 replies.
- Re: Unsubscribe - posted by Xev Orm <or...@gmail.com> on 2020/11/25 04:26:30 UTC, 1 replies.
- flink sql 连接mysql 无数据输出 - posted by 冯草纸 <al...@qq.com> on 2020/11/25 09:13:46 UTC, 4 replies.
- flink 1.11.2 rowtime和proctime流 Interval Join 问题错误问题 - posted by Asahi Lee <97...@qq.com> on 2020/11/25 09:23:27 UTC, 1 replies.
- 回复：flink sql 连接mysql 无数据输出 - posted by 冯草纸 <al...@qq.com> on 2020/11/25 09:44:12 UTC, 0 replies.
- 回复： flink sql 连接mysql 无数据输出 - posted by 冯草纸 <al...@qq.com> on 2020/11/25 10:42:37 UTC, 1 replies.
- flink内存设置求推荐 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/25 11:36:54 UTC, 0 replies.
- 回复：flink 1.11.2 rowtime和proctime流 Interval Join 问题错误问题 - posted by Asahi Lee <97...@qq.com> on 2020/11/25 12:05:04 UTC, 1 replies.
- flink on native k8s 没有 - posted by jiangjiguang719 <ji...@163.com> on 2020/11/25 12:26:57 UTC, 1 replies.
- datastream里的map里面没法用dataset-sql吗 - posted by 马里奥 <tu...@gmail.com> on 2020/11/26 02:36:49 UTC, 0 replies.
- 发现flinksql写hive比写hdfs慢很多 - posted by admin <17...@163.com> on 2020/11/26 03:49:00 UTC, 6 replies.
- 请教设置uid的最佳实践 - posted by kingdomad <ki...@163.com> on 2020/11/26 03:54:28 UTC, 0 replies.
- 回复：请教设置uid的最佳实践 - posted by 范瑞 <83...@qq.com> on 2020/11/26 04:09:35 UTC, 1 replies.
- flink1.11.2 一直不入hbase问题 - posted by simon <si...@163.com> on 2020/11/26 06:05:31 UTC, 1 replies.
- 使用per-job部署成功的flink sql应用但是用applicationMode部署失败，提交到yarn上不到2秒就死掉，并且读取不到日志 - posted by shimin huang <hu...@gmail.com> on 2020/11/26 06:58:33 UTC, 0 replies.
- flinksql读取format为avro的kafka topic 报错 ArrayIndexOutOfBoundsException - posted by 祁洁 <12...@qq.com> on 2020/11/26 08:57:03 UTC, 1 replies.
- udtf collect方法报NEP - posted by bulterman <15...@163.com> on 2020/11/26 10:25:03 UTC, 2 replies.
- Flink WebUI上每个TaskManager显示的cpu和mem是怎么检测到的。 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/26 11:35:07 UTC, 0 replies.
- flink1.11编译失败 - posted by zhy <zh...@akulaku.com> on 2020/11/26 11:43:33 UTC, 3 replies.
- flink sql实时计算分位数如何实现 - posted by 爱成绕指柔 <11...@qq.com> on 2020/11/26 14:55:35 UTC, 1 replies.
- FlinkSQL使用Hive自定义函数报类找不到 - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/11/27 01:36:52 UTC, 0 replies.
- canal-json 分库分表场景应用 - posted by air23 <wa...@163.com> on 2020/11/27 01:48:49 UTC, 5 replies.
- flink sql cdc 如果只处理一次全量数据问题 - posted by "cljbest@163.com" <cl...@163.com> on 2020/11/27 03:09:57 UTC, 1 replies.
- FlinkKafkaProducer好像每次事务提交都会重连producer导致打印了大量log - posted by Wz <32...@qq.com> on 2020/11/27 08:43:43 UTC, 0 replies.
- Re: 执行mvn构建错误 - posted by renjiyun <wo...@msn.cn> on 2020/11/27 08:44:50 UTC, 0 replies.
- 带有状态的算子保存checkpoint失败 - posted by 王默 <ws...@163.com> on 2020/11/27 09:22:00 UTC, 1 replies.
- 回复：带有状态的算子保存checkpoint失败 - posted by 魏积乾 <ha...@foxmail.com> on 2020/11/27 09:34:39 UTC, 5 replies.
- flink实时写入Hbase丢数据问题 - posted by bradyMk <zh...@126.com> on 2020/11/27 09:43:57 UTC, 0 replies.
- FLINK SQL 消费kafka消息乱序问题 - posted by bulterman <15...@163.com> on 2020/11/27 09:44:23 UTC, 2 replies.
- flink sql cdc 写数据到mysql，找不到相关的类 - posted by "cljbest@163.com" <cl...@163.com> on 2020/11/27 11:02:08 UTC, 2 replies.
- 回复：Re:回复：带有状态的算子保存checkpoint失败 - posted by 魏积乾 <ha...@foxmail.com> on 2020/11/27 11:08:24 UTC, 0 replies.
- flink任务运行不久后报netty错误 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/27 13:25:10 UTC, 1 replies.
- Flink cdc connector：数据量较大时，snapshot阶段报错 - posted by jindy_liu <28...@qq.com> on 2020/11/27 13:31:37 UTC, 0 replies.
- flink 1.11.2 - posted by zapjone <za...@163.com> on 2020/11/28 11:42:11 UTC, 0 replies.
- flink编译报错 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/28 13:30:59 UTC, 0 replies.
- 摄像头视频流采集 - posted by "Xia(Nate) Qu" <ts...@gmail.com> on 2020/11/29 00:43:46 UTC, 1 replies.
- Flink的富函数类中重新声明接口方法的目的是什么 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/29 04:16:52 UTC, 0 replies.
- flink sql client 报错java.net.NoRouteToHostException: 没有到主机的路由 - posted by 奚焘 <75...@qq.com> on 2020/11/29 08:56:22 UTC, 0 replies.
- 回复：FLINK SQL 消费kafka消息乱序问题 - posted by smq <37...@qq.com> on 2020/11/30 00:49:57 UTC, 0 replies.
- flink-json 函数用法 - posted by "Yan,Yunpeng(DXM,PB)" <ya...@duxiaoman.com> on 2020/11/30 02:37:02 UTC, 7 replies.
- Flink SQL 是否存在类似MySQL的group_concat函数 - posted by zhengzhongni <zh...@outlook.com> on 2020/11/30 03:41:19 UTC, 2 replies.
- 求助：开窗计算开启allowedLateness后，迟到数据会与当前状态累加，而不是对应的窗口状态累加 - posted by x <35...@qq.com> on 2020/11/30 07:55:57 UTC, 0 replies.
- 关于flink cdc sql转出Stream流问题 - posted by yujianbo <15...@163.com> on 2020/11/30 08:51:11 UTC, 0 replies.
- 使用 StreamingFileSink后 checkpoint状态中的数据如何hive读取 - posted by liliang <90...@qq.com> on 2020/11/30 08:57:29 UTC, 0 replies.
- flink sql cdc做计算后， elastic search connector 多并发sink 会有问题，偶现！数据量较大，目前还没较好复现。请问有人是否也遇到过类似的问题。 - posted by jindy_liu <28...@qq.com> on 2020/11/30 10:33:07 UTC, 0 replies.
- flink sql es写入时，用户名密码认证不支持 - posted by "cljbest@163.com" <cl...@163.com> on 2020/11/30 11:22:47 UTC, 1 replies.
- Flink检查点失败，原因写着是job failed，但我的job明明好好的。 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/30 14:23:54 UTC, 0 replies.
- flink taskmanager netty报错。 - posted by 赵一旦 <hi...@gmail.com> on 2020/11/30 14:24:35 UTC, 0 replies.
- flink cdc 如何保证group agg结果正确性 - posted by "kandy.wang" <ka...@163.com> on 2020/11/30 14:50:04 UTC, 1 replies.