user-zh@flink.apache.org, 2022-09

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

- Cannot serialize operator object class org.apache.flink.streaming.api.operators.SourceOperatorFactory - posted by yidan zhao <hi...@gmail.com> on 2022/09/01 08:09:33 UTC, 0 replies.
- Flink1.15.1读取Tidb6，sql-client执行select count异常 java.sql.SQLSyntaxErrorException - posted by RS <ti...@163.com> on 2022/09/01 12:18:05 UTC, 2 replies.
- Re:Re: 用什么工具展示实时报表？ - posted by 郑垚（ZhengYao） <zh...@163.com> on 2022/09/02 01:28:51 UTC, 0 replies.
- 回复：Re: 用什么工具展示实时报表？ - posted by 张洋 <28...@qq.com.INVALID> on 2022/09/02 01:46:17 UTC, 2 replies.
- Re: 基于savepoint重启作业无法保证端到端一致性 - posted by 杨扬 <ya...@cupdata.com> on 2022/09/02 06:57:54 UTC, 1 replies.
- 退订 - posted by 守护 <34...@qq.com.INVALID> on 2022/09/02 07:31:00 UTC, 10 replies.
- flink 读取多个hive表进行计算会有什么隐患吗？ - posted by 段泽炳 <du...@foxmail.com> on 2022/09/02 08:41:38 UTC, 1 replies.
- Re: hello flink - posted by yh z <zh...@gmail.com> on 2022/09/02 10:29:08 UTC, 1 replies.
- questions about FLINK-27341 - posted by yidan zhao <hi...@gmail.com> on 2022/09/03 15:22:50 UTC, 0 replies.
- flink-1.14.4 提示内置函数不存在 - posted by kcz <57...@qq.com.INVALID> on 2022/09/05 03:50:25 UTC, 1 replies.
- 回复：flink-1.14.4 提示内置函数不存在 - posted by kcz <57...@qq.com.INVALID> on 2022/09/05 06:36:26 UTC, 0 replies.
- flink table API使用 - posted by 小昌同学 <cc...@163.com> on 2022/09/05 12:53:03 UTC, 1 replies.
- 回复：flink table API使用 - posted by 小昌同学 <cc...@163.com> on 2022/09/06 05:19:33 UTC, 0 replies.
- flink-1.15.2 ConfigOption package-local method - posted by kcz <57...@qq.com.INVALID> on 2022/09/06 12:15:30 UTC, 0 replies.
- 回复：flink-1.15.2 ConfigOption package-local method - posted by kcz <57...@qq.com.INVALID> on 2022/09/06 12:24:17 UTC, 0 replies.
- flink 1.13 发现下游busy是0 ，上游backpressure 是100% - posted by 周虓岗 <zh...@163.com> on 2022/09/07 07:59:05 UTC, 0 replies.
- 关于 UDAF 里面 ListView 的疑问 - posted by Zhiwen Sun <pe...@gmail.com> on 2022/09/07 08:23:25 UTC, 3 replies.
- Re: flink作业生成保存点失败 - posted by Congxian Qiu <qc...@gmail.com> on 2022/09/07 09:24:33 UTC, 0 replies.
- 关于flink table store的疑问 - posted by Kyle Zhang <sh...@gmail.com> on 2022/09/08 00:36:53 UTC, 4 replies.
- 关于keyby()如何保留原并行度的问题 - posted by "junjie.miao@goupwith.com" <ju...@goupwith.com> on 2022/09/08 06:17:23 UTC, 3 replies.
- 触发savepoint后, source算子会从对应offset处停止消费吗? - posted by 郑致远 <ze...@hotmail.com> on 2022/09/08 11:39:24 UTC, 1 replies.
- 这里为什么会报null指针错误，和源表数据有关系吗？ - posted by Asahi Lee <as...@qq.com.INVALID> on 2022/09/09 03:46:47 UTC, 2 replies.
- Key group is not in KeyGroupRange - posted by "junjie.miao@goupwith.com" <ju...@goupwith.com> on 2022/09/09 09:33:36 UTC, 3 replies.
- 回复：Key group is not in KeyGroupRange - posted by 张洋 <28...@qq.com.INVALID> on 2022/09/09 09:37:45 UTC, 0 replies.
- 回复: Re: Key group is not in KeyGroupRange - posted by "junjie.miao@goupwith.com" <ju...@goupwith.com> on 2022/09/09 09:58:31 UTC, 0 replies.
- flink 的数据传输,是上游算子推给下游, 还是下游算子拉取上游, 设计的考虑是啥? - posted by 郑致远 <ze...@hotmail.com> on 2022/09/09 11:04:27 UTC, 5 replies.
- partition - posted by 李乐 <ll...@163.com> on 2022/09/11 15:16:50 UTC, 0 replies.
- 回复：这里为什么会报null指针错误，和源表数据有关系吗？ - posted by Asahi Lee <as...@qq.com.INVALID> on 2022/09/13 12:54:10 UTC, 0 replies.
- Flink+Hudi:java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V - posted by Summer <bi...@paat.com> on 2022/09/14 01:27:45 UTC, 2 replies.
- 某作业计算算子处于busy状态 - posted by 杨扬 <ya...@cupdata.com> on 2022/09/15 06:50:31 UTC, 8 replies.
- flink-sql-connector-hbase-2.2模块在shade打包时遗漏了commons-io依赖 - posted by "junjie.miao@goupwith.com" <ju...@goupwith.com> on 2022/09/16 01:34:02 UTC, 1 replies.
- 任务启动异常导致Flink服务挂掉，无法启动Flink服务 - posted by Summer <bi...@paat.com> on 2022/09/16 05:56:56 UTC, 4 replies.
- 如何监控flink sql作业端到端延迟? - posted by "casel.chen" <ca...@126.com> on 2022/09/16 06:01:15 UTC, 0 replies.
- 回复：任务启动异常导致Flink服务挂掉，无法启动Flink服务 - posted by Summer <bi...@paat.com> on 2022/09/16 06:32:28 UTC, 3 replies.
- flink实时双流驱动join问题 - posted by "casel.chen" <ca...@126.com> on 2022/09/17 02:59:16 UTC, 4 replies.
- Flink Session模式常驻taskmanager - posted by 谭家良 <ta...@126.com> on 2022/09/19 03:33:56 UTC, 0 replies.
- Flink-1.15 HiveDynamicTableFactory 取Catalog使用 - posted by yanggang_it_job <ya...@163.com> on 2022/09/19 09:04:00 UTC, 2 replies.
- flink hybrid source问题 - posted by "casel.chen" <ca...@126.com> on 2022/09/19 11:41:36 UTC, 1 replies.
- flink web ui 异常问题 - posted by yidan zhao <hi...@gmail.com> on 2022/09/20 09:17:59 UTC, 0 replies.
- Flink SQL suport tfrecord format - posted by 张颖 <qu...@163.com> on 2022/09/20 11:41:41 UTC, 1 replies.
- 如何停止一个CEP Pattern? - posted by Frank <fr...@qq.com.INVALID> on 2022/09/21 02:03:40 UTC, 0 replies.
- native k8s部署模式下使用HA架构的HDFS集群无法正常连接 - posted by Tino Hean <ti...@gmail.com> on 2022/09/21 10:24:46 UTC, 3 replies.
- flink sql中如何对于hive进行hive的参数set - posted by "junjie.miao@goupwith.com" <ju...@goupwith.com> on 2022/09/22 02:19:06 UTC, 1 replies.
- Flink 的大Hive 维度表 - posted by macia kk <pr...@gmail.com> on 2022/09/22 04:16:16 UTC, 1 replies.
- 并行度>1时实时写入hive partition table且开启了checkpoint没有同步信息到metastore - posted by "junjie.miao@goupwith.com" <ju...@goupwith.com> on 2022/09/22 05:59:55 UTC, 4 replies.
- 关于Managed Memory的疑问 - posted by haishui <ha...@126.com> on 2022/09/22 06:41:46 UTC, 2 replies.
- 回复： Re: 并行度>1时实时写入hive partition table且开启了checkpoint没有同步信息到metastore - posted by hjw <10...@qq.com.INVALID> on 2022/09/22 08:46:06 UTC, 0 replies.
- StreamTableEnvironment.fromDataStream(dataStream)如何生成T类型的Schema? - posted by Frank <fr...@qq.com.INVALID> on 2022/09/22 09:44:56 UTC, 4 replies.
- 回复： StreamTableEnvironment.fromDataStream(dataStream)如何生成T类型的Schema? - posted by Frank <fr...@qq.com.INVALID> on 2022/09/23 09:33:28 UTC, 0 replies.
- flink cdc作业是否支持将湖表作为源表source? - posted by "casel.chen" <ca...@126.com> on 2022/09/25 10:09:35 UTC, 0 replies.
- 咨询多条flink cdc作业消费同一个库下不同表优化方案 - posted by "casel.chen" <ca...@126.com> on 2022/09/25 10:18:52 UTC, 1 replies.
- flink的消费速率是否可以调整 - posted by Jason_H <hy...@163.com> on 2022/09/26 02:16:23 UTC, 2 replies.
- flink cdc + kafka场景下增加kafka分区数问题 - posted by "casel.chen" <ca...@126.com> on 2022/09/26 15:21:10 UTC, 2 replies.
- flink cdc同只步表的schema到下游kafka topic吗？ - posted by "casel.chen" <ca...@126.com> on 2022/09/26 15:24:14 UTC, 0 replies.
- flink cdc能否同步DDL语句? - posted by "casel.chen" <ca...@126.com> on 2022/09/26 15:27:05 UTC, 0 replies.
- 控制流方式能否改变作业ExecutionGraph? - posted by "casel.chen" <ca...@126.com> on 2022/09/27 00:36:53 UTC, 0 replies.
- 回复：flink cdc + kafka场景下增加kafka分区数问题 - posted by JasonLee <17...@163.com> on 2022/09/27 02:43:20 UTC, 0 replies.
- PartitionNotFoundException - posted by yidan zhao <hi...@gmail.com> on 2022/09/27 08:21:42 UTC, 7 replies.
- Flink任务异常停止 - posted by lxk <lx...@163.com> on 2022/09/28 01:46:23 UTC, 1 replies.
- Flink作业算子uid修复 - posted by BIGO <ga...@bigo.sg.INVALID> on 2022/09/28 06:24:43 UTC, 1 replies.
- Re: [*Newsletter*] Flink作业算子uid修复 - posted by BIGO <ga...@bigo.sg.INVALID> on 2022/09/28 07:25:50 UTC, 0 replies.
- Re: [ANNOUNCE] Apache Flink 1.14.6 released - posted by Jingsong Li <ji...@gmail.com> on 2022/09/28 13:12:30 UTC, 0 replies.
- 如何处理Flink KafkaSource的异常的数据 - posted by Summer <bi...@paat.com> on 2022/09/29 02:02:34 UTC, 0 replies.
- 依赖flink cdc如何达到kafka connect with schema registry效果？ - posted by "casel.chen" <ca...@126.com> on 2022/09/30 00:04:10 UTC, 0 replies.
- 如何实现flink作业失败实时通知告警？ - posted by "casel.chen" <ca...@126.com> on 2022/09/30 05:50:56 UTC, 1 replies.
- 提交新的flink-sql的最佳方案是什么？ - posted by Zeguang ZHANG <ze...@se.com.INVALID> on 2022/09/30 07:26:22 UTC, 0 replies.
- Re:Hive提交分区异常，Caused by: java.io.FileNotFoundException: /tmp/... (No such file or directory) - posted by RS <ti...@163.com> on 2022/09/30 08:08:20 UTC, 0 replies.