user-zh@flink.apache.org, 2021-08

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

- 回复：flink 1.13.1 使用hive方言，like语法不支持？ - posted by johnjlong <jo...@163.com> on 2021/08/02 01:56:27 UTC, 0 replies.
- 回复：场景题：Flink SQL 不支持 INSERT INTO… ON DUPLICATE KEY UPDATE ? - posted by silence <sl...@aliyun.com.INVALID> on 2021/08/02 02:08:28 UTC, 3 replies.
- Re: flink 1.13.1 使用hive方言，执行hive sql解析报错 - posted by Rui Li <li...@gmail.com> on 2021/08/02 04:23:49 UTC, 1 replies.
- Re: flink 1.13.1 使用hive方言，like语法不支持？ - posted by Rui Li <li...@gmail.com> on 2021/08/02 04:24:32 UTC, 0 replies.
- 通过savepoint重启任务，link消费kafka，有重复消息 - posted by Jim Chen <ch...@gmail.com> on 2021/08/02 06:01:18 UTC, 9 replies.
- Re: flink1.12 sql-client 临时文件 - posted by Shengkai Fang <fs...@gmail.com> on 2021/08/02 06:29:05 UTC, 0 replies.
- Re: 回复：场景题：Flink SQL 不支持 INSERT INTO… ON DUPLICATE KEY UPDATE ? - posted by Shengkai Fang <fs...@gmail.com> on 2021/08/02 06:35:04 UTC, 1 replies.
- 退订 - posted by 张震 <ya...@gmail.com> on 2021/08/02 06:39:35 UTC, 40 replies.
- 回复： flink 1.13.1 使用hive方言，执行hive sql解析报错 - posted by Asahi Lee <97...@qq.com.INVALID> on 2021/08/02 07:04:49 UTC, 1 replies.
- 回复：回复：场景题：Flink SQL 不支持 INSERT INTO… ON DUPLICATE KEY UPDATE ? - posted by silence <sl...@aliyun.com.INVALID> on 2021/08/02 07:39:09 UTC, 1 replies.
- Re: 回复：回复：场景题：Flink SQL 不支持 INSERT INTO… ON DUPLICATE KEY UPDATE ? - posted by Tony Wei <to...@gmail.com> on 2021/08/02 09:33:14 UTC, 2 replies.
- Re: Flink1.12 用官方默认的log4j2打日志到kafka，如何区分jobmanager和TaskManager的日志？怎么加参数？ - posted by zhisheng <zh...@gmail.com> on 2021/08/02 10:05:40 UTC, 0 replies.
- 非对齐检查点还能保证exactly once语义吗 - posted by 张锴 <zk...@gmail.com> on 2021/08/02 10:53:11 UTC, 7 replies.
- 几个Flink 1.12. 2超时问题 - posted by Chenyu Zheng <ch...@hulu.com.INVALID> on 2021/08/03 06:02:53 UTC, 7 replies.
- eventTime语义一些设备的数据总是迟到被丢弃 - posted by zwoi <31...@qq.com.INVALID> on 2021/08/03 07:15:37 UTC, 2 replies.
- Re: $internal.yarn.log-config-file - posted by liwei li <hi...@gmail.com> on 2021/08/03 16:40:17 UTC, 0 replies.
- Flink sql 维表聚合问题请教 - posted by carlc <ca...@126.com> on 2021/08/04 02:40:56 UTC, 4 replies.
- flink sql统计IP出现次数TopN问题 - posted by "casel.chen" <ca...@126.com> on 2021/08/04 03:55:06 UTC, 0 replies.
- 回复： $internal.yarn.log-config-file - posted by comsir <60...@qq.com.INVALID> on 2021/08/04 04:07:11 UTC, 0 replies.
- kafka appender限流 - posted by datafollower <60...@qq.com.INVALID> on 2021/08/04 04:25:17 UTC, 0 replies.
- 回复：kafka appender限流 - posted by JasonLee <17...@163.com> on 2021/08/04 04:45:07 UTC, 1 replies.
- flink table over 窗口报错 - posted by yanyunpeng <ya...@rockontrol.com> on 2021/08/04 06:30:02 UTC, 0 replies.
- Re: flink table over 窗口报错 - posted by Caizhi Weng <ts...@gmail.com> on 2021/08/04 06:34:08 UTC, 5 replies.
- 1.14啥时候出呀 - posted by yidan zhao <hi...@gmail.com> on 2021/08/04 08:48:00 UTC, 2 replies.
- 回复： Flink sql 维表聚合问题请教 - posted by 黑色 <xi...@qq.com.INVALID> on 2021/08/04 08:50:58 UTC, 0 replies.
- filesystem connector不支持跨subtask合并小文件 - posted by "lixin58688@163.com" <li...@163.com> on 2021/08/04 09:32:44 UTC, 4 replies.
- (无主题) - posted by 洗你的头 <12...@qq.com.INVALID> on 2021/08/04 10:28:19 UTC, 1 replies.
- sql hints 在寫入透過 hive 創建的表時沒有作用 - posted by Tony Wei <to...@gmail.com> on 2021/08/05 02:20:42 UTC, 3 replies.
- flink sql sink到hbase报错hbase版本问题 - posted by tomhan_th <to...@126.com> on 2021/08/05 04:43:36 UTC, 0 replies.
- flink 1.13.1 执行hive方言sql, 报错Can not make a progress: all selected inputs are already finished - posted by Asahi Lee <97...@qq.com.INVALID> on 2021/08/05 09:52:41 UTC, 0 replies.
- taskmanager数问题请教 - posted by 上官 <yu...@163.com> on 2021/08/06 02:15:28 UTC, 1 replies.
- [ANNOUNCE] Apache Flink 1.13.2 released - posted by Yun Tang <my...@LIVE.COM> on 2021/08/06 05:51:41 UTC, 5 replies.
- 回复：如何监控kafka延迟 - posted by Jimmy Zhang <zh...@163.com> on 2021/08/07 03:06:48 UTC, 2 replies.
- 批流一体的一些疑问 - posted by yanyunpeng <ya...@rockontrol.com> on 2021/08/09 02:12:07 UTC, 3 replies.
- 如何通过Flink-sql 实现3个kafka-topic的join以及后续的窗口聚合计算操作？ - posted by wang guanglei <gl...@outlook.com> on 2021/08/09 15:58:41 UTC, 1 replies.
- Flink SQL向下兼容吗？ - posted by Jason Lee <ja...@163.com> on 2021/08/10 03:44:52 UTC, 2 replies.
- - posted by Chenyu Zheng <ch...@hulu.com.INVALID> on 2021/08/10 11:13:18 UTC, 1 replies.
- Re: Flink 1.12.5: The heartbeat of JobManager/TaskManager with id xxx timed out - posted by Chenyu Zheng <ch...@hulu.com.INVALID> on 2021/08/10 11:15:12 UTC, 0 replies.
- Flink HIve 文件压缩报错 - posted by 周瑞 <ru...@woqutech.com> on 2021/08/10 11:44:45 UTC, 3 replies.
- StreamSQL udf 类型返回问题 - posted by 梁钧宁 <li...@foxmail.com> on 2021/08/10 12:19:27 UTC, 0 replies.
- Re:Re: Over窗口聚合性能调优问题 - posted by Michael Ran <gr...@163.com> on 2021/08/10 12:23:33 UTC, 2 replies.
- cumulate 不能和比较函数连用 - posted by 李航飞 <te...@163.com> on 2021/08/11 03:40:56 UTC, 3 replies.
- Flink HIve 数据写入后查询无数据 - posted by 周瑞 <ru...@woqutech.com> on 2021/08/11 06:46:35 UTC, 0 replies.
- flink sql聚合后collect收集数据问题 - posted by "casel.chen" <ca...@126.com> on 2021/08/11 09:06:31 UTC, 2 replies.
- 有没有flink on k8s operator相关的中文使用资料 - posted by "casel.chen" <ca...@126.com> on 2021/08/12 00:45:15 UTC, 0 replies.
- Flink HIve 文件，上游Kafak数据很大的时候，无法完成checkpoint - posted by 周瑞 <ru...@woqutech.com> on 2021/08/12 02:09:21 UTC, 1 replies.
- SQL null 过滤的问题 - posted by silence <sl...@aliyun.com.INVALID> on 2021/08/12 04:54:12 UTC, 1 replies.
- FLink 1.13.2 use TVF data is not correct - posted by 李占阳 <15...@126.com> on 2021/08/13 09:14:05 UTC, 1 replies.
- flink调用drools服务器问题 - posted by yanyunpeng <ya...@rockontrol.com> on 2021/08/13 09:16:59 UTC, 1 replies.
- flink sql job 提交流程问题 - posted by Peihui He <pe...@gmail.com> on 2021/08/15 03:18:00 UTC, 1 replies.
- 关于flink sql自定义udf，eval方法被调用两次问题 - posted by 黄志高 <hu...@163.com> on 2021/08/15 14:04:36 UTC, 4 replies.
- 请教下Flink时间戳问题 - posted by Geoff nie <ge...@163.com> on 2021/08/16 02:27:26 UTC, 3 replies.
- 关于 Flink SQL 上的 State Schema Evolution - posted by 吴志宇 <na...@gmail.com> on 2021/08/16 03:43:55 UTC, 0 replies.
- 关于flink时区问题 - posted by Geoff nie <ge...@163.com> on 2021/08/16 03:47:15 UTC, 2 replies.
- Flink使用SQL注册UDF未来有规划吗 - posted by Ada Luna <gf...@gmail.com> on 2021/08/16 06:26:25 UTC, 2 replies.
- FlinkSQL 反压 inputPoolUsage问题 - posted by Ada Luna <gf...@gmail.com> on 2021/08/16 08:16:17 UTC, 2 replies.
- Flink On Yarn HA 部署模式下Flink程序无法启动 - posted by 周瑞 <ru...@woqutech.com> on 2021/08/17 03:03:22 UTC, 2 replies.
- flink 1.13.1版本，使用hive方言，执行insert overwirite语句，插入数据为空时，没有将表中原数据清空 - posted by Asahi Lee <97...@qq.com.INVALID> on 2021/08/17 06:46:55 UTC, 1 replies.
- flink 是否有计划执行truncate table语句 - posted by Asahi Lee <97...@qq.com.INVALID> on 2021/08/17 06:55:03 UTC, 0 replies.
- 邮件退订 - posted by 1421070960 <14...@qq.com.INVALID> on 2021/08/17 07:31:59 UTC, 0 replies.
- flinksql的udf中可以使用Operator state的api么？ - posted by andrew <15...@163.com> on 2021/08/17 11:04:18 UTC, 1 replies.
- 广告业务中如何用flink替换spark一些逻辑处理，是否需要用到processfunction - posted by 张锴 <zk...@gmail.com> on 2021/08/18 02:25:49 UTC, 2 replies.
- flink任务触发检查点时报错，非必现。并发访问Map异常。 - posted by yidan zhao <hi...@gmail.com> on 2021/08/18 02:36:11 UTC, 0 replies.
- cumulate函数和比较函数连用报错 - posted by 李航飞 <te...@163.com> on 2021/08/18 07:55:08 UTC, 4 replies.
- 固定间隔重启策略 - 计数逻辑 - posted by much l <mu...@gmail.com> on 2021/08/18 12:54:23 UTC, 0 replies.
- Process suspend when get Hana connection in open method of sink function - posted by "Chenzhiyuan(HR)" <zh...@huawei.com> on 2021/08/18 13:05:46 UTC, 0 replies.
- 关于InfluxDB中大量监控指标的count为0 - posted by Camile Sing <ca...@gmail.com> on 2021/08/19 07:13:59 UTC, 0 replies.
- flink-connector-redis连接器upsert()模式插入问题 - posted by 李航飞 <te...@163.com> on 2021/08/19 09:02:59 UTC, 5 replies.
- 请问如何从源码构建flink docker镜像？ - posted by Chenyu Zheng <ch...@hulu.com.INVALID> on 2021/08/19 11:37:57 UTC, 1 replies.
- Flink SQL Api不支持TIMESTAMP(p) WITH TIME ZONE 类型的列 - posted by changfeng <qi...@woqutech.com> on 2021/08/19 12:51:43 UTC, 3 replies.
- Re: Process suspend when get Hana connection in open method of sink function - posted by Chesnay Schepler <ch...@apache.org> on 2021/08/19 18:26:18 UTC, 0 replies.
- 请问同一个flink history server能够支持多个flink application cluster吗？ - posted by Chenyu Zheng <ch...@hulu.com.INVALID> on 2021/08/20 03:43:05 UTC, 2 replies.
- cumulate累加函数输出问题 - posted by 李航飞 <te...@163.com> on 2021/08/20 07:26:03 UTC, 2 replies.
- spring集成flinkclient提交jar文件的问题 - posted by 教主 <84...@qq.com.INVALID> on 2021/08/20 07:29:46 UTC, 0 replies.
- 怎么才能取消订阅呢 - posted by 18221112048 <18...@163.com> on 2021/08/20 07:36:39 UTC, 1 replies.
- flink checkpoint 到hdfs 报错 - posted by 杨帅统 <it...@163.com> on 2021/08/20 10:13:10 UTC, 3 replies.
- 回复：退订 - posted by JasonLee <17...@163.com> on 2021/08/21 02:21:29 UTC, 0 replies.
- Flink-SQL 消费Confluent Kafka 反序列化失败 - posted by wang guanglei <gl...@outlook.com> on 2021/08/23 02:06:34 UTC, 0 replies.
- flink on k8s作业日志持久化问题 - posted by "casel.chen" <ca...@126.com> on 2021/08/23 03:37:54 UTC, 2 replies.
- 如何按照数据量，可用内存，核为flink job分配合适的资源 - posted by 张锴 <zk...@gmail.com> on 2021/08/24 03:15:22 UTC, 2 replies.
- Flink web ui 鉴权 - posted by yidan zhao <hi...@gmail.com> on 2021/08/24 09:25:49 UTC, 3 replies.
- mini-batch 设置后没效果 - posted by 李航飞 <te...@163.com> on 2021/08/25 03:03:54 UTC, 3 replies.
- 回复：mini-batch 设置后没效果 - posted by 牛成 <ch...@sugardt.com> on 2021/08/25 07:50:26 UTC, 0 replies.
- mini-batch配置信息没产生效果 - posted by 李航飞 <te...@163.com> on 2021/08/25 08:38:53 UTC, 1 replies.
- Flink 从checkpoint恢复时，部分状态没有正确恢复 - posted by dixingxing <di...@163.com> on 2021/08/25 12:56:46 UTC, 2 replies.
- 【Announce】Zeppelin 0.10.0 is released, Flink on Zeppelin Improved - posted by Jeff Zhang <zj...@gmail.com> on 2021/08/25 14:48:22 UTC, 2 replies.
- Flink任务假死；无限100%反压；但下游节点无压力。 - posted by yidan zhao <hi...@gmail.com> on 2021/08/26 02:08:55 UTC, 8 replies.
- 基于flink 1.12 如何通过Flink SQL 实现多sink端在同一个事务中 - posted by 悟空 <wu...@foxmail.com> on 2021/08/26 03:31:08 UTC, 7 replies.
- 回复：基于flink 1.12 如何通过Flink SQL 实现多sink端在同一个事务中 - posted by 悟空 <wu...@foxmail.com> on 2021/08/26 04:41:37 UTC, 1 replies.
- Flink sql CLI parsing avro format data error 解析avro数据失败 - posted by Wayne <17...@163.com> on 2021/08/26 05:18:56 UTC, 2 replies.
- 回复： Flink任务假死；无限100%反压；但下游节点无压力。 - posted by JasonLee <17...@163.com> on 2021/08/26 05:28:47 UTC, 0 replies.
- flink on native k8s jobManger频繁重启，caused by too old resource version - posted by blue <ia...@163.com> on 2021/08/26 09:07:45 UTC, 1 replies.
- Flink的window计算、级联window计算、window后复杂算子计算等导致CPU尖刺问题 - posted by yidan zhao <hi...@gmail.com> on 2021/08/26 09:33:45 UTC, 1 replies.
- table.exec.state.ttl - posted by 李航飞 <te...@163.com> on 2021/08/26 11:02:33 UTC, 3 replies.
- 如何 Flink 通过不同的hive_catalog，访问离线和实时两套集群的hive？ - posted by Jim Chen <ch...@gmail.com> on 2021/08/27 05:59:22 UTC, 4 replies.
- flink sink oss problem - posted by payne_z <pa...@aliyun.com.INVALID> on 2021/08/27 06:02:19 UTC, 2 replies.
- flink oss ha - posted by dker eandei <wa...@outlook.com> on 2021/08/27 06:58:14 UTC, 2 replies.
- flink run -d -m yarn-cluster 提交任务到yarn集群不成功 - posted by Wayne <17...@163.com> on 2021/08/28 12:37:08 UTC, 0 replies.
- 来自Wayne的邮件 - posted by Wayne <17...@163.com> on 2021/08/28 12:40:31 UTC, 0 replies.
- flink系统配置中的io.tmp.dirs里的文件自动清理机制 - posted by 王春波 <89...@qq.com.INVALID> on 2021/08/30 01:56:47 UTC, 2 replies.
- Re: flink run -d -m yarn-cluster 提交任务到yarn集群不成功 - posted by Caizhi Weng <ts...@gmail.com> on 2021/08/30 02:03:04 UTC, 2 replies.
- 回复： flink系统配置中的io.tmp.dirs里的文件自动清理机制 - posted by 王春波 <89...@qq.com.INVALID> on 2021/08/30 02:26:29 UTC, 0 replies.
- 回复: flink oss ha - posted by dker eandei <wa...@outlook.com> on 2021/08/30 04:36:07 UTC, 0 replies.
- flink run 提交任务到yarn 报Cannot load user class: org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer - posted by Wayne <17...@163.com> on 2021/08/30 07:12:45 UTC, 1 replies.
- 回复: Re: 基于flink 1.12 如何通过Flink SQL 实现多sink端在同一个事务中 - posted by "wukong91@foxmail.com" <wu...@foxmail.com> on 2021/08/30 08:54:53 UTC, 0 replies.
- flink keyby问题 - posted by cs <58...@qq.com.INVALID> on 2021/08/30 14:26:37 UTC, 0 replies.
- 回复：flink keyby问题 - posted by JasonLee <17...@163.com> on 2021/08/30 14:42:31 UTC, 0 replies.
- Flink on yarn的日志监控和checkpoint的监控生产是如何处理的？ - posted by guanyq <dl...@163.com> on 2021/08/31 05:23:06 UTC, 0 replies.
- Could not execute ALTER TABLE check_rule_base_hive_catalog.test_flink.test_partition DROP PARTITION (dt=2021-08-31) - posted by Asahi Lee <97...@qq.com.INVALID> on 2021/08/31 06:03:07 UTC, 0 replies.
- 是否可以自定义trigger实现event time window的分散触发 - posted by yidan zhao <hi...@gmail.com> on 2021/08/31 06:51:57 UTC, 6 replies.
- 回复：Flink on yarn的日志监控和checkpoint的监控生产是如何处理的？ - posted by JasonLee <17...@163.com> on 2021/08/31 11:43:00 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 3.1.0 released - posted by Igal Shilman <ig...@apache.org> on 2021/08/31 15:09:43 UTC, 1 replies.