You are viewing a plain text version of this content. The canonical link for it is here.
- Re: flink-1.11.1 Table API /SQL 无法写入hive orc表 - posted by "amenhub@163.com" <am...@163.com> on 2020/09/01 02:00:49 UTC, 1 replies.
- Re: 回复: flink1.11连接mysql问题 - posted by "amenhub@163.com" <am...@163.com> on 2020/09/01 02:12:10 UTC, 0 replies.
- Re: flink checkpoint导致反压严重 - posted by 赵一旦 <hi...@gmail.com> on 2020/09/01 02:14:41 UTC, 1 replies.
- 使用orc写动态分区表时,文件大小滚动策略不起作用 - posted by "wei.wei" <we...@163.com> on 2020/09/01 02:40:44 UTC, 0 replies.
- Re: FLINK1.11.1 对OGG数据入HIVE的问题咨询 - posted by Qishang <zh...@gmail.com> on 2020/09/01 03:06:07 UTC, 0 replies.
- flink json ddl解析 - posted by Dream-底限 <zh...@akulaku.com> on 2020/09/01 03:40:10 UTC, 7 replies.
- 关于FlinkSQL的窗口和触发 - posted by BenChen <ha...@163.com> on 2020/09/01 05:43:48 UTC, 0 replies.
- 回复: flink1.11连接mysql问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/09/01 06:27:28 UTC, 0 replies.
- flink cancel命令 - posted by 462329521 <46...@qq.com> on 2020/09/01 07:41:19 UTC, 1 replies.
- flink1.9.1采用Prometheus Pushgateway监控,当任务被kill掉,但grafana还是可以监控到数据 - posted by bradyMk <zh...@126.com> on 2020/09/01 08:23:34 UTC, 2 replies.
- 回复:flink1.9.1采用Prometheus Pushgateway监控,当任务被kill掉,但grafana还是可以监控到数据 - posted by 972684638 <da...@qq.com> on 2020/09/01 08:27:31 UTC, 21 replies.
- Re:flink-1.11连接hive或filesystem问题 - posted by Danny Chan <yu...@gmail.com> on 2020/09/01 08:36:52 UTC, 0 replies.
- TM SLOT资源共享 - posted by liangji <ji...@gmail.com> on 2020/09/01 08:45:13 UTC, 2 replies.
- 回复:关于FlinkSQL的窗口和触发 - posted by Cayden chen <11...@qq.com> on 2020/09/01 09:10:07 UTC, 1 replies.
- Flink SQL 为什么不支持 utf8mb4 字符集? - posted by LittleFall <15...@qq.com> on 2020/09/01 09:25:50 UTC, 0 replies.
- Flink on k8s - posted by superainbower <su...@163.com> on 2020/09/01 10:50:31 UTC, 2 replies.
- Flink 使用 RocksDB CPU 打满 - posted by fanrui <83...@qq.com> on 2020/09/01 13:00:39 UTC, 3 replies.
- Re: 请教 hive streaming 报错 - posted by Rui Li <li...@gmail.com> on 2020/09/01 13:36:14 UTC, 3 replies.
- 回复: Flink 使用 RocksDB CPU 打满 - posted by 范瑞 <83...@qq.com> on 2020/09/02 05:56:45 UTC, 1 replies.
- Cannot load user class - posted by admin <17...@163.com> on 2020/09/02 06:00:02 UTC, 0 replies.
- 【闫云鹏】Flink sql 写入es实现object嵌套形式 - posted by "Yan,Yunpeng(DXM,PB)" <ya...@duxiaoman.com> on 2020/09/02 06:52:03 UTC, 0 replies.
- Flink 1.10.1 cdh-hdfs启用HA时,flink job提交报错 - posted by storm <st...@163.com> on 2020/09/02 07:02:03 UTC, 5 replies.
- flink-1.11 sql写ES6问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/09/02 07:09:52 UTC, 2 replies.
- 请指教一个关于时间窗的问题,非常感谢! - posted by "samuel.qiu@ubtrobot.com" <sa...@ubtrobot.com> on 2020/09/02 07:20:34 UTC, 3 replies.
- ceshi - posted by Storm☀️ <st...@163.com> on 2020/09/02 07:32:10 UTC, 0 replies.
- Re:【闫云鹏】Flink sql写入es实现object嵌套形式 - posted by Danny Chan <yu...@gmail.com> on 2020/09/02 08:50:39 UTC, 0 replies.
- sql-training环境搭建 - posted by jacky-cui <82...@qq.com> on 2020/09/02 08:55:17 UTC, 0 replies.
- Re: [DKIM Failure] Re: 【闫云鹏】Flink sql 写入es实现object嵌套形式 - posted by "Yan,Yunpeng(DXM,PB)" <ya...@duxiaoman.com> on 2020/09/02 09:01:29 UTC, 0 replies.
- Flink 涉及到 state 恢复能从 RocketMQ 直接转到 Kafka 吗? - posted by "wanglei2@geekplus.com" <wa...@geekplus.com> on 2020/09/02 09:21:37 UTC, 2 replies.
- flink1.10集成PrometheusPushGateway,日志报错Failed to push metrics to PushGateway with jobName - posted by Jim Chen <ch...@gmail.com> on 2020/09/02 09:43:35 UTC, 1 replies.
- 回复:请指教一个关于时间窗的问题,非常感谢! - posted by jacky-cui <82...@qq.com> on 2020/09/02 10:58:03 UTC, 2 replies.
- Flink如何实现至多一次(At Most Once) - posted by Tianwang Li <li...@gmail.com> on 2020/09/02 11:16:21 UTC, 2 replies.
- 回复: flink-1.11 sql写ES6问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/09/02 11:18:00 UTC, 0 replies.
- flink-1.11 使用 application 模式时 jobid 问题 - posted by chenkaibit <ch...@163.com> on 2020/09/02 11:28:38 UTC, 1 replies.
- 从Savepoint/Checkpoint恢复时 keyedstate中部分数据无法被读取 - posted by Liu Rising <st...@gmail.com> on 2020/09/02 12:14:50 UTC, 6 replies.
- kafka metric lag统计 - posted by liangji <ji...@gmail.com> on 2020/09/02 15:56:23 UTC, 0 replies.
- flink-sql-gateway hive ddl 语句parse报错 godfrey he 能帮忙看下吗? - posted by shougou <80...@qq.com> on 2020/09/02 16:06:05 UTC, 0 replies.
- 回复: 回复:请指教一个关于时间窗的问题,非常感谢! - posted by "samuel.qiu@ubtrobot.com" <sa...@ubtrobot.com> on 2020/09/03 01:23:20 UTC, 1 replies.
- Re: flink-sql-gateway hive ddl 语句parse报错 godfrey he 能帮忙看下吗? - posted by Rui Li <li...@gmail.com> on 2020/09/03 02:31:16 UTC, 1 replies.
- 无法savepoint - posted by x <35...@qq.com> on 2020/09/03 03:30:06 UTC, 1 replies.
- 回复: 无法savepoint - posted by x <35...@qq.com> on 2020/09/03 04:22:18 UTC, 1 replies.
- 回复: 请指教一个关于时间窗的问题,非常感谢! - posted by jacky-cui <82...@qq.com> on 2020/09/03 04:35:10 UTC, 1 replies.
- FlinkKafkaConsumer问题 - posted by op <52...@qq.com> on 2020/09/03 07:03:33 UTC, 5 replies.
- 无法从checkpoint中恢复state - posted by sun <13...@qq.com> on 2020/09/03 07:56:58 UTC, 5 replies.
- pyflink1.11.1连接hive问题 - posted by 程龙 <13...@163.com> on 2020/09/03 08:12:04 UTC, 3 replies.
- 回复:无法从checkpoint中恢复state - posted by sun <13...@qq.com> on 2020/09/03 08:13:30 UTC, 0 replies.
- Flink SQL 任务乱码问题 - posted by LakeShen <sh...@gmail.com> on 2020/09/03 09:03:56 UTC, 0 replies.
- Flink动态CEP该怎么做? - posted by Jim Chen <ch...@gmail.com> on 2020/09/03 10:34:05 UTC, 0 replies.
- flink sql多层view嵌套,字段not found - posted by Lin Hou <li...@gmail.com> on 2020/09/03 10:40:51 UTC, 1 replies.
- pyflink-udf 问题反馈 - posted by whh_960101 <wh...@163.com> on 2020/09/03 13:03:05 UTC, 15 replies.
- 回复:pyflink-udf 问题反馈 - posted by wh...@163.com on 2020/09/03 13:44:42 UTC, 0 replies.
- 回复: FlinkKafkaConsumer问题 - posted by op <52...@qq.com> on 2020/09/04 02:25:03 UTC, 1 replies.
- flink读取kafka遇到kafka.consumer:type=app-info,id=1 - posted by 宁吉浩 <a9...@dingtalk.com.INVALID> on 2020/09/04 02:40:31 UTC, 1 replies.
- Re: Flink SQL任务乱码问题 - posted by Danny Chan <yu...@gmail.com> on 2020/09/04 02:56:54 UTC, 0 replies.
- Re: flinksql多层view嵌套,字段not found - posted by Danny Chan <yu...@gmail.com> on 2020/09/04 02:59:11 UTC, 0 replies.
- flink on k8s 如果jobmanager 所在pod重启后job失败如何处理 - posted by "dtygfn@163.com" <dt...@163.com> on 2020/09/04 03:02:54 UTC, 1 replies.
- FlinkSQL如何处理上游的表结构变更 - posted by xiao cai <fl...@163.com> on 2020/09/04 06:18:34 UTC, 1 replies.
- 关于flink sql并行度问题的请教 - posted by me <me...@lishiyu.cn> on 2020/09/04 07:18:17 UTC, 0 replies.
- 回复:关于flink sql并行度问题的请教 - posted by me <me...@lishiyu.cn> on 2020/09/04 07:29:48 UTC, 1 replies.
- 消费kafka数据乱序问题 - posted by smq <37...@qq.com> on 2020/09/04 08:40:02 UTC, 3 replies.
- flink sql client 如何同时执行多条 sql 语句 - posted by LittleFall <15...@qq.com> on 2020/09/04 09:04:38 UTC, 3 replies.
- 回复:消费kafka数据乱序问题 - posted by smq <37...@qq.com> on 2020/09/04 09:35:32 UTC, 2 replies.
- 回复:请教:用flink实现实时告警的功能 - posted by 李军 <ho...@163.com> on 2020/09/04 09:46:26 UTC, 0 replies.
- flink sql 1.11.1 FileSystem SQL Connector path directory slow - posted by Peihui He <pe...@gmail.com> on 2020/09/04 10:02:54 UTC, 7 replies.
- sql-client checkpoint sql-client - posted by 引领 <yr...@163.com> on 2020/09/04 10:13:02 UTC, 2 replies.
- 1.11版本,创建视图后,根据表名称获取视图表对象,表名为临时名称的问题 - posted by Asahi Lee <97...@qq.com> on 2020/09/04 11:20:19 UTC, 1 replies.
- flink 使用 StreamingFileSink 向catalog中增加分区失败 - posted by MuChen <93...@qq.com> on 2020/09/04 11:23:47 UTC, 0 replies.
- 回复:flink sql client 如何同时执行多条 sql 语句 - posted by faaron zheng <fa...@gmail.com> on 2020/09/05 01:37:19 UTC, 0 replies.
- 回复: 消费kafka数据乱序问题 - posted by 忝忝向仧 <15...@qq.com> on 2020/09/05 03:32:17 UTC, 0 replies.
- 回复:FlinkSQL如何处理上游的表结构变更 - posted by 忝忝向仧 <15...@qq.com> on 2020/09/05 08:50:13 UTC, 0 replies.
- 回复:FlinkKafkaConsumer问题 - posted by SmileSmile <a5...@163.com> on 2020/09/05 08:51:30 UTC, 0 replies.
- Flink 1.9.1的报错信息,在启动flink on yran的时候出现问题 - posted by xzw0223 <74...@qq.com> on 2020/09/06 06:58:03 UTC, 2 replies.
- flink-sql1.11写入mysql重复问题 - posted by 凌天荣 <46...@qq.com> on 2020/09/06 13:21:28 UTC, 1 replies.
- Re: 请教:用flink实现实时告警的功能 - posted by 刘建刚 <li...@gmail.com> on 2020/09/07 00:59:19 UTC, 0 replies.
- 使用StreamingFileSink向hive metadata中增加分区部分失败 - posted by MuChen <93...@qq.com> on 2020/09/07 02:23:23 UTC, 1 replies.
- 回复: 使用StreamingFileSink向hive metadata中增加分区部分失败 - posted by MuChen <93...@qq.com> on 2020/09/07 03:01:29 UTC, 1 replies.
- flink任务运行一段时间checkpoint超时,任务挂掉 - posted by jordan95225 <jo...@163.com> on 2020/09/07 03:03:27 UTC, 1 replies.
- flink-spillable-statebackend不能正常使用 - posted by jiafu <53...@qq.com> on 2020/09/07 03:19:19 UTC, 0 replies.
- Re: FlinkSQL 任务提交后 任务名称问题 - posted by LittleFall <15...@qq.com> on 2020/09/07 03:40:10 UTC, 0 replies.
- 邮件列表地址错误 - posted by darion <fl...@163.com> on 2020/09/07 05:00:34 UTC, 2 replies.
- flink 1.11 streaming file sink to hdfs orc file format could be recognized by hive - posted by 大罗 <ti...@163.com> on 2020/09/07 06:10:50 UTC, 1 replies.
- flink1.9.3 on yarn 提交任务问题 - posted by 宁吉浩 <a9...@dingtalk.com.INVALID> on 2020/09/07 07:23:12 UTC, 1 replies.
- 使用k8s 实现flink 的高可用 - posted by 旧城以西 <dt...@163.com> on 2020/09/07 09:17:07 UTC, 1 replies.
- flink-CDC 中文乱码问题 - posted by "Li,Qian(DXM,PB)" <li...@duxiaoman.com> on 2020/09/07 09:31:53 UTC, 0 replies.
- RocksDBStateBackend 问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/09/07 09:47:33 UTC, 2 replies.
- flink-1.11 native k8s state 在 ceph 存储问题 - posted by chenkaibit <ch...@163.com> on 2020/09/07 11:41:57 UTC, 1 replies.
- 回复: 1.11版本,创建视图后,根据表名称获取视图表对象,表名为临时名称的问题 - posted by Asahi Lee <97...@qq.com> on 2020/09/07 14:26:50 UTC, 0 replies.
- how flink-sql connector kafka reads array json - posted by 大罗 <ti...@163.com> on 2020/09/08 02:38:45 UTC, 1 replies.
- 回复:使用StreamingFileSink向hive metadata中增加分区部分失败 - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/09/08 02:47:07 UTC, 5 replies.
- 回复: 回复:使用StreamingFileSink向hive metadata中增加分区部分失败 - posted by MuChen <93...@qq.com> on 2020/09/08 02:56:30 UTC, 0 replies.
- 回复:回复:使用StreamingFileSink向hive metadata中增加分区部分失败 - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/09/08 03:02:05 UTC, 0 replies.
- flink 1.11.1 版本执行HiveCatalog遇到问题质询 - posted by zhongbaoluo <zh...@shxgroup.net> on 2020/09/08 06:09:12 UTC, 3 replies.
- flink-sql 1.11版本都还没完全支持checkpoint吗 - posted by 凌天荣 <46...@qq.com> on 2020/09/08 07:50:00 UTC, 2 replies.
- 回复: flink-sql 1.11版本都还没完全支持checkpoint吗 - posted by 凌天荣 <46...@qq.com> on 2020/09/08 08:04:47 UTC, 0 replies.
- 回复: flink-sql 1.11版本都还没完全支持checkpoint吗 - posted by silence <sl...@aliyun.com.INVALID> on 2020/09/08 08:15:26 UTC, 0 replies.
- flink sql 1.11.1 could not insert hive orc record - posted by 大罗 <ti...@163.com> on 2020/09/08 08:26:43 UTC, 3 replies.
- 回复:flink sql 1.11.1 could not insert hive orc record - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/09/08 08:58:09 UTC, 2 replies.
- 回复:回复:flink sql 1.11.1 could not insert hive orc record - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/09/08 09:07:14 UTC, 0 replies.
- 回复: 回复:使用StreamingFileSink向hive metadata中增加分区部分失败 - posted by MuChen <93...@qq.com> on 2020/09/08 09:15:07 UTC, 2 replies.
- flink实时统计GMV,如果订单金额下午变了该怎么处理 - posted by xuzh <xu...@chyjr.com> on 2020/09/08 09:56:11 UTC, 7 replies.
- flink sql中Table类型注册临时表,无法使用的问题? - posted by me <me...@lishiyu.cn> on 2020/09/08 09:59:41 UTC, 2 replies.
- 回复:flink实时统计GMV,如果订单金额下午变了该怎么处理 - posted by "1115098508@qq.com" <so...@foxmail.com> on 2020/09/08 10:18:07 UTC, 4 replies.
- 回复:flink sql中Table类型注册临时表,无法使用的问题? - posted by 引领 <yr...@163.com> on 2020/09/08 11:12:43 UTC, 0 replies.
- 请教个checkpoint目录删除问题 - posted by superainbower <su...@163.com> on 2020/09/08 11:47:09 UTC, 0 replies.
- 回复:请教个checkpoint目录删除问题 - posted by 范瑞 <83...@qq.com> on 2020/09/08 11:56:20 UTC, 2 replies.
- Flink Plan Visualizer - posted by zilong xiao <ac...@gmail.com> on 2020/09/08 11:59:36 UTC, 3 replies.
- MetricQueryService中metric更新 - posted by liangji <ji...@gmail.com> on 2020/09/08 12:17:05 UTC, 0 replies.
- blob server相关,文件找不到 - posted by leiyanrui <11...@qq.com> on 2020/09/08 13:19:37 UTC, 0 replies.
- Re: Re: Re: Re: Re:Re: flink 1.11 StreamingFileWriter及sql-client问题 - posted by Jingsong Li <ji...@gmail.com> on 2020/09/09 03:19:26 UTC, 0 replies.
- pyflink execute_insert问题求解答 - posted by whh_960101 <wh...@163.com> on 2020/09/09 03:31:58 UTC, 4 replies.
- 手动修改CK状态 - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/09/09 03:41:11 UTC, 0 replies.
- Row和RowData的区别 - posted by 刘首维 <li...@autohome.com.cn> on 2020/09/09 05:51:13 UTC, 1 replies.
- 回复:手动修改CK状态 - posted by xuhaiLong <xi...@163.com> on 2020/09/09 06:00:32 UTC, 1 replies.
- localtimestamp和current_timestamp插入mysql时区错乱 - posted by xuzh <hu...@foxmail.com> on 2020/09/09 07:06:52 UTC, 2 replies.
- flink sql 1.11.1 insert data to hive from kafka split into two jobs - posted by 大罗 <ti...@163.com> on 2020/09/09 07:13:24 UTC, 2 replies.
- flink sql 1.11.1 如何只插入一个列簇的数据到hbase - posted by 大罗 <ti...@163.com> on 2020/09/09 08:22:12 UTC, 1 replies.
- flink-sql消费基于on kafka的flink table,每次select这个flink table相当于是不同group id了吗? - posted by 凌天荣 <46...@qq.com> on 2020/09/09 08:24:24 UTC, 2 replies.
- flink table Kafka 重新连接的问题 - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/09/09 08:37:55 UTC, 3 replies.
- flink-cdc sink mysql 问题 - posted by 杨帅统 <it...@163.com> on 2020/09/09 08:48:55 UTC, 4 replies.
- 回复: flink-cdc sink mysql 问题 - posted by wdmcode <wd...@aliyun.com.INVALID> on 2020/09/09 08:56:44 UTC, 0 replies.
- Re: 问题跟踪 - posted by Dian Fu <di...@gmail.com> on 2020/09/09 09:44:45 UTC, 0 replies.
- 回复:flink1.9.3 on yarn 提交任务问题 - posted by 宁吉浩 <a9...@dingtalk.com.INVALID> on 2020/09/09 09:45:35 UTC, 1 replies.
- Yarn-Session长时间运行Kerberos问题 - posted by hua mulan <de...@outlook.com> on 2020/09/09 12:07:24 UTC, 0 replies.
- sql-client提交报错UpsertStreamTableSink requires that Table has a full primary keys if it is updated - posted by "kandy.wang" <ka...@163.com> on 2020/09/09 12:27:18 UTC, 1 replies.
- 回复: flink实时统计GMV,如果订单金额下午变了该怎么处理 - posted by 忝忝向仧 <15...@qq.com> on 2020/09/09 14:53:46 UTC, 1 replies.
- Flink 1.11 jdbc查pg失败 - posted by Jimmy Zhang <zh...@163.com> on 2020/09/09 15:24:38 UTC, 2 replies.
- flink集成spring - posted by "1115098508@qq.com" <so...@foxmail.com> on 2020/09/10 01:09:06 UTC, 4 replies.
- 退订 - posted by harveyer <ha...@163.com> on 2020/09/10 01:21:34 UTC, 23 replies.
- 答复: 从Savepoint/Checkpoint恢复时 keyedstate中部分数据无法被读取 - posted by 范超 <fa...@mgtv.com> on 2020/09/10 01:35:02 UTC, 0 replies.
- 回复: Flink 1.11 jdbc查pg失败 - posted by wdmcode <wd...@aliyun.com.INVALID> on 2020/09/10 01:44:40 UTC, 0 replies.
- 回复:flink集成spring - posted by 罗显宴 <15...@163.com> on 2020/09/10 02:00:22 UTC, 0 replies.
- 回复: flink-sql消费基于on kafka的flink table,每次select这个flink table相当于是不同group id了吗? - posted by 凌天荣 <46...@qq.com> on 2020/09/10 02:08:05 UTC, 0 replies.
- flink 1.11 taskmanager实际占用内存超出配置太多 - posted by Z-Z <zz...@qq.com> on 2020/09/10 02:08:13 UTC, 1 replies.
- Flink 1.5.0 savepoint 失败 - posted by likai <11...@qq.com> on 2020/09/10 02:39:43 UTC, 2 replies.
- 回复:flink 1.11 taskmanager实际占用内存超出配置太多 - posted by Z-Z <zz...@qq.com> on 2020/09/10 04:54:07 UTC, 0 replies.
- Flink 1.11.1 job申请到PhysicalSlot的ResourceProfile问题 - posted by 黄潇 <hx...@gmail.com> on 2020/09/10 06:46:44 UTC, 0 replies.
- 关于Fink Native K8S Session模式的两个问题 - posted by Mori_Tang <49...@qq.com> on 2020/09/10 08:09:44 UTC, 1 replies.
- 回复: localtimestamp和current_timestamp插入mysql时区错乱 - posted by xuzh <hu...@qq.com> on 2020/09/10 09:36:24 UTC, 0 replies.
- Flink1.10.0 的checkpoint越来越大 - posted by Tianwang Li <li...@gmail.com> on 2020/09/10 13:18:41 UTC, 2 replies.
- Re:Re: localtimestamp和current_timestamp插入mysql时区错乱 - posted by 443435766 <44...@qq.com> on 2020/09/10 14:01:41 UTC, 1 replies.
- flink 1.11.1写s3问题 - posted by zya <z_...@foxmail.com> on 2020/09/10 14:29:01 UTC, 0 replies.
- flink写s3问题 - posted by 无言 <z_...@foxmail.com> on 2020/09/11 03:17:42 UTC, 0 replies.
- flink 填补窗口问题 - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/09/11 03:42:40 UTC, 2 replies.
- Flink sql权限 - posted by 163 <xi...@163.com> on 2020/09/11 06:33:41 UTC, 2 replies.
- flink 动态分区策略 - posted by venn <wx...@163.com> on 2020/09/11 08:29:27 UTC, 0 replies.
- 回复:localtimestamp和current_timestamp插入mysql时区错乱 - posted by xuzh <hu...@foxmail.com> on 2020/09/11 08:41:55 UTC, 0 replies.
- Re: Flink 1.10 on Yarn - posted by xuhaiLong <xi...@163.com> on 2020/09/11 09:52:54 UTC, 0 replies.
- 关于flink cdc 测试时遇到的几种问题,比较疑惑,各位大佬求帮助 - posted by 引领 <yr...@163.com> on 2020/09/11 09:55:50 UTC, 2 replies.
- flink sql执行sql语句无法执行的错误-No operators defined in streaming topology. Cannot execute. - posted by me <me...@lishiyu.cn> on 2020/09/11 09:58:20 UTC, 3 replies.
- 回复:flink sql执行sql语句无法执行的错误-No operators defined in streaming topology. Cannot execute. - posted by 引领 <yr...@163.com> on 2020/09/11 10:02:52 UTC, 0 replies.
- 有木有比较好flink sql 任务提交插件推荐 - posted by xuzh <hu...@qq.com> on 2020/09/11 10:04:54 UTC, 2 replies.
- 请教一下Flink和主流数据湖集成的情况 - posted by dixingxing85 <di...@163.com> on 2020/09/12 08:53:30 UTC, 4 replies.
- 时间窗口和reduce算子问题 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/09/12 09:57:01 UTC, 1 replies.
- UDAF函数在over窗口使用问题 - posted by chen310 <22...@163.com> on 2020/09/13 02:37:34 UTC, 2 replies.
- 通过sql client操作flink mysql-cdc异常 - posted by 陈帅 <ca...@gmail.com> on 2020/09/13 03:10:10 UTC, 1 replies.
- 来自杨红建的邮件 - posted by 杨红建 <yh...@163.com> on 2020/09/13 11:25:35 UTC, 0 replies.
- pyflink 断点设置 - posted by whh_960101 <wh...@163.com> on 2020/09/14 01:16:37 UTC, 0 replies.
- 关于使用flinksql 生成滑动窗口 table数据进不来的问题 - posted by 李杨烨 <43...@qq.com> on 2020/09/14 03:24:42 UTC, 1 replies.
- Flink 1.11.1 JDBC Sink 使用旧版配置 数据丢失 - posted by LittleFall <15...@qq.com> on 2020/09/14 03:37:07 UTC, 6 replies.
- 多线程模式下使用Blink TableEnvironment - posted by jun su <su...@gmail.com> on 2020/09/14 03:37:50 UTC, 4 replies.
- 关于flinksql 滑动窗口数据进不来的问题 - posted by 李杨烨 <43...@qq.com> on 2020/09/14 05:32:19 UTC, 2 replies.
- flink hive批量作业报FileNotFoundException - posted by 李佳宸 <li...@gmail.com> on 2020/09/14 09:11:17 UTC, 2 replies.
- 回复: 关于flinksql 滑动窗口数据进不来的问题 - posted by 李杨烨 <43...@qq.com> on 2020/09/14 09:26:59 UTC, 0 replies.
- [sql-client][checkpoint] sql-client提交任务,checkpoint没有写入hdfs - posted by "Harold.Miao" <mi...@gmail.com> on 2020/09/14 10:44:08 UTC, 6 replies.
- flink RichFilterFunction重复过滤一条数据 - posted by 13...@163.com, 13...@163.com on 2020/09/15 02:21:42 UTC, 1 replies.
- Re: flink 1.9 关于回撤流的问题 - posted by Shengkai Fang <fs...@gmail.com> on 2020/09/15 08:01:57 UTC, 1 replies.
- StreamingFileSink文件滚动策略 - posted by zya <z_...@foxmail.com> on 2020/09/15 08:54:10 UTC, 0 replies.
- flink-sql cdc 支持哪些sink?是否支持sink到开启了update的hive - posted by MuChen <93...@qq.com> on 2020/09/15 09:00:45 UTC, 1 replies.
- 如何在启动taskmanager时传入自定义的java参数 - posted by xiao cai <fl...@163.com> on 2020/09/15 09:46:21 UTC, 4 replies.
- Flink 1.11 operator metric name 长度限制问题 - posted by Jian Wang <wa...@seagroup.com> on 2020/09/15 11:48:53 UTC, 0 replies.
- FlinkSQL1.11.1读取kafka写入Hive(parquet) OOM问题 - posted by wangenbao <15...@qq.com> on 2020/09/15 12:20:10 UTC, 4 replies.
- HiveTableSink中关于streaming方式文件回滚策略HiveRollingPolicy疑问 - posted by "kandy.wang" <ka...@163.com> on 2020/09/15 12:32:52 UTC, 0 replies.
- 关于自定义数据类型实现空间数据类型的处理的问题 - posted by 陈韬 <to...@qq.com> on 2020/09/16 01:58:35 UTC, 0 replies.
- 含有多个kafka-source的job里如果用events_time作为时间的话,如何解决快流通过水印覆盖漫流的情况。 - posted by hao kong <ha...@lemonbox.me> on 2020/09/16 02:24:27 UTC, 11 replies.
- flink检查点 - posted by Dream-底限 <zh...@akulaku.com> on 2020/09/16 02:26:52 UTC, 1 replies.
- Flink SQL format问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/09/16 02:29:32 UTC, 0 replies.
- 回复:Flink SQL format问题 - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/09/16 02:33:36 UTC, 1 replies.
- 关于JDBC Source中connector.read.query属性在1.11新接口版本的JDBC Souce实现中没有提供 - posted by 陈韬 <to...@qq.com> on 2020/09/16 03:25:07 UTC, 2 replies.
- 回复:回复:Flink SQL format问题 - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/09/16 04:53:30 UTC, 0 replies.
- 统计数据含有中间回撤数据的问题 - posted by 1337220620 <13...@qq.com> on 2020/09/16 05:14:01 UTC, 9 replies.
- StreamingFileWriter 压测性能 - posted by "kandy.wang" <ka...@163.com> on 2020/09/16 06:03:35 UTC, 13 replies.
- Flink SQL create view问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/09/16 06:32:22 UTC, 1 replies.
- 两个over窗口对应的view join问题 - posted by chen310 <22...@163.com> on 2020/09/16 06:58:33 UTC, 0 replies.
- Streaming File Sink 不能生成 _SUCCESS 标记文件 - posted by highfei2011 <hi...@outlook.com> on 2020/09/16 07:01:35 UTC, 1 replies.
- Re: Re:Flink SQL format问题 - posted by Jark Wu <im...@gmail.com> on 2020/09/16 07:28:44 UTC, 0 replies.
- K8s native 部署失败 - posted by yanzhibo <bu...@163.com> on 2020/09/16 09:25:14 UTC, 5 replies.
- 请教大家如何注册支持多返回值类型的UDAF - posted by silence <sl...@aliyun.com.INVALID> on 2020/09/16 12:45:55 UTC, 1 replies.
- checkpoint问题 - posted by smq <37...@qq.com> on 2020/09/16 23:02:28 UTC, 1 replies.
- flink table api中无法设置子json中的列为rowtime - posted by kylin <ky...@163.com> on 2020/09/17 02:00:56 UTC, 1 replies.
- 关于官方的k8s operator - posted by "Harold.Miao" <mi...@gmail.com> on 2020/09/17 02:14:22 UTC, 2 replies.
- Flink 1.11 datastream写hive parquet表异常 - posted by zilong xiao <ac...@gmail.com> on 2020/09/17 02:27:11 UTC, 0 replies.
- Flink SQL TableSource复用问题,相同数据源聚合多个指标,引擎创建多个相同的数据源 - posted by Kevin Dai <15...@qq.com> on 2020/09/17 03:10:36 UTC, 2 replies.
- 回复: checkpoint问题 - posted by 明启 孙 <37...@qq.com> on 2020/09/17 05:11:28 UTC, 0 replies.
- 请问flink jdbc connector 支持greenplum吗 - posted by xuzh <hu...@qq.com> on 2020/09/17 05:13:28 UTC, 1 replies.
- [ANNOUNCE] Apache Flink 1.11.2 released - posted by Zhu Zhu <zh...@apache.org> on 2020/09/17 05:29:10 UTC, 7 replies.
- pyflink连接器支持问题 - posted by whh_960101 <wh...@163.com> on 2020/09/17 06:46:00 UTC, 1 replies.
- python udf 提交到本地节点执行报错 - posted by myfjdthink <jf...@kalengo.com> on 2020/09/17 06:50:07 UTC, 4 replies.
- Per-job mode 任务失败 jm没有退出 - posted by Qishang <zh...@gmail.com> on 2020/09/17 07:59:41 UTC, 0 replies.
- 关于checkpointFunction接口 - posted by smq <37...@qq.com> on 2020/09/17 09:05:01 UTC, 0 replies.
- 使用flinksql时 jdbc connector参数不起作用 - posted by chenxuying <cx...@163.com> on 2020/09/17 10:15:09 UTC, 2 replies.
- ListState 设置 TTL 会在 list 中删除之前的记录吗 - posted by "wanglei2@geekplus.com" <wa...@geekplus.com> on 2020/09/18 02:49:51 UTC, 0 replies.
- 关于stream注册成表的数据存储时长问题 - posted by 李杨烨 <43...@qq.com> on 2020/09/18 03:20:32 UTC, 0 replies.
- Flink sql 消费kafka的顺序是怎么样的 第二次运行sql的结果和第一次不同 - posted by anonnius <an...@126.com> on 2020/09/18 03:24:37 UTC, 0 replies.
- flink connect kafka - posted by "wchxii@163.com" <wc...@163.com> on 2020/09/18 05:45:13 UTC, 0 replies.
- 回复: Flink sql 消费kafka的顺序是怎么样的 第二次运行sql的结果和第一次不同 - posted by "chengyanan1008@foxmail.com" <ch...@foxmail.com> on 2020/09/18 06:42:42 UTC, 3 replies.
- Flink 任务提交问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/09/18 07:21:51 UTC, 0 replies.
- Flink-1.11.1 读写 Hive 问题 - posted by nashcen <24...@qq.com> on 2020/09/18 07:32:42 UTC, 1 replies.
- FlinkKafkaConsumer on Yarn 模式下 设置并行度无法提高kafka的消费速度,但是提交两个应用却可以 - posted by 范超 <fa...@mgtv.com> on 2020/09/18 08:07:25 UTC, 6 replies.
- 回复:FlinkKafkaConsumer on Yarn 模式下 设置并行度无法提高kafka的消费速度,但是提交两个应用却可以 - posted by 吴磊 <wu...@foxmail.com> on 2020/09/18 08:29:05 UTC, 0 replies.
- 回复:ListState 设置 TTL 会在 list 中删除之前的记录吗 - posted by 吴磊 <wu...@foxmail.com> on 2020/09/18 08:40:31 UTC, 0 replies.
- 答复: flink RichFilterFunction重复过滤一条数据 - posted by 范超 <fa...@mgtv.com> on 2020/09/18 11:20:32 UTC, 0 replies.
- flink任务中使用hive的udf时的一个疑问 - posted by Husky Zeng <56...@qq.com> on 2020/09/19 07:37:39 UTC, 0 replies.
- 任务提交中使用了hive的udf时的疑问 - posted by Husky Zeng <56...@qq.com> on 2020/09/19 07:46:56 UTC, 2 replies.
- [SQL] parse table name from sql statement - posted by "Harold.Miao" <mi...@gmail.com> on 2020/09/21 02:12:13 UTC, 9 replies.
- Re: Table api son schema - posted by chuyuan <wl...@163.com> on 2020/09/21 02:31:47 UTC, 0 replies.
- flink-CDC client 一对多问题 - posted by "Li,Qian(DXM,PB)" <li...@duxiaoman.com> on 2020/09/21 04:20:39 UTC, 2 replies.
- 消费kafka source反压 - posted by smq <37...@qq.com> on 2020/09/21 06:08:33 UTC, 2 replies.
- 线上环境出现:org.apache.kafka.common.serialization.StringSerializer is not an instance of org.apache.kafka.common.serialization.Serializer,本地没有 - posted by Jeff <zi...@126.com> on 2020/09/21 06:24:12 UTC, 0 replies.
- Re: 答复: 关于FLinkSQL如何创建类json无限扩展的表结构问题 - posted by chuyuan <wl...@163.com> on 2020/09/21 06:30:43 UTC, 7 replies.
- Flink消费kafka中json数据,其中有个value是Json类型,写入Hive表Map结构异常 - posted by chuyuan <wl...@163.com> on 2020/09/21 06:55:44 UTC, 0 replies.
- Re: [DKIM Failure] Re: flink-CDC client 一对多问题 - posted by "Li,Qian(DXM,PB)" <li...@duxiaoman.com> on 2020/09/21 06:59:19 UTC, 0 replies.
- Re: [DKIM Failure] Re: flink-CDC client 一对多问题 - posted by Jark Wu <im...@gmail.com> on 2020/09/21 07:04:38 UTC, 0 replies.
- 资源均衡问题 - posted by 赵一旦 <hi...@gmail.com> on 2020/09/21 09:44:38 UTC, 4 replies.
- Flink-1.11 Table API &符号 语法问题 - posted by nashcen <24...@qq.com> on 2020/09/21 10:23:07 UTC, 5 replies.
- 回复:消费kafka source反压 - posted by smq <37...@qq.com> on 2020/09/21 10:46:44 UTC, 0 replies.
- flink读写kafka - posted by 宁吉浩 <a9...@dingtalk.com.INVALID> on 2020/09/22 01:33:40 UTC, 0 replies.
- Calcite在嵌套多层包含where条件的sql语句时优化器OOM - posted by jun su <su...@gmail.com> on 2020/09/22 07:26:54 UTC, 9 replies.
- Flink-1.11.1 Kafka Table API BigInt 问题 - posted by nashcen <24...@qq.com> on 2020/09/22 08:29:41 UTC, 0 replies.
- 答复: Flink-1.11.1 Kafka Table API BigInt 问题 - posted by 刘首维 <li...@autohome.com.cn> on 2020/09/22 10:24:11 UTC, 0 replies.
- flink on yarn容器异常退出 - posted by Dream-底限 <zh...@akulaku.com> on 2020/09/22 11:19:12 UTC, 0 replies.
- Re: [DKIM Failure] Re: [DKIM Failure] Re: flink-CDC client 一对多问题 - posted by "Li,Qian(DXM,PB)" <li...@duxiaoman.com> on 2020/09/22 11:27:43 UTC, 0 replies.
- Re: [DKIM Failure] Re: [DKIM Failure] Re: flink-CDC client 一对多问题 - posted by Jark Wu <im...@gmail.com> on 2020/09/22 11:51:29 UTC, 0 replies.
- [flink-1.10.2] Blink SQL 超用内存严重 - posted by Tianwang Li <li...@gmail.com> on 2020/09/22 12:25:53 UTC, 6 replies.
- keyedstate TTL 清理状态如何触发 - posted by smq <37...@qq.com> on 2020/09/22 12:47:08 UTC, 0 replies.
- flink从mongdb中读取数据 - posted by GeGe <gg...@163.com> on 2020/09/23 02:12:37 UTC, 0 replies.
- 回复:[flink-1.10.2] Blink SQL 超用内存严重 - posted by 郑斌斌 <zh...@heint.cn> on 2020/09/23 04:28:52 UTC, 2 replies.
- 编译Flink时找不到scala-maven-plugin:3.1.4 - posted by Natasha <13...@163.com> on 2020/09/23 08:00:05 UTC, 2 replies.
- flink sql延迟数据 - posted by ang <80...@qq.com> on 2020/09/23 08:17:29 UTC, 2 replies.
- flink pb转json性能问题 - posted by "kandy.wang" <ka...@163.com> on 2020/09/23 08:55:29 UTC, 1 replies.
- flink sql grouping sets语义中NOT NULL不生效 - posted by "kandy.wang" <ka...@163.com> on 2020/09/23 09:34:19 UTC, 0 replies.
- Flink Kerberos认证问题 - posted by zhangjunj <zh...@163.com> on 2020/09/23 09:44:30 UTC, 0 replies.
- 查询hbase sink结果表,有时查到数据,有时查不到 - posted by "kandy.wang" <ka...@163.com> on 2020/09/23 09:55:44 UTC, 4 replies.
- kafka增加字段,hive表如何处理 - posted by china_tao <ta...@163.com> on 2020/09/23 10:50:09 UTC, 1 replies.
- flinksql接收到字段值格式为2020-09-23T20:58:24+08:00,如何转成TIMESTAMP - posted by chenxuying <cx...@163.com> on 2020/09/23 13:07:54 UTC, 4 replies.
- 回复: flink sql延迟数据 - posted by ang <80...@qq.com> on 2020/09/24 02:30:20 UTC, 0 replies.
- 答复: FlinkKafkaConsumer on Yarn 模式下 设置并行度无法提高kafka的消费速度,但是提交两个应用却可以 - posted by 范超 <fa...@mgtv.com> on 2020/09/24 02:47:48 UTC, 2 replies.
- 答复: 回复:FlinkKafkaConsumer on Yarn 模式下 设置并行度无法提高kafka的消费速度,但是提交两个应用却可以 - posted by 范超 <fa...@mgtv.com> on 2020/09/24 02:48:58 UTC, 1 replies.
- Flink-1.11 sql-client yaml 配置问题 - posted by nashcen <24...@qq.com> on 2020/09/24 03:00:42 UTC, 1 replies.
- flink on yarn NM JVM内存 - posted by superainbower <su...@163.com> on 2020/09/24 03:52:20 UTC, 1 replies.
- [DISCUSS] Move Hive document to "Table & SQL Connectors" from "Table API & SQL" - posted by Jingsong Li <ji...@gmail.com> on 2020/09/24 04:15:48 UTC, 3 replies.
- 回复: flinksql接收到字段值格式为2020-09-23T20:58:24+08:00,如何转成TIMESTAMP - posted by Joker <ga...@163.com> on 2020/09/24 05:54:13 UTC, 1 replies.
- zeppelin指定的依赖去哪找 - posted by 赵一旦 <hi...@gmail.com> on 2020/09/24 07:08:57 UTC, 6 replies.
- A group window expects a time attribute for grouping in a stream environment. - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/09/24 07:33:01 UTC, 0 replies.
- [flink-1.11] 读 kafka 写 hive,partition-time 抽取值不准确 - posted by nashcen <24...@qq.com> on 2020/09/24 08:16:21 UTC, 2 replies.
- Processing time attribute 'pt' is not of type SQL_TIMESTAMP. - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/09/24 08:22:17 UTC, 1 replies.
- flink sql 1.11.2 jdbc connector 按月分表读取 - posted by Peihui He <pe...@gmail.com> on 2020/09/24 09:26:02 UTC, 3 replies.
- pyflink如何提交作业到集群运行 - posted by whh_960101 <wh...@163.com> on 2020/09/24 10:51:23 UTC, 0 replies.
- pyflink如何提交作业到CDP集群中运行 - posted by whh_960101 <wh...@163.com> on 2020/09/24 10:52:54 UTC, 1 replies.
- [flink-1.11] 读kafka写hive,IDEA运行成功,打成jar包,提交到yarn运行报错 - posted by nashcen <24...@qq.com> on 2020/09/24 11:17:06 UTC, 1 replies.
- 回复:flinksql接收到字段值格式为2020-09-23T20:58:24+08:00,如何转成TIMESTAMP - posted by Jun Zhang <82...@qq.com> on 2020/09/24 11:34:58 UTC, 2 replies.
- flink sql ddl 是否支持映射多层json - posted by Roc Marshal <fl...@126.com> on 2020/09/24 11:53:14 UTC, 1 replies.
- flink canal-json 如何获取每条数据是updata insert delete - posted by air23 <wa...@163.com> on 2020/09/25 01:39:00 UTC, 0 replies.
- Re: flink canal-json 如何获取每条数据是updata insert delete - posted by Jark Wu <im...@gmail.com> on 2020/09/25 02:39:12 UTC, 2 replies.
- 关于flink sql的数据类型 - posted by 赵一旦 <hi...@gmail.com> on 2020/09/25 02:57:43 UTC, 4 replies.
- 请教二阶段提交问题 - posted by 高亮 <li...@qq.com> on 2020/09/25 03:14:32 UTC, 2 replies.
- 回复: 编译Flink时找不到scala-maven-plugin:3.1.4 - posted by Natasha <13...@163.com> on 2020/09/25 04:27:39 UTC, 0 replies.
- 执行mvn构建错误 - posted by 迟成 <cc...@qq.com> on 2020/09/25 05:44:51 UTC, 2 replies.
- flinksql/table中针对迟到数据的处理 - posted by "gygzljy@163.com" <gy...@163.com> on 2020/09/25 05:47:12 UTC, 0 replies.
- flink读取mongo数据本地部署成功,flink-cluster部署找不到类 - posted by GeGe <gg...@163.com> on 2020/09/25 07:38:02 UTC, 1 replies.
- Submit New Job -> Show Plan源码 - posted by zilong xiao <ac...@gmail.com> on 2020/09/25 07:38:15 UTC, 1 replies.
- Flink SQL 1.11.1 executeSql/SqlUpdate时 SQL validation的一些问题 - posted by 刘首维 <li...@autohome.com.cn> on 2020/09/25 07:41:24 UTC, 1 replies.
- 怎么样在Flink中使用java代码提交job到yarn - posted by xiao cai <fl...@163.com> on 2020/09/25 08:23:43 UTC, 16 replies.
- 回复: flink读取mongo数据本地部署成功,flink-cluster部署找不到类 - posted by GeGe <gg...@163.com> on 2020/09/25 09:17:52 UTC, 0 replies.
- Re: flink 1.9.2 升级 1.10.0 任务失败不能从checkpoint恢复 - posted by Robin Zhang <vi...@outlook.com> on 2020/09/25 10:00:42 UTC, 0 replies.
- 关于sql中null值设置watermark - posted by Kyle Zhang <sh...@gmail.com> on 2020/09/25 11:23:50 UTC, 1 replies.
- flink在校验DDL属性是否合格时候代码在哪里? - posted by kcz <57...@qq.com> on 2020/09/26 05:26:47 UTC, 1 replies.
- 回复:请教二阶段提交问题 - posted by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/09/26 07:39:56 UTC, 1 replies.
- flink获取latencymarker有什么好的方法 - posted by 郭士榕 <gs...@163.com> on 2020/09/26 13:15:02 UTC, 4 replies.
- Flink 1.10.1 checkpoint失败问题 - posted by Storm☀️ <st...@163.com> on 2020/09/27 02:16:50 UTC, 1 replies.
- Flink SQL撤回流问题 - posted by xiao cai <fl...@163.com> on 2020/09/27 03:48:36 UTC, 13 replies.
- flink多流关联 - posted by Dream-底限 <zh...@akulaku.com> on 2020/09/27 04:09:23 UTC, 3 replies.
- FlinkSQL是否支持设置窗口trigger实现continuious trigger呢 - posted by 赵一旦 <hi...@gmail.com> on 2020/09/27 05:25:37 UTC, 9 replies.
- Checkpoint dir is not cleaned up after cancel the job with monitoring API - posted by Eleanore Jin <el...@gmail.com> on 2020/09/27 05:49:35 UTC, 3 replies.
- 【公告】Flink Forward 2020 亚洲峰会议题征集 - posted by Kurt Young <ku...@apache.org> on 2020/09/27 06:03:08 UTC, 0 replies.
- Flink SQL如何设置checkpoint的TTL - posted by xiao cai <fl...@163.com> on 2020/09/27 07:47:11 UTC, 1 replies.
- HistoryServer完成任务丢失的问题 - posted by xiao cai <fl...@163.com> on 2020/09/27 08:40:27 UTC, 7 replies.
- FlinkSQL timestamp数据类型转化 - posted by 赵一旦 <hi...@gmail.com> on 2020/09/27 08:46:36 UTC, 0 replies.
- flink sql count问题 - posted by zya <z_...@foxmail.com> on 2020/09/27 08:53:56 UTC, 2 replies.
- 回复:flink sql count问题 - posted by zya <z_...@foxmail.com> on 2020/09/27 09:01:06 UTC, 7 replies.
- 当kafka有大量数据积压并且flink冷启动,flink端读取kafka有没有限流的参数? - posted by me <me...@lishiyu.cn> on 2020/09/27 09:22:00 UTC, 3 replies.
- flink1.11提供的flink-webui中的日志界面的查看问题 - posted by 赵一旦 <hi...@gmail.com> on 2020/09/27 09:39:54 UTC, 0 replies.
- 关于如何贡献社区 - posted by Kyle Zhang <sh...@gmail.com> on 2020/09/27 09:43:10 UTC, 2 replies.
- 回复:当kafka有大量数据积压并且flink冷启动,flink端读取kafka有没有限流的参数? - posted by me <me...@lishiyu.cn> on 2020/09/27 09:44:49 UTC, 0 replies.
- flink 1.11.2 Table sql聚合后设置并行度为2及以上,数据无法输出 - posted by Asahi Lee <97...@qq.com> on 2020/09/27 10:05:15 UTC, 4 replies.
- flink-sql任务含有回撤数据的问题 - posted by 徐山山 <13...@qq.com> on 2020/09/27 10:15:43 UTC, 1 replies.
- Field types of query result and registered TableSink 'table' do not match. - posted by smallwong <sm...@163.com> on 2020/09/27 11:24:24 UTC, 2 replies.
- flink使用在docker环境中部署出现的两个问题 - posted by chenxuying <cx...@163.com> on 2020/09/27 11:56:06 UTC, 5 replies.
- 回复:Flink SQL如何设置checkpoint的TTL - posted by 111 <xi...@163.com> on 2020/09/28 00:47:01 UTC, 0 replies.
- sql-cli执行sql报错 - posted by "hl9902@126.com" <hl...@126.com> on 2020/09/28 01:16:08 UTC, 6 replies.
- 回复:sql-cli执行sql报错 - posted by 111 <xi...@163.com> on 2020/09/28 01:23:18 UTC, 2 replies.
- flunk - checkpoint - posted by 郝文强 <18...@163.com> on 2020/09/28 02:34:17 UTC, 2 replies.
- 回复: sql-cli执行sql报错 - posted by 111 <xi...@163.com> on 2020/09/28 02:41:17 UTC, 1 replies.
- 回复: flink 1.11.2 Table sql聚合后设置并行度为2及以上,数据无法输出 - posted by Asahi Lee <97...@qq.com> on 2020/09/28 05:55:51 UTC, 0 replies.
- flink1.8.1处理utc时间方式 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/09/28 06:42:42 UTC, 0 replies.
- Flink Batch 模式下,The rpc invocation size 113602196 exceeds the maximum akka framesize - posted by 李加燕 <li...@163.com> on 2020/09/28 07:06:36 UTC, 2 replies.
- flink1.11.2基于官网在k8s上部署是正常的,但是加了volume配置之后报错Read-only file system - posted by chenxuying <cx...@163.com> on 2020/09/28 07:40:16 UTC, 1 replies.
- flink sql 更新mysql字段 - posted by lemon <z_...@foxmail.com> on 2020/09/28 09:46:47 UTC, 2 replies.
- 回复: Re: sql-cli执行sql报错 - posted by "hl9902@126.com" <hl...@126.com> on 2020/09/28 10:05:31 UTC, 0 replies.
- 了解下大家生产中都用什么任务调度系统呢 - posted by 赵一旦 <hi...@gmail.com> on 2020/09/28 11:40:45 UTC, 5 replies.
- 回复:了解下大家生产中都用什么任务调度系统呢 - posted by 孟小鹏 <60...@qq.com> on 2020/09/28 12:22:04 UTC, 0 replies.
- 回复: Re: 怎么样在Flink中使用java代码提交job到yarn - posted by "chengyanan1008@foxmail.com" <ch...@foxmail.com> on 2020/09/29 01:54:25 UTC, 2 replies.
- flink基于源码如何编译打包生成flink-table-blink.jar - posted by XiaChang <13...@163.com> on 2020/09/29 02:46:20 UTC, 3 replies.
- checkpoint rocksdb hdfs 如何协调,保证数据不丢失 - posted by Michael Ran <gr...@163.com> on 2020/09/29 03:05:50 UTC, 0 replies.
- Re: checkpoint rocksdb hdfs 如何协调,保证数据不丢失 - posted by Congxian Qiu <qc...@gmail.com> on 2020/09/29 05:34:07 UTC, 1 replies.
- 如何在流式数据源上使用分析函数LAG和EAD函数 - posted by Robin Zhang <vi...@outlook.com> on 2020/09/29 06:03:56 UTC, 2 replies.
- Re: 回复: 怎么样在Flink中使用java代码提交job到yarn - posted by "chengyanan1008@foxmail.com" <ch...@foxmail.com> on 2020/09/29 06:14:57 UTC, 0 replies.
- Flink配置hdfs状态后端遇到的问题 - posted by jester_jim <je...@sina.com> on 2020/09/29 06:19:16 UTC, 2 replies.
- flink消费kafka,事务关闭问题 - posted by 宁吉浩 <a9...@dingtalk.com.INVALID> on 2020/09/29 06:25:48 UTC, 0 replies.
- flinksql多sink案例 - posted by todd <to...@163.com> on 2020/09/29 06:30:02 UTC, 0 replies.
- 创建BatchTableEnvironment报错 - posted by "hl9902@126.com" <hl...@126.com> on 2020/09/29 08:39:43 UTC, 0 replies.
- Re: 回复: BLinkPlanner sql join状态清理 - posted by Ericliuk <er...@gmail.com> on 2020/09/29 08:57:54 UTC, 3 replies.
- 使用异步IO时,数据写入到capacity数后,卡住不再消费source端数据了。 - posted by 王敏超 <mi...@163.com> on 2020/09/29 09:43:18 UTC, 2 replies.
- pyflink1.11 window groupby出错 - posted by 刘乘九 <li...@163.com> on 2020/09/29 09:46:04 UTC, 1 replies.
- 回复: flink sql count问题 - posted by lemon <z_...@foxmail.com> on 2020/09/29 09:50:17 UTC, 1 replies.
- flink1.11实时写入hive,写入速度很慢,checkpoint为60秒,并行度为1 - posted by me <me...@lishiyu.cn> on 2020/09/29 11:08:14 UTC, 0 replies.
- 回复:flink1.11实时写入hive,写入速度很慢,checkpoint为60秒,并行度为1 - posted by Jun Zhang <82...@qq.com> on 2020/09/29 11:12:40 UTC, 0 replies.
- 关于flink sql cdc - posted by Kyle Zhang <sh...@gmail.com> on 2020/09/29 11:39:15 UTC, 2 replies.
- Flink消费kafka,突然间任务输出结果从原来的每秒几十万降低到几万每秒 - posted by Yang Peng <ya...@gmail.com> on 2020/09/29 12:44:44 UTC, 10 replies.
- 回复:关于flink sql cdc - posted by 谢治平 <xi...@163.com> on 2020/09/30 01:25:43 UTC, 0 replies.
- flink1.11.1 kafka eos checkpoints失败:Timeout expired after 600000milliseconds - posted by 静谧雨寒 <fr...@vip.qq.com> on 2020/09/30 01:44:55 UTC, 0 replies.
- Flink 1.11 table.executeInsert 程序退出 - posted by HunterXHunter <13...@qq.com> on 2020/09/30 02:32:32 UTC, 0 replies.
- 回复: 回复:关于flink sql cdc - posted by 史 正超 <sh...@outlook.com> on 2020/09/30 02:51:05 UTC, 0 replies.
- 回复: Flink 1.11 table.executeInsert 程序退出 - posted by 史 正超 <sh...@outlook.com> on 2020/09/30 02:58:20 UTC, 0 replies.
- group agg 开启了mini batch之后,state ttl不生效的问题 - posted by "kandy.wang" <ka...@163.com> on 2020/09/30 06:19:01 UTC, 3 replies.
- Flink on K8s statebackend 配置 - posted by superainbower <su...@163.com> on 2020/09/30 06:33:47 UTC, 0 replies.
- 回复:Flink on K8s statebackend 配置 - posted by superainbower <su...@163.com> on 2020/09/30 07:03:54 UTC, 0 replies.
- 有docker jobmanager HA的 1.11.2 docker-entrypoint.sh - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/09/30 07:21:38 UTC, 0 replies.
- flink任务yarn perjob 提交任务如何设置job name - posted by 丁浩浩 <18...@163.com> on 2020/09/30 07:44:10 UTC, 1 replies.
- 回复:flink任务yarn perjob 提交任务如何设置job name - posted by 宁吉浩 <a9...@dingtalk.com.INVALID> on 2020/09/30 08:17:51 UTC, 0 replies.
- flinksql注册udtf使用ROW类型做为输出输出时出错 - posted by chenxuying <cx...@163.com> on 2020/09/30 11:07:06 UTC, 1 replies.