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

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

- 回复：如何获取算子处理一条数据记录的时间 - posted by 张江 <zj...@163.com> on 2020/01/01 12:44:04 UTC, 9 replies.
- Re: flink内存分配的问题 - posted by Xintong Song <to...@gmail.com> on 2020/01/02 01:54:55 UTC, 3 replies.
- FLINK 1.9.1 StreamingFileSink 压缩问题 - posted by USERNAME <or...@126.com> on 2020/01/02 05:36:26 UTC, 2 replies.
- How should i set the field type in mysql when i use temporal table join between kafka and jdbc ? - posted by 刘世民 <am...@163.com> on 2020/01/02 05:47:16 UTC, 2 replies.
- 回复： Re: flink内存分配的问题 - posted by cs <58...@qq.com> on 2020/01/02 05:49:00 UTC, 0 replies.
- flink 创建hbase出错 - posted by "lucas.wu" <lu...@xiaoying.com> on 2020/01/02 08:54:40 UTC, 2 replies.
- Re: Error:java: 无效的标记: --add-exports=java.base/sun.net.util=ALL-UNNAMED - posted by Chesnay Schepler <ch...@apache.org> on 2020/01/02 10:54:45 UTC, 0 replies.
- 回复： Flink实现Kafka到Mysql的 End-To-End Exactly-Once中遇到的问题 - posted by 残翅2008 <77...@qq.com> on 2020/01/03 07:13:38 UTC, 0 replies.
- Re: Flink实现Kafka到Mysql的 End-To-End Exactly-Once中遇到的问题 - posted by 卢伟楠 <gl...@gmail.com> on 2020/01/03 07:18:31 UTC, 0 replies.
- Re: 如何获取算子处理一条数据记录的时间 - posted by zhisheng <zh...@gmail.com> on 2020/01/03 07:57:05 UTC, 0 replies.
- 使用influxdb作为flink metrics reporter - posted by 张江 <zj...@163.com> on 2020/01/03 13:22:14 UTC, 1 replies.
- 单个算子处理一条数据的真实处理时间 - posted by 张江 <zj...@163.com> on 2020/01/03 13:28:01 UTC, 1 replies.
- SQL层应用维表join jdbc的时候，请问怎么动态感知维表数据的变化呢？ - posted by 刘世民 <am...@163.com> on 2020/01/04 03:27:22 UTC, 4 replies.
- 回复: StreamTableEnvironment.registerDatastream() 开放用户自定义的schemaDescriptionh和DeserializationSchema - posted by "aven.wu" <da...@163.com> on 2020/01/04 07:58:43 UTC, 0 replies.
- 回复：使用influxdb作为flink metrics reporter - posted by 张江 <zj...@163.com> on 2020/01/04 11:14:14 UTC, 2 replies.
- How long Flink state default TTL，if I don't config the state ttl config? - posted by LakeShen <sh...@gmail.com> on 2020/01/06 01:58:36 UTC, 3 replies.
- 问一下Flink Plan Visualizer什么时候会更新成1.9的样式 - posted by sl...@aliyun.com.INVALID on 2020/01/06 03:14:32 UTC, 2 replies.
- 使用Flink SQL时，碰到的【Window can only be defined over a time attribute column】 - posted by amenhub <am...@163.com> on 2020/01/06 08:41:19 UTC, 5 replies.
- Using async io in cep - posted by 郑洁锋 <zj...@hotmail.com> on 2020/01/06 08:59:06 UTC, 0 replies.
- 回复: 回复：如何获取算子处理一条数据记录的时间 - posted by 戴嘉诚 <a7...@gmail.com> on 2020/01/06 12:04:09 UTC, 1 replies.
- Flink Weekly | 每周社区动态更新 - 2020/01/07 - posted by Yun Tang <my...@LIVE.COM> on 2020/01/07 06:55:02 UTC, 0 replies.
- 注册table时catalog无法变更 - posted by "xiyueha@163.com" <xi...@163.com> on 2020/01/07 07:20:21 UTC, 3 replies.
- FLINK 不同 StateBackend ProcessWindowFunction的差别 - posted by USERNAME <or...@126.com> on 2020/01/07 09:54:12 UTC, 5 replies.
- Re: flink sql confluent schema avro topic注册成表 - posted by Bowen Li <bo...@gmail.com> on 2020/01/08 00:07:38 UTC, 0 replies.
- Re: jobgraph 生成 - posted by tison <wa...@gmail.com> on 2020/01/08 03:08:09 UTC, 1 replies.
- 回复：jobgraph 生成 - posted by 张江 <zj...@163.com> on 2020/01/08 04:09:33 UTC, 0 replies.
- 回复: 问一下Flink Plan Visualizer什么时候会更新成1.9的样式 - posted by sl...@aliyun.com.INVALID on 2020/01/08 04:55:59 UTC, 1 replies.
- Flink SQL Count Distinct performance optimization - posted by sunfulin <su...@163.com> on 2020/01/08 07:39:17 UTC, 6 replies.
- Re: 疑似ParquetTableSource Filter Pushdown bug - posted by jun su <su...@gmail.com> on 2020/01/08 09:12:08 UTC, 2 replies.
- flink算子状态查看 - posted by sunfulin <su...@163.com> on 2020/01/08 09:43:40 UTC, 1 replies.
- flink是否可以通过代码设置hadoop的配置文件目录 - posted by LJY <th...@163.com> on 2020/01/09 07:51:17 UTC, 2 replies.
- flink遇到 valueState 自身的 NPE - posted by Kevin Liao <li...@gmail.com> on 2020/01/09 09:56:39 UTC, 12 replies.
- Re: 流处理任务失败该如何追回之前的数据 - posted by Px New <15...@gmail.com> on 2020/01/09 10:50:15 UTC, 1 replies.
- flink消费Kafka没有数据问题 - posted by sunfulin <su...@163.com> on 2020/01/10 01:51:10 UTC, 0 replies.
- 回复：flink消费Kafka没有数据问题 - posted by Evan <ch...@foxmail.com> on 2020/01/10 01:53:52 UTC, 3 replies.
- Re: checkpoint、state - posted by Px New <15...@gmail.com> on 2020/01/10 02:27:05 UTC, 1 replies.
- Re: flink savepoint checkpoint - posted by Px New <15...@gmail.com> on 2020/01/10 02:58:41 UTC, 5 replies.
- 关于flink集群中调用dubbo服务的咨询 - posted by 依辰 <43...@qq.com> on 2020/01/10 03:12:21 UTC, 2 replies.
- flink消费kafka数据，如何从kafka端获取消费偏移信息 - posted by wqpapa <wq...@126.com> on 2020/01/12 13:09:16 UTC, 3 replies.
- 回复： Re: flink消费kafka数据，如何从kafka端获取消费偏移信息 - posted by Evan <ch...@foxmail.com> on 2020/01/13 02:47:48 UTC, 0 replies.
- 取消关注 - posted by sun <13...@qq.com> on 2020/01/13 03:33:15 UTC, 2 replies.
- Fail to deploy flink on k8s in minikube - posted by 刘建刚 <li...@gmail.com> on 2020/01/13 04:13:47 UTC, 4 replies.
- blink planner的org.apache.flink.table.api.ValidationException报错 - posted by Kevin Liao <li...@gmail.com> on 2020/01/13 09:19:49 UTC, 5 replies.
- flink checkpoint不生成 - posted by 起子 <qi...@dian.so> on 2020/01/13 09:52:57 UTC, 0 replies.
- 回复：flink checkpoint不生成 - posted by 起子 <qi...@dian.so> on 2020/01/13 10:01:22 UTC, 1 replies.
- Flink向量化读取parquet - posted by faaron zheng <fa...@gmail.com> on 2020/01/13 11:50:11 UTC, 1 replies.
- Flink Weekly | 每周社区动态更新 - 2020/01/14 - posted by Forward Xu <fo...@gmail.com> on 2020/01/14 01:58:03 UTC, 0 replies.
- 咨询一下 RocksDB 状态后端的调优经验 - posted by "DONG, Weike" <ky...@connect.hku.hk> on 2020/01/14 02:02:50 UTC, 4 replies.
- 转发：1.90版本的Flinksql相关使用问题 - posted by 往事Ψ随风 <13...@qq.com> on 2020/01/14 08:10:29 UTC, 0 replies.
- 求助帖: 流join场景可能出现的重复计算 - posted by Ren Xie <xi...@gmail.com> on 2020/01/14 09:37:57 UTC, 9 replies.
- Re: 1.90版本的Flinksql相关使用问题 - posted by Caizhi Weng <ts...@gmail.com> on 2020/01/14 09:45:14 UTC, 1 replies.
- 回复: 求助帖: 流join场景可能出现的重复计算 - posted by "Yuan,Youjun" <yu...@baidu.com> on 2020/01/14 12:22:17 UTC, 0 replies.
- 关于使用Flink RocksDBStateBackend问题 - posted by chanamper <ch...@163.com> on 2020/01/14 14:32:55 UTC, 1 replies.
- 两个问题：sideoutput 及 sql里的state - posted by izual <iz...@163.com> on 2020/01/15 02:40:36 UTC, 0 replies.
- flink on yarn jdk版本问题 - posted by 郑洁锋 <zj...@hotmail.com> on 2020/01/15 03:34:23 UTC, 4 replies.
- 求助帖:flink 连接kafka source 部署集群报错 - posted by Others <41...@qq.com> on 2020/01/15 06:59:51 UTC, 3 replies.
- 回复：求助帖:flink 连接kafka source 部署集群报错 - posted by AS <al...@163.com> on 2020/01/15 08:19:05 UTC, 1 replies.
- 回复： Re: Re: Re: 求助帖:flink 连接kafka source 部署集群报错 - posted by Others <41...@qq.com> on 2020/01/15 08:55:06 UTC, 0 replies.
- Re: When I use flink 1.9.1 and produce data to Kafka 1.1.1, The streamTask checkpoint error . - posted by Yun Tang <my...@live.com> on 2020/01/15 19:23:44 UTC, 0 replies.
- Flink Sql Join, how to clear the sql join state? - posted by LakeShen <sh...@gmail.com> on 2020/01/16 02:15:08 UTC, 1 replies.
- MiniCluster问题 - posted by 郑洁锋 <zj...@hotmail.com> on 2020/01/16 03:38:01 UTC, 13 replies.
- Filter with large key set - posted by Jin Yi <el...@gmail.com> on 2020/01/16 06:48:10 UTC, 2 replies.
- Flink 1.6 版本，RocksDBStateBackend ,增量 Checkpoint 目录问题 - posted by LakeShen <sh...@gmail.com> on 2020/01/16 08:47:45 UTC, 1 replies.
- 回复：Flink 1.6 版本，RocksDBStateBackend ,增量 Checkpoint 目录问题 - posted by "lucas.wu" <lu...@xiaoying.com> on 2020/01/16 08:50:28 UTC, 0 replies.
- 求助帖:flink tpc-ds中加入blink的runtime filter问题 - posted by zh...@gmail.com, zh...@gmail.com on 2020/01/16 09:00:38 UTC, 0 replies.
- 求助帖:flink tpc-ds分支尝试加入runtime filter问题 - posted by 小强 <fa...@qq.com> on 2020/01/16 09:04:13 UTC, 0 replies.
- 怎么使用flink的内存作为缓存 - posted by sun <13...@qq.com> on 2020/01/16 09:54:27 UTC, 1 replies.
- 关于1.9版本的flinksql中的csv format的问题 - posted by 往事Ψ随风 <13...@qq.com> on 2020/01/16 09:55:49 UTC, 0 replies.
- 怎么使用flink内存替代redis - posted by sun <13...@qq.com> on 2020/01/16 09:56:02 UTC, 2 replies.
- [ANNOUNCE] Dian Fu becomes a Flink committer - posted by jincheng sun <su...@gmail.com> on 2020/01/16 09:58:09 UTC, 24 replies.
- Frequently checkpoint failure, could make the flink sql state not clear? - posted by LakeShen <sh...@gmail.com> on 2020/01/16 12:53:30 UTC, 1 replies.
- 从checkpoint恢复任务失败 - posted by claylin <10...@qq.com> on 2020/01/16 14:00:39 UTC, 1 replies.
- flink内存参数 - posted by 张江 <zj...@163.com> on 2020/01/17 02:10:55 UTC, 1 replies.
- 怎么不使用checkpoint - posted by sun <13...@qq.com> on 2020/01/17 02:41:47 UTC, 1 replies.
- 回复：怎么不使用checkpoint - posted by sun <13...@qq.com> on 2020/01/17 05:43:53 UTC, 1 replies.
- 回复：回复：怎么不使用checkpoint - posted by sun <13...@qq.com> on 2020/01/17 08:03:49 UTC, 0 replies.
- Flink 增量 Checkpoint ，容错恢复后，随着时间的推移，之前的 Checkpoint 状态没有清理 - posted by LakeShen <sh...@gmail.com> on 2020/01/17 08:28:26 UTC, 7 replies.
- FLINK 1.9.1 TriggerResult.FIRE_AND_PURGE 与 ctx.registerEventTimeTimer() - posted by USERNAME <or...@126.com> on 2020/01/19 05:27:17 UTC, 1 replies.
- Re: 回复: 关于Flink SQL DISTINCT问题 - posted by LakeShen <sh...@gmail.com> on 2020/01/19 07:24:45 UTC, 0 replies.
- Flink 1.6, increment Checkpoint, the shared dir stored the last year checkpoint state - posted by LakeShen <sh...@gmail.com> on 2020/01/19 10:55:36 UTC, 1 replies.
- 支持flink.yarn.jars 参数 - posted by melin li <li...@gmail.com> on 2020/01/20 06:47:32 UTC, 1 replies.
- Question regarding checkpoint/savepoint and State Processor API - posted by Jin Yi <el...@gmail.com> on 2020/01/21 00:07:28 UTC, 1 replies.
- CountEvictor 与 TriggerResult.FIRE_AND_PURGE 清理窗口数据有区别吗? - posted by USERNAME <or...@126.com> on 2020/01/21 09:21:33 UTC, 3 replies.
- java.lang.StackOverflowError - posted by 刘建刚 <li...@gmail.com> on 2020/01/22 02:15:43 UTC, 4 replies.
- flink on yarn任务启动报错 The assigned slot container_e10_1579661300080_0005_01_000002_0 was removed. - posted by 郑洁锋 <zj...@hotmail.com> on 2020/01/22 03:15:56 UTC, 8 replies.
- blink(基于flink1.5.1版本)可以使用两个hadoop集群吗？ - posted by Yong <lu...@foxmail.com> on 2020/01/22 06:53:10 UTC, 1 replies.
- request for a flink sink - posted by 容祖儿 <zu...@gmail.com> on 2020/01/22 11:55:23 UTC, 1 replies.
- [State Processor API] how to convert savepoint back to broadcast state - posted by Jin Yi <el...@gmail.com> on 2020/01/23 00:12:34 UTC, 5 replies.
- Dataset是否能以index提取內部元素 - posted by 月月 <yu...@gmail.com> on 2020/01/28 16:06:40 UTC, 3 replies.