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

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

- test - posted by mq sun <su...@gmail.com> on 2021/01/01 18:41:20 UTC, 0 replies.
- flink 1.11.2 非原生k8s session模式作业运行失败 - posted by 陈帅 <ca...@126.com> on 2021/01/02 01:42:01 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 2.2.2 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2021/01/02 02:36:51 UTC, 2 replies.
- Re:Re: flink 1.12.0 kubernetes-session部署问题 - posted by 陈帅 <ca...@126.com> on 2021/01/02 02:42:53 UTC, 1 replies.
- 回复：FlinkSQL 下推的值类型与字段类型不对应 - posted by automths <au...@163.com> on 2021/01/02 04:28:40 UTC, 1 replies.
- crontab通过脚本启动flink-job失败,flink-sql-parquet_2.11-1.12.0.jar does not exist - posted by 徐州州 <25...@qq.com> on 2021/01/02 07:19:10 UTC, 2 replies.
- flink on k8s作业监控问题 - posted by 陈帅 <ca...@126.com> on 2021/01/02 11:53:51 UTC, 1 replies.
- flink on k8s application mode指定运行作业jar包路径问题 - posted by 陈帅 <ca...@126.com> on 2021/01/02 12:08:24 UTC, 1 replies.
- Flink SQL DDL Schema csv嵌套json - posted by "amenhub@163.com" <am...@163.com> on 2021/01/03 08:09:41 UTC, 0 replies.
- 回复： flink 1.12 Cancel Job内存未释放(问) - posted by 徐州州 <25...@qq.com> on 2021/01/04 00:44:36 UTC, 6 replies.
- Flink SQL>查询的hive表数据全部为NULL - posted by Jacob <17...@163.com> on 2021/01/04 01:19:30 UTC, 3 replies.
- Re: flink1.12错误OSError: Expected IPC message of type schema but got record batch - posted by 咿咿呀呀 <20...@qq.com> on 2021/01/04 01:38:02 UTC, 4 replies.
- flink1.11 mysql cdc checkpoint 失败后程序自动恢复，同步数据出现重复 - posted by lingchanhu <li...@163.com> on 2021/01/04 02:38:30 UTC, 1 replies.
- 回复: Flink SQL DDL Schema csv嵌套json - posted by "amenhub@163.com" <am...@163.com> on 2021/01/04 03:12:34 UTC, 0 replies.
- 回复： flink1.12错误OSError: Expected IPC message of type schema but got record batch - posted by 刘海 <li...@163.com> on 2021/01/04 03:40:34 UTC, 0 replies.
- 如何优雅的开发Flink SQL作业 - posted by HideOnBushKi <14...@qq.com> on 2021/01/04 07:14:46 UTC, 1 replies.
- Flink SQL查询ORC表结果全部为NULL - posted by Jacob <17...@163.com> on 2021/01/04 08:08:40 UTC, 0 replies.
- pyflink-1.12.0 stream api任务执行失败 - posted by ゛无邪 <17...@163.com> on 2021/01/04 08:10:44 UTC, 3 replies.
- Flink on k8s 1.11.3版本，使用 hdfs 的任务， taskmanager 无法启动的问题 - posted by 龙逸尘 <ly...@gmail.com> on 2021/01/04 08:38:48 UTC, 2 replies.
- Re: FlinkSQL 下推的值类型与字段类型不对应 - posted by Sebastian Liu <li...@gmail.com> on 2021/01/04 08:49:25 UTC, 0 replies.
- 回复： FlinkSQL 下推的值类型与字段类型不对应 - posted by automths <au...@163.com> on 2021/01/04 08:57:49 UTC, 0 replies.
- pyflink-udaf - posted by 消息室 <he...@qq.com> on 2021/01/04 12:07:18 UTC, 3 replies.
- Re: flink on yarn提交任务失败。 - posted by Yang Wang <da...@gmail.com> on 2021/01/04 13:09:27 UTC, 0 replies.
- Re: flink 1.12 Cancel Job内存未释放(问) - posted by 赵一旦 <hi...@gmail.com> on 2021/01/04 14:06:21 UTC, 0 replies.
- apache flink - posted by "Waldeinsamkeit." <12...@qq.com> on 2021/01/05 03:12:44 UTC, 1 replies.
- 关于flink rest api的监控接口问题 - posted by 赵一旦 <hi...@gmail.com> on 2021/01/05 03:24:42 UTC, 0 replies.
- 回复： apache flink - posted by "Waldeinsamkeit." <12...@qq.com> on 2021/01/05 03:27:31 UTC, 0 replies.
- 退订 - posted by fuzs <fu...@mvs.com.cn> on 2021/01/05 03:57:14 UTC, 11 replies.
- FlinkSQL 1.10.0 where条件包含关键字列名的过滤条件不能使用=判断 - posted by Robin Zhang <vi...@outlook.com> on 2021/01/05 05:58:57 UTC, 0 replies.
- flink，自定义调度 - posted by "Waldeinsamkeit." <12...@qq.com> on 2021/01/05 08:11:15 UTC, 0 replies.
- flink cpu 利用率 - posted by 爱吃鱼 <ai...@163.com> on 2021/01/05 08:17:55 UTC, 11 replies.
- 回复：flink cpu 利用率 - posted by 爱吃鱼 <ai...@163.com> on 2021/01/05 08:48:47 UTC, 0 replies.
- flink sql 消费鉴权的kafka，是怎么消费的呢？在kafka未添加鉴权之前，flink SQL消费kafka是正常的 - posted by Carmen Free <dd...@gmail.com> on 2021/01/05 09:09:23 UTC, 4 replies.
- Flink 1.10在udf中传入array类型的解析异常 - posted by sunfulin <su...@163.com> on 2021/01/05 09:37:48 UTC, 0 replies.
- 回复：apache flink - posted by 12...@qq.com on 2021/01/05 10:00:27 UTC, 0 replies.
- Re: Some questions about limit push down - posted by Arvid Heise <ar...@ververica.com> on 2021/01/05 10:31:09 UTC, 0 replies.
- flink 空指针警告 - posted by lp <97...@qq.com> on 2021/01/05 12:06:47 UTC, 3 replies.
- flinksql1.11 查询phoenix维表报错Caused by: org.apache.calcite.avatica.NoSuchStatementException - posted by 黑色 <xi...@qq.com> on 2021/01/05 12:20:14 UTC, 0 replies.
- 请教Flink中关于窗口的问题 - posted by syumialiu <sy...@163.com> on 2021/01/05 15:40:20 UTC, 2 replies.
- 回复： crontab通过脚本启动flink-job失败,flink-sql-parquet_2.11-1.12.0.jar does not exist - posted by 徐州州 <25...@qq.com> on 2021/01/06 01:32:46 UTC, 3 replies.
- 回复: flinksql1.11 查询phoenix维表报错Caused by: org.apache.calcite.avatica.NoSuchStatementException - posted by Evan <ch...@foxmail.com> on 2021/01/06 01:49:40 UTC, 1 replies.
- checkpoint失败怎么排查 - posted by ab...@163.com on 2021/01/06 01:53:33 UTC, 3 replies.
- hive模块依赖orc版本与flink-orc版本不一致问题 - posted by 奔跑的小飞袁 <s_...@126.com> on 2021/01/06 02:12:54 UTC, 0 replies.
- PyFlink on Yarn,Per-Job模式，如何增加多个外部依赖jar包? - posted by Zhizhao Shangguan <sg...@163.com> on 2021/01/06 02:23:06 UTC, 1 replies.
- flink timestamp 解析问题 - posted by air23 <wa...@163.com> on 2021/01/06 02:41:06 UTC, 1 replies.
- flink任务调度 - posted by "penguin." <bx...@126.com> on 2021/01/06 02:44:43 UTC, 0 replies.
- 来自penguin.的邮件 - posted by "penguin." <bx...@126.com> on 2021/01/06 02:55:17 UTC, 0 replies.
- Re: PyFlink on Yarn, Per-Job模式，如何增加多个外部依赖jar包? - posted by Wei Zhong <we...@gmail.com> on 2021/01/06 03:04:56 UTC, 0 replies.
- 修改flink的任务调度 - posted by "penguin." <bx...@126.com> on 2021/01/06 03:15:33 UTC, 10 replies.
- flink sql消费kafka sink到mysql问题 - posted by air23 <wa...@163.com> on 2021/01/06 04:29:26 UTC, 0 replies.
- 自定义InputFormat在发生异常时状态如何保存 - posted by automths <au...@163.com> on 2021/01/06 05:44:01 UTC, 0 replies.
- 请问大神们flink-sql可以指定时间清除内存中的全部State吗？ - posted by 徐州州 <25...@qq.com> on 2021/01/06 05:53:28 UTC, 2 replies.
- 回复: flink sql消费kafka sink到mysql问题 - posted by Evan <ch...@foxmail.com> on 2021/01/06 06:01:34 UTC, 1 replies.
- Flink SQL 如何保证多个sql 语句按顺序执行 - posted by Jacob <17...@163.com> on 2021/01/06 06:11:48 UTC, 2 replies.
- hive表已创建的情况下从checkpoint恢复作业 - posted by "amenhub@163.com" <am...@163.com> on 2021/01/06 07:47:02 UTC, 0 replies.
- 通过k8s 部署的flink 集群 - posted by 旧城以西 <dt...@163.com> on 2021/01/06 07:54:07 UTC, 2 replies.
- Flink sql 流批一体的应用 - posted by Jacob <17...@163.com> on 2021/01/06 07:56:54 UTC, 0 replies.
- Re: Flink cdc connector：数据量较大时，snapshot阶段报错 - posted by jindy_liu <28...@qq.com> on 2021/01/06 08:07:47 UTC, 0 replies.
- Flink 1.10 on yarn提交任务报错 - posted by 黄润星 <hu...@163.com> on 2021/01/06 08:14:15 UTC, 1 replies.
- flink sql开了TwoStageOptimizedAggregateRule优化，容易jvm heap outofmemory？ - posted by jindy_liu <28...@qq.com> on 2021/01/06 08:24:34 UTC, 0 replies.
- flink作业通过grafana监控，若想发出报警该如何选择指标的问题 - posted by bradyMk <zh...@126.com> on 2021/01/06 08:35:05 UTC, 12 replies.
- StreamFileSink落盘文件合并 - posted by cs <58...@qq.com> on 2021/01/06 10:10:33 UTC, 0 replies.
- CEP 如何按事件时间处理 - posted by bulterman <15...@163.com> on 2021/01/06 11:50:34 UTC, 1 replies.
- 请教关于是否有除了计算压力以外的反压原因。比如‘网络’？ - posted by 赵一旦 <hi...@gmail.com> on 2021/01/06 15:43:12 UTC, 1 replies.
- flink版本升级问题咨询 - posted by zhang hao <zh...@gmail.com> on 2021/01/07 01:50:45 UTC, 0 replies.
- flink-kafka-sink - posted by cxx <11...@qq.com> on 2021/01/07 01:53:18 UTC, 1 replies.
- Flink CVE补丁会打在1.10版本吗 - posted by Luna Wong <gf...@gmail.com> on 2021/01/07 02:44:23 UTC, 1 replies.
- Flink 1.11.2版本实时任务运行报错 is running beyond physical memory limits. Current usage: 25.0 GB of 25 GB physical memory used; 28.3 GB of 52.5 GB virtual memory used. Killing container - posted by Yang Peng <ya...@gmail.com> on 2021/01/07 04:24:34 UTC, 1 replies.
- flink的算子没有类似于spark的cache操作吗？ - posted by 李继 <li...@gmail.com> on 2021/01/07 09:41:57 UTC, 2 replies.
- sql-client配置hive启动不了 - posted by amenhub <am...@163.com> on 2021/01/07 10:39:51 UTC, 0 replies.
- Flink1.12触发保存点时失败 - posted by 赵一旦 <hi...@gmail.com> on 2021/01/07 12:13:23 UTC, 1 replies.
- SQL作业的提交方式 - posted by jiangjiguang719 <ji...@163.com> on 2021/01/07 12:33:59 UTC, 4 replies.
- Flink1.12怎么降级avro到1.8.2？ - posted by Dacheng <dy...@163.com> on 2021/01/07 12:55:14 UTC, 1 replies.
- 回复：sql-client配置hive启动不了 - posted by 叶贤勋 <yx...@163.com> on 2021/01/08 02:03:30 UTC, 2 replies.
- flink on k8s 提交job时如何指定taskmanager的个数 - posted by 旧城以西 <dt...@163.com> on 2021/01/08 02:12:45 UTC, 1 replies.
- flink1.12.0 native k8s启动不了 - posted by yzxs <cz...@gmail.com> on 2021/01/08 04:12:21 UTC, 2 replies.
- Re: 在where条件中使用汉字导致查询出的字段出现unicode编码 - posted by spike <tc...@gmail.com> on 2021/01/08 04:21:02 UTC, 0 replies.
- Re: Re：sql-client配置hive启动不了 - posted by amenhub <am...@163.com> on 2021/01/08 07:22:11 UTC, 0 replies.
- 检查点无错误，但是日志中有错误，不清楚是什么原理呢？ - posted by 赵一旦 <hi...@gmail.com> on 2021/01/08 08:51:35 UTC, 0 replies.
- 腾讯安检测的这个Apache Flink目录遍历漏洞风险通告，社区会对以前的版本根据修复吗 - posted by zhouyajun <ya...@dmall.com> on 2021/01/08 09:39:20 UTC, 1 replies.
- FlinkSQL 的表中定义字段为Float类型，查询时报错 - posted by automths <au...@163.com> on 2021/01/08 10:26:45 UTC, 0 replies.
- flink1.12的kafka source 和 OperatorCoordinator - posted by hao kong <ha...@lemonbox.me> on 2021/01/08 16:28:57 UTC, 0 replies.
- Sql Client读取Kafka报错：Could not find any factory for identifier 'kafka' - posted by inza9hi <ya...@foxmail.com> on 2021/01/08 18:08:12 UTC, 2 replies.
- 【Flink SQL】维表优化规则建议 - posted by 张韩 <ha...@163.com> on 2021/01/09 01:39:18 UTC, 4 replies.
- flink sqlsubmit自定义程序报错 - posted by Fei Han <ha...@aliyun.com.INVALID> on 2021/01/10 08:22:58 UTC, 1 replies.
- Row function cannot have column reference through table alias - posted by 马阳阳 <ma...@163.com> on 2021/01/11 03:04:35 UTC, 3 replies.
- Flink Stream SQL 何时支持拉取 Iceberg表 - posted by Luna Wong <gf...@gmail.com> on 2021/01/11 07:49:06 UTC, 0 replies.
- 请教个Flink savepoint的问题 - posted by "yinghua_zh@163.com" <yi...@163.com> on 2021/01/11 11:07:31 UTC, 2 replies.
- flink 1.10 将流设置为 idle - posted by Akisaya <ak...@gmail.com> on 2021/01/11 11:17:55 UTC, 1 replies.
- 回复：flink版本升级问题咨询 - posted by xuhaiLong <xi...@163.com> on 2021/01/11 12:12:56 UTC, 1 replies.
- flink1.12流式写hive任务暂停问题 - posted by lhuiseu <li...@ipalfish.com> on 2021/01/11 12:40:01 UTC, 1 replies.
- Flink IDEA中使用Iceberg - posted by Luna Wong <gf...@gmail.com> on 2021/01/11 12:56:25 UTC, 0 replies.
- flink编译报错 - posted by "penguin." <bx...@126.com> on 2021/01/12 01:58:39 UTC, 3 replies.
- Flink1.12.0 sql-client连接hive报错 - posted by yujianbo <15...@163.com> on 2021/01/12 02:34:34 UTC, 0 replies.
- 回复：Flink1.12.0 sql-client连接hive报错 - posted by 范瑞 <83...@qq.com> on 2021/01/12 02:49:28 UTC, 1 replies.
- flinksql1.12建view流式读取hive分区表不支持，报错信息：[ERROR] Could not execute SQL statement. Reason: java.lang.UnsupportedOperationException: class org.apache.calcite.sql.SqlSyntax$6: SPECIAL - posted by yanzi <an...@126.com> on 2021/01/12 03:11:46 UTC, 0 replies.
- flink1.12-sql的current_date不会随着时间改变。 - posted by 徐州州 <25...@qq.com> on 2021/01/12 04:34:01 UTC, 0 replies.
- Flink代码一直报 java.lang.NullPointerException错误，但变量明明初始化了，却仍然有该错误，找不到原因，请诸位指教。谢谢 - posted by JackJia <co...@126.com> on 2021/01/12 06:16:10 UTC, 1 replies.
- Flink SQL 可以使用异步IO特性吗 - posted by kenyore <wo...@gmail.com> on 2021/01/12 06:38:32 UTC, 4 replies.
- rocksdb作为statebackend时，TM节点挂掉了，为何任务不能恢复呢？ - posted by Carmen Free <dd...@gmail.com> on 2021/01/12 07:52:47 UTC, 6 replies.
- flink waterMark 相关问题 - posted by 张锴 <zk...@gmail.com> on 2021/01/12 09:55:47 UTC, 7 replies.
- FlinkSQL Filter Error With Float Column on flink-1.12.0 - posted by jy l <lj...@gmail.com> on 2021/01/12 10:04:21 UTC, 1 replies.
- Flink SQL一个Job使用多个Catalog的例子 - posted by Luna Wong <gf...@gmail.com> on 2021/01/12 13:41:48 UTC, 1 replies.
- flink 编译 - posted by "penguin." <bx...@126.com> on 2021/01/12 13:44:06 UTC, 1 replies.
- 回复: flink 编译 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2021/01/12 15:09:47 UTC, 0 replies.
- 为什么我这个打印的是上次的watermark,而是用的是这次的watermark呢,为什么打印的不是这次的呢 - posted by 何宗谨 <he...@qq.com> on 2021/01/13 01:19:59 UTC, 2 replies.
- 回复：flink waterMark 相关问题 - posted by Ball's Holy <87...@qq.com> on 2021/01/13 01:41:38 UTC, 0 replies.
- flink1.11.1 如何让多个log4j配置文件生效 - posted by nicygan <re...@163.com> on 2021/01/13 01:54:00 UTC, 1 replies.
- 回复： flink waterMark 相关问题 - posted by Ball's Holy <87...@qq.com> on 2021/01/13 02:14:57 UTC, 1 replies.
- 回复：为什么我这个打印的是上次的watermark,而是用的是这次的watermark呢,为什么打印的不是这次的呢 - posted by 何宗谨 <he...@qq.com> on 2021/01/13 02:20:39 UTC, 0 replies.
- flink sql读kafka元数据问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2021/01/13 02:45:38 UTC, 2 replies.
- flink源码项目导入idea，无法下载插件和依赖 - posted by "penguin." <bx...@126.com> on 2021/01/13 04:11:48 UTC, 0 replies.
- idea导入flink源码问题 - posted by "penguin." <bx...@126.com> on 2021/01/13 05:19:40 UTC, 3 replies.
- 如何修改FlinkSQL中DATE类型对应的Conversion类？ - posted by automths <au...@163.com> on 2021/01/13 05:25:13 UTC, 0 replies.
- Re:Re: idea导入flink源码问题(看不到图片，贴了下文字) - posted by "penguin." <bx...@126.com> on 2021/01/13 05:57:20 UTC, 3 replies.
- Flink sql cli 查询hive 为两个字段的分区表如果where条件不指定这两个字段条件会出异常 - posted by yujianbo <15...@163.com> on 2021/01/13 06:33:23 UTC, 1 replies.
- Flink 1.12 Too old resource version - posted by 吴松 <ux...@gmail.com> on 2021/01/13 06:54:34 UTC, 0 replies.
- flink watermark 为负数的异常 - posted by 张锴 <zk...@gmail.com> on 2021/01/13 07:38:06 UTC, 0 replies.
- flink 1.12.0 报MaxWithRetractAggFunction$MaxWithRetractAccumulatr$Converter.toInternal java.lang.interger cannot to org.apache.flink.table.data.StringData异常 - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2021/01/13 08:10:42 UTC, 0 replies.
- flink-cdc报错 - posted by "guoxb__123@sina.com" <gu...@sina.com> on 2021/01/13 08:32:26 UTC, 1 replies.
- Re: Re: Flink 1.10.1版本StreamingFileSink写入HDFS失败 - posted by amenhub <am...@163.com> on 2021/01/13 08:52:11 UTC, 0 replies.
- Flink CEP 使用Keyby之后无法输出结果 - posted by HunterXHunter <13...@qq.com> on 2021/01/13 09:10:31 UTC, 0 replies.
- flink1.12 k8s session部署，TM无法启动 - posted by 1120344670 <11...@qq.com> on 2021/01/13 09:17:30 UTC, 1 replies.
- Re: Flink-sql 读取hive报错,invalid type code: 9C. - posted by "spancer.ray" <37...@qq.com> on 2021/01/13 09:44:49 UTC, 0 replies.
- Re: Flink streaming sql是否支持两层group by聚合 - posted by Joshua Fan <jo...@gmail.com> on 2021/01/13 11:24:33 UTC, 1 replies.
- Flink sql的state ttl设置 - posted by 孙啸龙 <su...@126.com> on 2021/01/13 12:45:59 UTC, 0 replies.
- 回复：Flink sql的state ttl设置 - posted by 马阳阳 <ma...@163.com> on 2021/01/14 00:51:17 UTC, 0 replies.
- Flink webui 查询任务信息报错500 - posted by 赵一旦 <hi...@gmail.com> on 2021/01/14 03:38:01 UTC, 4 replies.
- flink1.9.2版本升级到1.12.0版本启动异常 - posted by guanyq <dl...@163.com> on 2021/01/14 06:08:13 UTC, 0 replies.
- Flink SQL支持createTemporaryView吗?谢谢 - posted by Appleyuchi <ap...@163.com> on 2021/01/14 07:12:09 UTC, 0 replies.
- Flink sql 状态过期后，checkpoint 大小没变化 - posted by 孙啸龙 <su...@126.com> on 2021/01/14 07:52:47 UTC, 5 replies.
- 回复： flink sql读kafka元数据问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2021/01/14 08:03:17 UTC, 5 replies.
- flink1.11使用createStatementSet报错 No operators defined in streaming topology - posted by datayangl <da...@gmail.com> on 2021/01/14 08:13:00 UTC, 1 replies.
- 转发：flink-sql字段类型问题 - posted by 郝文强 <18...@163.com> on 2021/01/14 09:24:46 UTC, 1 replies.
- 请教个Flink checkpoint的问题 - posted by "yinghua_zh@163.com" <yi...@163.com> on 2021/01/14 09:26:26 UTC, 8 replies.
- 回复：flink1.12 k8s session部署，TM无法启动 - posted by superainbower <su...@163.com> on 2021/01/14 09:41:44 UTC, 0 replies.
- 回复: 请教个Flink checkpoint的问题 - posted by "yinghua_zh@163.com" <yi...@163.com> on 2021/01/14 09:55:24 UTC, 3 replies.
- 回复: 回复: 请教个Flink checkpoint的问题 - posted by "yinghua_zh@163.com" <yi...@163.com> on 2021/01/14 10:02:59 UTC, 2 replies.
- Re: Re：flink-sql字段类型问题 - posted by "yinghua_zh@163.com" <yi...@163.com> on 2021/01/14 10:22:51 UTC, 1 replies.
- flinksql 消费kafka offset问题 - posted by air23 <wa...@163.com> on 2021/01/15 02:29:15 UTC, 3 replies.
- 回复: Re: 请教个Flink checkpoint的问题 - posted by "yinghua_zh@163.com" <yi...@163.com> on 2021/01/15 03:23:19 UTC, 0 replies.
- flink sql hop函数窗口时间前移问题 - posted by bigdata <11...@qq.com> on 2021/01/15 05:39:22 UTC, 1 replies.
- flink sql 消费kafka 消息写入Hive不提交分区 - posted by 花乞丐 <hu...@163.com> on 2021/01/15 07:19:30 UTC, 2 replies.
- flink监控 - posted by "penguin." <bx...@126.com> on 2021/01/15 09:06:12 UTC, 3 replies.
- flink滑动窗口输出结果的问题 - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2021/01/15 09:13:26 UTC, 6 replies.
- 回复： flink sql 消费kafka 消息写入Hive不提交分区 - posted by 刘小红 <18...@163.com> on 2021/01/15 11:14:01 UTC, 3 replies.
- 构建Flink任务提交平台时兼容低版本Flink的问题 - posted by Shengnan YU <ys...@hotmail.com> on 2021/01/16 00:14:56 UTC, 1 replies.
- Re: Re: sql-client 连接hive报错 TTransportException - posted by 赵一旦 <hi...@gmail.com> on 2021/01/16 05:24:19 UTC, 0 replies.
- flink怎么读kafka offset - posted by 黑色 <xi...@qq.com> on 2021/01/16 11:38:21 UTC, 0 replies.
- K8s HA Session模式下1.12.1 jobmanager 周期性 restart - posted by macdoor <ma...@gmail.com> on 2021/01/17 04:48:31 UTC, 9 replies.
- Re: flink1.12.0 HA on k8s native运行一段时间后jobmanager-leader产生大量ConfigMap问题 - posted by macdoor <ma...@gmail.com> on 2021/01/17 05:24:27 UTC, 1 replies.
- 回复：flink怎么读kafka offset - posted by 刘小红 <18...@163.com> on 2021/01/17 09:04:46 UTC, 2 replies.
- flink集群监控 - posted by "penguin." <bx...@126.com> on 2021/01/17 10:40:15 UTC, 0 replies.
- [Announce] Zeppelin 0.9.0 is released (Flink on Zeppelin) - posted by Jeff Zhang <zj...@gmail.com> on 2021/01/17 12:20:56 UTC, 0 replies.
- flink sql hop使用udaf问题 - posted by bigdata <11...@qq.com> on 2021/01/17 14:19:52 UTC, 1 replies.
- 回复: flink sql hop使用udaf问题 - posted by Evan <ch...@foxmail.com> on 2021/01/18 01:00:12 UTC, 0 replies.
- yarn Per-Job Cluster Mode提交任务时通过cli指定的内存参数无效 - posted by 刘海 <li...@163.com> on 2021/01/18 01:15:36 UTC, 0 replies.
- 回复：yarn Per-Job Cluster Mode提交任务时通过cli指定的内存参数无效 - posted by 刘海 <li...@163.com> on 2021/01/18 01:18:51 UTC, 0 replies.
- Re: yarn Per-Job Cluster Mode提交任务时通过cli指定的内存参数无效 - posted by Yangze Guo <ka...@gmail.com> on 2021/01/18 02:12:52 UTC, 1 replies.
- PROCTIME()函数语义问题 - posted by smailxie <sm...@163.com> on 2021/01/18 02:26:11 UTC, 0 replies.
- flink sql hop函数使用udaf问题 - posted by bigdata <11...@qq.com> on 2021/01/18 02:31:24 UTC, 0 replies.
- 回复： yarn Per-Job Cluster Mode提交任务时通过cli指定的内存参数无效 - posted by 刘海 <li...@163.com> on 2021/01/18 02:34:21 UTC, 2 replies.
- Re: Flink CEP 动态加载 pattern - posted by mokaful <64...@qq.com> on 2021/01/18 03:04:02 UTC, 0 replies.
- flink native k8s 有计划支持hostAlias配置码？ - posted by 高函 <ga...@163.com> on 2021/01/18 03:13:07 UTC, 1 replies.
- flink 设置broadcastStream 的MapStateDescriptor - posted by 明启孙 <37...@qq.com> on 2021/01/18 03:30:12 UTC, 1 replies.
- flink sql hop函数使用udaf，跟踪源码对merge方法进行参数校验时问题 - posted by bigdata <11...@qq.com> on 2021/01/18 04:02:49 UTC, 1 replies.
- 转发：flink 设置broadcastStream 的MapStateDescriptor - posted by smq <37...@qq.com> on 2021/01/18 04:17:53 UTC, 0 replies.
- 回复: flink sql hop函数使用udaf，跟踪源码对merge方法进行参数校验时问题 - posted by Evan <ch...@foxmail.com> on 2021/01/18 07:06:43 UTC, 0 replies.
- 回复：回复: flink sql hop函数使用udaf，跟踪源码对merge方法进行参数校验时问题 - posted by bigdata <11...@qq.com> on 2021/01/18 07:16:26 UTC, 0 replies.
- flink1.10.1 merge参数不支持scala的迭代器吗？这算是flink的bug吗 - posted by bigdata <11...@qq.com> on 2021/01/18 07:55:42 UTC, 0 replies.
- 回复：flink 设置broadcastStream 的MapStateDescriptor - posted by smq <37...@qq.com> on 2021/01/18 08:33:19 UTC, 0 replies.
- flinksql中如何写自定义的Table Aggregate Functions语句 - posted by jiangwan <ji...@foxmail.com> on 2021/01/18 09:07:05 UTC, 0 replies.
- Flink On Yarn部署模式下，提交Flink作业如何指定自定义log4j 配置 - posted by Bobby <10...@qq.com> on 2021/01/18 11:17:46 UTC, 5 replies.
- 获取flinksql返回的查询结果 - posted by 黑色 <xi...@qq.com> on 2021/01/18 12:42:29 UTC, 2 replies.
- 有做过提供实时大屏数据支持，需实现封装逻辑，读取excel中保存的多个规范好的sql语句（sql语句可达到50多个），通过Flink来执行读取到的多个sql语句，将计算的结果按照固定格式字段写入到MySQL中，有什么好的实现方案吗？ - posted by 18293503878 <18...@163.com> on 2021/01/19 03:04:05 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.12.1 released - posted by Xintong Song <xt...@apache.org> on 2021/01/19 03:53:20 UTC, 7 replies.
- flink sql任务提交，sql一直只执行一个 - posted by 花乞丐 <hu...@163.com> on 2021/01/19 04:01:07 UTC, 1 replies.
- Flink 1.11.3 PackagedProgram启动报错 - posted by xingoo <xi...@163.com> on 2021/01/19 06:01:58 UTC, 1 replies.
- Table proram cannot be compiled - posted by Asahi Lee <97...@qq.com> on 2021/01/19 06:17:09 UTC, 0 replies.
- 1.12.0版本启动异常 on yarn per job方式 - posted by guanyq <dl...@163.com> on 2021/01/19 07:30:41 UTC, 1 replies.
- flink offset自定义存储 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2021/01/19 07:38:57 UTC, 0 replies.
- Pyflink 提交 Batch 任务后报错 “Failed to execute sql” - posted by 岳坤 <ku...@qingping.co> on 2021/01/19 07:45:04 UTC, 1 replies.
- Flink SQL自定义source解析weblog获取数据的topic信息 - posted by gimlee <gi...@163.com> on 2021/01/19 07:58:36 UTC, 0 replies.
- Pyflink JVM Metaspace 内存泄漏定位 - posted by 岳坤 <ku...@qingping.co> on 2021/01/19 08:06:50 UTC, 10 replies.
- Flink 上报到pushgateway到数据量太大了 - posted by Tianwang Li <li...@gmail.com> on 2021/01/19 09:36:47 UTC, 1 replies.
- 答复: Re:Flink Jdbc sink写入多表如何实现 - posted by 范超 <fa...@mgtv.com> on 2021/01/19 09:59:54 UTC, 1 replies.
- 答复: Flink程序连接Kafka类型不匹配问题 - posted by 范超 <fa...@mgtv.com> on 2021/01/19 10:09:24 UTC, 0 replies.
- flink yarn application 提交任务出错 - posted by "casel.chen" <ca...@126.com> on 2021/01/19 10:19:29 UTC, 1 replies.
- 想实现over窗口每条记录生成多行结果怎么做？ - posted by jiangwan <ji...@foxmail.com> on 2021/01/19 11:01:33 UTC, 0 replies.
- flink sql作业监控问题 - posted by "casel.chen" <ca...@126.com> on 2021/01/19 15:15:50 UTC, 0 replies.
- flink作业版本管理实现方案 - posted by "casel.chen" <ca...@126.com> on 2021/01/19 15:20:13 UTC, 0 replies.
- flink作业版本管理实现方案探讨 - posted by "casel.chen" <ca...@126.com> on 2021/01/19 15:25:09 UTC, 4 replies.
- flink yarn application提交作业问题 - posted by "casel.chen" <ca...@126.com> on 2021/01/20 02:21:32 UTC, 2 replies.
- flinksql 将计算结果写入到hbase数据不一致 - posted by 刘海 <li...@163.com> on 2021/01/20 02:27:34 UTC, 0 replies.
- Flink 1.11 SQL可以支持kafka动态分区发现么？ - posted by sunfulin <su...@163.com> on 2021/01/20 06:40:29 UTC, 0 replies.
- 回复：Flink 1.11 SQL可以支持kafka动态分区发现么？ - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2021/01/20 06:42:36 UTC, 2 replies.
- yarn per模式如何配置rocksDB的本地目录localdir--v1.10.1 - posted by x <35...@qq.com> on 2021/01/20 07:07:59 UTC, 0 replies.
- 回复：yarn per模式如何配置rocksDB的本地目录localdir--v1.10.1 - posted by 耿延杰 <gy...@qq.com> on 2021/01/20 07:39:26 UTC, 1 replies.
- flink 写hive的并行度只能为1 - posted by 高函 <ga...@163.com> on 2021/01/20 08:29:03 UTC, 1 replies.
- flink 写hive decimal类型报错 - posted by "kandy.wang" <ka...@163.com> on 2021/01/20 08:39:10 UTC, 1 replies.
- Re: UDTAGG在SQL中可以使用么，语法是什么 - posted by jiangwan <ji...@foxmail.com> on 2021/01/20 08:57:22 UTC, 0 replies.
- flink1.12 on yarn per-job 运行问题 - posted by chaos <ji...@163.com> on 2021/01/20 09:29:35 UTC, 4 replies.
- Re: 回复：1.11.1 报OutOfMemoryError: Metaspace. 错误 - posted by YueKun <ku...@qingping.co> on 2021/01/20 10:15:33 UTC, 0 replies.
- 设置状态存储位置后，job运行起来后找不到状态数据 - posted by 刘海 <li...@163.com> on 2021/01/20 13:04:41 UTC, 1 replies.
- flink 1.12.0版本消费0.10版本kafka集群数据==>0.9版本kafka集群 - posted by guanyq <dl...@163.com> on 2021/01/21 02:15:59 UTC, 0 replies.
- yarn-per-job 模式 savepoint执行保存点报错 - posted by 刘海 <li...@163.com> on 2021/01/21 02:24:31 UTC, 1 replies.
- flink No operators defined in streaming topology. Cannot execute. 问题 - posted by HunterXHunter <13...@qq.com> on 2021/01/21 02:38:31 UTC, 0 replies.
- Flink SQL kafka connector有办法获取到partition、offset信息嘛？ - posted by gimlee <gi...@163.com> on 2021/01/21 03:20:57 UTC, 4 replies.
- Flink ddl sql 在 Test和在Main里面执行结果不同 - posted by HunterXHunter <13...@qq.com> on 2021/01/21 03:28:49 UTC, 0 replies.
- flink heartbeat timeout - posted by "guoxb__123@sina.com" <gu...@sina.com> on 2021/01/21 03:39:12 UTC, 1 replies.
- Re: [DISCUSS] Correct time-related function behavior in Flink SQL - posted by Kurt Young <yk...@gmail.com> on 2021/01/21 04:11:42 UTC, 1 replies.
- Re: yarn-per-job 模式 savepoint执行保存点报错 - posted by zhisheng <zh...@gmail.com> on 2021/01/21 05:15:28 UTC, 0 replies.
- flink整合hive问题 - posted by 赵一旦 <hi...@gmail.com> on 2021/01/21 05:52:20 UTC, 0 replies.
- flink sql 执行limit 很少的语句依然会暴增 - posted by zhang hao <zh...@gmail.com> on 2021/01/21 07:47:45 UTC, 5 replies.
- Flink与MySQL对接相关的问题 - posted by Land <la...@qq.com> on 2021/01/21 07:50:18 UTC, 1 replies.
- Application Mode部署作业到yarn,找不到.properties文件 - posted by lp <97...@qq.com> on 2021/01/21 08:07:58 UTC, 1 replies.
- flink sql升级到1.12 基于eventtime的window聚合没有watermark导致没有数据输出 - posted by Jie Wong <bi...@gmail.com> on 2021/01/21 08:29:11 UTC, 0 replies.
- Flink SQL建hive表为什么没有if not exists - posted by gimlee <gi...@163.com> on 2021/01/21 08:49:03 UTC, 0 replies.
- Flink写hdfs提交任务就报错。Recoverable writers on Hadoop are only supported for HDFS - posted by 赵一旦 <hi...@gmail.com> on 2021/01/21 09:17:14 UTC, 11 replies.
- 使用了流应用中使用了mysql jdbc的source，Execution处于FINISHED状态无法生成检查点 - posted by 刘海 <li...@163.com> on 2021/01/21 09:52:06 UTC, 0 replies.
- Re: 根据业务需求选择合适的flink state - posted by 张锴 <zk...@gmail.com> on 2021/01/21 10:24:41 UTC, 7 replies.
- flink sql是否有json_to_map函数，或者实现方法是怎么样的？ - posted by Jeff <zi...@126.com> on 2021/01/21 10:29:48 UTC, 4 replies.
- flink sink到kafka，报错Failed to construct kafka producer - posted by lp <97...@qq.com> on 2021/01/21 11:02:05 UTC, 0 replies.
- Re: [DISCUSS] Correct time-related function behavior in Flink SQL - posted by Leonard Xu <xb...@gmail.com> on 2021/01/21 14:32:35 UTC, 0 replies.
- [DISCUSS] FLIP-162: Consistent Flink SQL time function behavior - posted by Leonard Xu <xb...@gmail.com> on 2021/01/21 15:50:54 UTC, 0 replies.
- FlinkUserCodeClassLoader在session模式的集群下是如何卸载类的 - posted by Asahi Lee <97...@qq.com> on 2021/01/22 01:51:46 UTC, 1 replies.
- 回复：根据业务需求选择合适的flink state - posted by xuhaiLong <xi...@163.com> on 2021/01/22 02:00:16 UTC, 4 replies.
- Flink的StreamFileSink和1.12提供的FileSink中，BucketsBuilder的createBucketWriter中仅支持recoverableWriter。 - posted by 赵一旦 <hi...@gmail.com> on 2021/01/22 02:17:57 UTC, 1 replies.
- Flink SQL csv格式分隔符设置失败 - posted by gimlee <gi...@163.com> on 2021/01/22 02:47:32 UTC, 1 replies.
- Flink sql去重问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2021/01/22 02:53:48 UTC, 1 replies.
- 不同程序间checkpoint迁移 - posted by gimlee <gi...@163.com> on 2021/01/22 04:07:17 UTC, 1 replies.
- flink sink kafka from checkpoint run failed - posted by maokeluo <fa...@gmail.com> on 2021/01/22 05:58:27 UTC, 0 replies.
- flink消费kafka出现GC问题 - posted by nick <bd...@gmail.com> on 2021/01/22 06:18:51 UTC, 2 replies.
- 请教关于Flink yarnship的使用 - posted by Yan Tang <ya...@cisco.com.INVALID> on 2021/01/22 07:38:35 UTC, 3 replies.
- flink-Kafka 报错：ByteArraySerializer is not an instance of org.apache.kafka.common.serialization.Serializer - posted by lp <97...@qq.com> on 2021/01/22 08:14:17 UTC, 0 replies.
- Flink 并行度问题 - posted by Jacob <17...@163.com> on 2021/01/22 08:18:32 UTC, 9 replies.
- Exception in thread "main" java.lang.RuntimeException: Unknown call expression: avg(amount) - posted by Appleyuchi <ap...@163.com> on 2021/01/22 08:19:45 UTC, 0 replies.
- 回复：请教关于Flink yarnship的使用 - posted by 叶贤勋 <yx...@163.com> on 2021/01/22 18:03:28 UTC, 1 replies.
- 公司强行拆分Orders主表，遇到事实表join请各位大神们支个招。 - posted by 徐州州 <25...@qq.com> on 2021/01/23 02:48:20 UTC, 3 replies.
- 回复：公司强行拆分Orders主表，遇到事实表join请各位大神们支个招。 - posted by 徐州州 <25...@qq.com> on 2021/01/23 03:11:05 UTC, 2 replies.
- flink-sql-gateway支持远程吗 - posted by 罗显宴 <15...@163.com> on 2021/01/23 03:19:00 UTC, 4 replies.
- 求一个简单的示例，flink写orc格式文件，对于Map复杂类型的写法。 - posted by 赵一旦 <hi...@gmail.com> on 2021/01/23 05:48:55 UTC, 2 replies.
- Caused by: java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument(ZLjava/lang/String;Ljava/lang/Object;)V - posted by 董海峰（Sharp） <Sh...@aishu.cn> on 2021/01/23 07:40:22 UTC, 6 replies.
- Flink on yarn JDK 版本支持问题 - posted by Jacob <17...@163.com> on 2021/01/23 08:17:12 UTC, 1 replies.
- pyflink 1.12.1 没有 python 3.8 安装文件 - posted by macdoor <ma...@gmail.com> on 2021/01/23 15:22:25 UTC, 3 replies.
- FlinkSQL1.12查询hive表很快finished；No more splits available - posted by 赵一旦 <hi...@gmail.com> on 2021/01/23 19:49:39 UTC, 7 replies.
- FlinkSQL读取orc表，SQL提交就会导致JobManager进程报错并退出。 - posted by 赵一旦 <hi...@gmail.com> on 2021/01/23 23:34:10 UTC, 0 replies.
- Flink On Yarn部署模式下，yarn能否实现自定义日志聚合策略而不是作业结束后才聚合。 - posted by Bobby <10...@qq.com> on 2021/01/24 03:10:05 UTC, 0 replies.
- 对于 Flink 可撤回流做聚合，当上游数据撤回时，最终聚合值变小了，怎么解决这种问题。 - posted by LakeShen <sh...@gmail.com> on 2021/01/25 08:00:28 UTC, 2 replies.
- flink1.12用不了flink-sql-gateway - posted by jinsx <ji...@qq.com> on 2021/01/25 11:30:31 UTC, 0 replies.
- Re: python udf 提交到本地节点执行报错 - posted by 陈康 <84...@qq.com> on 2021/01/25 11:35:34 UTC, 1 replies.
- flink batch sql使用union all的并行度与-p参数不一致问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2021/01/25 12:28:27 UTC, 0 replies.
- Re: Streaming File Sink 不能生成 _SUCCESS 标记文件 - posted by Xavier <xa...@gmail.com> on 2021/01/25 13:36:34 UTC, 0 replies.
- Support - posted by Global Givers Foundation <no...@gcxasia.com.INVALID> on 2021/01/25 19:01:24 UTC, 0 replies.
- 关于1.12新增的initialize阶段时间较长问题 - posted by 赵一旦 <hi...@gmail.com> on 2021/01/26 02:51:28 UTC, 0 replies.
- 多流join的场景如何优化 - posted by "hl9902@126.com" <hl...@126.com> on 2021/01/26 03:30:56 UTC, 4 replies.
- flink-sql-gateway稳定性如何，可以在生产环境使用吗？ - posted by jinsx <ji...@qq.com> on 2021/01/26 03:37:46 UTC, 6 replies.
- 咨询关于flink究竟使用的是log4j1还是log4j2. - posted by 赵一旦 <hi...@gmail.com> on 2021/01/26 05:27:23 UTC, 2 replies.
- flink-sql-gateway相关问题 - posted by zilong xiao <ac...@gmail.com> on 2021/01/26 07:59:52 UTC, 6 replies.
- python udf求助: Process died with exit code 0 - posted by Appleyuchi <ap...@163.com> on 2021/01/26 09:50:52 UTC, 0 replies.
- flink启动任务时异常，加载不到flink/lib目录下的包 - posted by yujianbo <15...@163.com> on 2021/01/26 11:06:53 UTC, 1 replies.
- [DISCUSS] Removal of flink-swift-fs-hadoop module - posted by Robert Metzger <rm...@apache.org> on 2021/01/26 13:11:15 UTC, 0 replies.
- TaggedOperatorSubtaskState is missing when creating a new savepoint using state processor api - posted by 郭斌 <18...@163.com> on 2021/01/27 02:42:07 UTC, 0 replies.
- Flink sql 1.12写入hive报metastore失败 - posted by gimlee <gi...@163.com> on 2021/01/27 02:46:55 UTC, 1 replies.
- Flink 1.10 table setIdleStateRetentionTime - posted by xuhaiLong <xi...@163.com> on 2021/01/27 03:39:21 UTC, 0 replies.
- Re: Flink 1.10 table setIdleStateRetentionTime - posted by xuhaiLong <xi...@163.com> on 2021/01/27 04:00:07 UTC, 0 replies.
- 用application mode部署应用，classloader.resolve-order参数是否必须要改为parent-first？ - posted by lp <97...@qq.com> on 2021/01/27 04:39:13 UTC, 3 replies.
- Scala REPL YARN 运行模式报 NoSuchMethodError setPrintSpaceAfterFullCompletion - posted by macia kk <pr...@gmail.com> on 2021/01/27 06:39:22 UTC, 0 replies.
- flink-sql-gateway如何使用flink自定义的udf - posted by 阿华田 <a1...@163.com> on 2021/01/27 07:25:41 UTC, 2 replies.
- pyflink 1.11 connector数据读取问题 - posted by 肖越 <18...@163.com> on 2021/01/27 07:29:05 UTC, 0 replies.
- 回复：pyflink 1.11 connector数据读取问题 - posted by 12862930 <xi...@qq.com> on 2021/01/27 07:35:04 UTC, 0 replies.
- 回复：退订 - posted by Roc Marshal <fl...@126.com> on 2021/01/27 08:44:38 UTC, 0 replies.
- 文档问题 - posted by xi...@163.com, xi...@163.com on 2021/01/27 08:54:23 UTC, 1 replies.
- flink-1.12.1 k8s Session集群模式没有生成Stdout输出文件 - posted by Tianwang Li <li...@gmail.com> on 2021/01/27 09:38:00 UTC, 1 replies.
- pyflink1.11 table.to_pandas() 报错 'Sort on a non-time-attribute field is not supported.' - posted by 肖越 <18...@163.com> on 2021/01/27 09:43:42 UTC, 0 replies.
- sql编译代码时超过64kb导致编译失败 - posted by stgztsw <st...@126.com> on 2021/01/27 10:10:37 UTC, 2 replies.
- flink sql 处理自定义watermark - posted by 花乞丐 <hu...@163.com> on 2021/01/27 10:32:14 UTC, 0 replies.
- Flink-1.11 消费Kafka 写 Hive，消费堆积问题 - posted by nashcen <24...@qq.com> on 2021/01/27 12:19:04 UTC, 0 replies.
- Re: pyflink1.11 table.to_pandas() 报错 'Sort on a non-time-attribute field is not supported.' - posted by Xingbo Huang <hx...@gmail.com> on 2021/01/27 12:59:51 UTC, 0 replies.
- 我的Flink SQL 任务跑了一天5个小时就挂了，报这个错，是啥原因呢 - posted by nick <bd...@gmail.com> on 2021/01/28 01:43:35 UTC, 0 replies.
- Catalog(Kafka Connectors 的ddl)持久化到hive metastore，groupid一样的问题 - posted by 孙啸龙 <su...@126.com> on 2021/01/28 03:17:14 UTC, 1 replies.
- over window丢数据 - posted by Appleyuchi <ap...@163.com> on 2021/01/28 03:42:08 UTC, 1 replies.
- 咨询一下 LEFT JOIN 产生 DELETE 消息的疑惑 - posted by "DONG, Weike" <ky...@connect.hku.hk> on 2021/01/28 04:12:20 UTC, 0 replies.
- Flink 读 Hive 表，如何设置 TTL - posted by macia kk <pr...@gmail.com> on 2021/01/28 04:24:53 UTC, 0 replies.
- kafka 所有分区无数据的情况下，导致watermark无法前进 - posted by 林影 <br...@gmail.com> on 2021/01/28 04:28:21 UTC, 8 replies.
- flink-1.12 通过-t指定模式后无法指定yarn参数 - posted by Yapor <17...@163.com> on 2021/01/28 06:07:30 UTC, 2 replies.
- 关于端到端的延迟监控 - posted by 13051111332 <13...@163.com> on 2021/01/28 06:09:53 UTC, 4 replies.
- 回复： kafka 所有分区无数据的情况下，导致watermark无法前进 - posted by 刘小红 <18...@163.com> on 2021/01/28 07:01:15 UTC, 0 replies.
- 关于Flink程序既有流又有SQL，提交任务到yarn之后没有水印生成 - posted by 花乞丐 <hu...@163.com> on 2021/01/28 07:18:44 UTC, 0 replies.
- Flink1.12 批处理模式，分词统计时单词个数为1的单词不会被打印 - posted by xhyan0427 <15...@163.com> on 2021/01/28 08:31:30 UTC, 1 replies.
- key group from xx to yy does not contain zz异常 - posted by restart <ne...@outlook.com> on 2021/01/28 09:54:23 UTC, 2 replies.
- 检查点成功，但从检查点恢复失败。使用了guava的bloomFilter，有人帮忙分析下吗？ - posted by 赵一旦 <hi...@gmail.com> on 2021/01/28 10:03:00 UTC, 2 replies.
- 回复：关于端到端的延迟监控 - posted by 13051111332 <13...@163.com> on 2021/01/28 10:03:16 UTC, 0 replies.
- 关于flink-shaded-xxx的问题 - posted by 赵一旦 <hi...@gmail.com> on 2021/01/28 11:19:36 UTC, 0 replies.
- 为什么window的reduceFunction不支持RichFunction呢 - posted by 赵一旦 <hi...@gmail.com> on 2021/01/28 12:26:23 UTC, 5 replies.
- 使用DataStream API + HBaseRowInputFormat读取HBase时表时，Row arity of from (2) does not match this serializers field length (1) - posted by automths <au...@163.com> on 2021/01/28 12:27:46 UTC, 1 replies.
- 自定义表函数需定义啥参数来接受 flink sql 内置函数COLLECT(DISTINCT t.tag_id) 结果？ - posted by jindy_liu <28...@qq.com> on 2021/01/28 12:54:36 UTC, 0 replies.
- 怎么理解 tolerableCheckpointFailureNumber - posted by jiangjiguang719 <ji...@163.com> on 2021/01/29 01:35:49 UTC, 1 replies.
- Hi?? - posted by Ayesha Johnson <at...@gmail.com> on 2021/01/29 03:21:12 UTC, 0 replies.
- reduce函数的trigger问题 - posted by "xiaolailong@163.com" <xi...@163.com> on 2021/01/29 03:27:16 UTC, 2 replies.
- 回复：为什么window的reduceFunction不支持RichFunction呢 - posted by cs <58...@qq.com> on 2021/01/29 03:35:30 UTC, 0 replies.
- 关于Flink作业的负载监控 task-load指标 - posted by 13051111332 <13...@163.com> on 2021/01/29 03:59:38 UTC, 2 replies.
- 提交job的命令，./bin/flink run-application -t yarn-application ... 和 ./bin/flink run -m yarn-cluster ... - posted by lp <97...@qq.com> on 2021/01/29 04:52:41 UTC, 2 replies.
- 回复：关于Flink作业的负载监控 task-load指标 - posted by 13051111332 <13...@163.com> on 2021/01/29 05:19:59 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.10.3 released - posted by Xintong Song <xt...@apache.org> on 2021/01/29 07:05:10 UTC, 4 replies.
- 未生成水位线 - posted by 沉醉寒風 <10...@qq.com> on 2021/01/29 08:54:25 UTC, 1 replies.
- Re: 提交job的命令，./bin/flink run-application -t yarn-application ... 和 ./bin/flink run -m yarn-cluster ... - posted by Yang Wang <da...@gmail.com> on 2021/01/29 08:57:41 UTC, 0 replies.
- 回复：未生成水位线 - posted by 沉醉寒風 <10...@qq.com> on 2021/01/29 09:41:41 UTC, 0 replies.
- FOR SYSTEM_TIME AS OF 维表关联报错 - posted by 阿华田 <a1...@163.com> on 2021/01/29 12:23:11 UTC, 0 replies.
- Re: Flink 1.11 job hit error "Job leader lost leadership" or "ResourceManager leader changed to new address null" - posted by Xintong Song <to...@gmail.com> on 2021/01/30 00:27:29 UTC, 0 replies.
- 请问pyflink如何跟kerberos认证的kafka对接呢 - posted by 瞿叶奇 <38...@qq.com> on 2021/01/30 05:58:56 UTC, 0 replies.
- 咨询求助 - posted by 瞿叶奇 <38...@qq.com> on 2021/01/30 06:00:03 UTC, 2 replies.
- 问题求助（Pyflink） - posted by 瞿叶奇 <38...@qq.com> on 2021/01/30 06:25:57 UTC, 4 replies.
- 回复：问题求助（Pyflink） - posted by 瞿叶奇 <38...@qq.com> on 2021/01/30 07:14:18 UTC, 0 replies.
- 求一份可以编译flink源码的settings.xml文件 - posted by 徐州州 <25...@qq.com> on 2021/01/30 08:38:54 UTC, 1 replies.
- Pyflink对接kerberos认证的Kafka的问题求助 - posted by 瞿叶奇 <38...@qq.com> on 2021/01/30 09:53:00 UTC, 1 replies.
- 是否可以 hive 流 join hive 流？ - posted by macdoor <ma...@gmail.com> on 2021/01/30 09:54:37 UTC, 0 replies.
- 回复: Pyflink对接kerberos认证的Kafka的问题求助 - posted by Evan <ch...@foxmail.com> on 2021/01/30 09:58:11 UTC, 0 replies.
- pyflink gives the error message "Could not find a'KafkaClient' entry in the JAAS configuration. System property'java.security.auth.login.config' is not set" - posted by 瞿叶奇 <38...@qq.com> on 2021/01/30 10:08:00 UTC, 0 replies.
- PyFlink Expected IPC message of type schema but got record batch - posted by 苗红宾 <ho...@126.com> on 2021/01/31 07:27:44 UTC, 0 replies.
- 请教 flink 1.12.1 插入 mysql 有时耗时很长 - posted by macdoor <ma...@gmail.com> on 2021/01/31 09:39:41 UTC, 2 replies.