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

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

- Flink Training - why cannot keyBy hour? - posted by Eleanore Jin <el...@gmail.com> on 2020/07/01 00:25:39 UTC, 1 replies.
- 回复：【Flink的transformations】 - posted by 17626017841 <17...@163.com> on 2020/07/01 02:53:22 UTC, 0 replies.
- flink sql if 函数使用问题 - posted by kcz <57...@qq.com> on 2020/07/01 03:02:53 UTC, 0 replies.
- Re: 作业因为异常restart后，频繁OOM - posted by 徐骁 <ff...@gmail.com> on 2020/07/01 03:15:31 UTC, 1 replies.
- 回复：作业因为异常restart后，频繁OOM - posted by kcz <57...@qq.com> on 2020/07/01 03:32:48 UTC, 0 replies.
- 回复：作业因为异常restart后，频繁OOM - posted by SmileSmile <a5...@163.com> on 2020/07/01 04:49:13 UTC, 0 replies.
- Re: flink sql if 函数使用问题 - posted by Benchao Li <li...@apache.org> on 2020/07/01 05:15:15 UTC, 0 replies.
- Re: 关于flink sql问题 - posted by Benchao Li <li...@apache.org> on 2020/07/01 05:22:06 UTC, 1 replies.
- flink1.10 用flinksql 写hbase，报错：UpsertStreamTableSink requires that Table has a full primary keys if it is updated. - posted by "tiantingting5435@163.com" <ti...@163.com> on 2020/07/01 05:51:14 UTC, 1 replies.
- 回复： flink sql if 函数使用问题 - posted by kcz <57...@qq.com> on 2020/07/01 05:57:36 UTC, 0 replies.
- Re: 关于local cluster的问题 - posted by Yang Wang <da...@gmail.com> on 2020/07/01 06:19:24 UTC, 0 replies.
- flink sql ddl CREATE TABLE kafka011 sink 如何开启事务exactly-once？ - posted by 静谧雨寒 <fr...@vip.qq.com> on 2020/07/01 06:33:28 UTC, 0 replies.
- 回复：flink sql ddl CREATE TABLE kafka011 sink 如何开启事务exactly-once？ - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/01 07:13:21 UTC, 0 replies.
- Re: flink sql ddl CREATE TABLE kafka011 sink 如何开启事务exactly-once？ - posted by 方盛凯 <fs...@gmail.com> on 2020/07/01 07:31:15 UTC, 0 replies.
- 回复： flink sql ddl CREATE TABLE kafka011 sink 如何开启事务exactly-once？ - posted by 静谧雨寒 <fr...@vip.qq.com> on 2020/07/01 07:41:12 UTC, 0 replies.
- 来自boss_大数据开发_史文龙的邮件 - posted by boss_大数据开发_史文龙 <ia...@163.com> on 2020/07/01 09:35:56 UTC, 1 replies.
- flink基于yarn的HA次数无效，以及HA拉起的任务是否可以重用state - posted by MuChen <93...@qq.com> on 2020/07/01 11:50:14 UTC, 2 replies.
- flink1.10 checkpoint 运行一段时间空指针异常 - posted by 程龙 <13...@163.com> on 2020/07/01 12:43:20 UTC, 0 replies.
- 回复：flink1.10 checkpoint 运行一段时间空指针异常 - posted by JasonLee <17...@163.com> on 2020/07/01 12:51:34 UTC, 11 replies.
- 回复： flink基于yarn的HA次数无效，以及HA拉起的任务是否可以重用state - posted by MuChen <93...@qq.com> on 2020/07/01 14:45:52 UTC, 2 replies.
- UDTAGGs sql的查询怎么写 - posted by liangji <ji...@gmail.com> on 2020/07/02 03:10:24 UTC, 2 replies.
- flink的state过期设置 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/07/02 03:17:04 UTC, 1 replies.
- 回复：关于flink sql问题 - posted by zya <z_...@foxmail.com> on 2020/07/02 03:30:18 UTC, 0 replies.
- flink任务提交方式 - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/02 04:09:05 UTC, 3 replies.
- 在一个 flink operator 中怎样根据消息内容动态生成多个监控指标？ - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/02 07:34:29 UTC, 1 replies.
- flink asynctablefunction调用异常 - posted by sunfulin <su...@163.com> on 2020/07/02 07:56:46 UTC, 3 replies.
- 回复：在一个 flink operator 中怎样根据消息内容动态生成多个监控指标？ - posted by JasonLee <17...@163.com> on 2020/07/02 08:16:39 UTC, 4 replies.
- 回复: 回复：在一个 flink operator 中怎样根据消息内容动态生成多个监控指标？ - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/02 08:39:02 UTC, 0 replies.
- Position out of bounds. - posted by xuhaiLong <xi...@163.com> on 2020/07/02 09:46:26 UTC, 1 replies.
- rocksdb的block cache usage应该如何使用 - posted by SmileSmile <a5...@163.com> on 2020/07/02 10:05:27 UTC, 1 replies.
- table execution-options 能否通过 -yd 生效 - posted by liangji <ji...@gmail.com> on 2020/07/02 10:12:28 UTC, 4 replies.
- 回复：Position out of bounds. - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/02 10:39:35 UTC, 2 replies.
- 做实时数仓，sql怎么保证分topic区有序 - posted by air23 <wa...@163.com> on 2020/07/02 10:39:59 UTC, 3 replies.
- Flink job不定期就会重启，版本是1.9 - posted by noon cjihg <cc...@gmail.com> on 2020/07/03 02:48:20 UTC, 2 replies.
- flink对task分配slot问题 - posted by "liuhy_email@163.com" <li...@163.com> on 2020/07/03 03:11:56 UTC, 2 replies.
- 在没有开启Checkpoint的情况下，当作业重启时，历史数据是否会残留在内存中？ - posted by SmileSmile <a5...@163.com> on 2020/07/03 03:21:54 UTC, 0 replies.
- 回复：在没有开启Checkpoint的情况下，当作业重启时，历史数据是否会残留在内存中？ - posted by SmileSmile <a5...@163.com> on 2020/07/03 04:22:46 UTC, 1 replies.
- kafkaf To mysql 写入问题 - posted by 郑斌斌 <zh...@heint.cn> on 2020/07/03 05:38:10 UTC, 1 replies.
- 如何在窗口关闭的时候清除状态 - posted by "18579099920@163.com" <18...@163.com> on 2020/07/03 06:02:11 UTC, 4 replies.
- Re: 在没有开启Checkpoint的情况下，当作业重启时，历史数据是否会残留在内存中？ - posted by Congxian Qiu <qc...@gmail.com> on 2020/07/03 06:02:36 UTC, 1 replies.
- 回复：rocksdb的block cache usage应该如何使用 - posted by SmileSmile <a5...@163.com> on 2020/07/03 06:20:15 UTC, 8 replies.
- 回复: Re: flink1.10 用flinksql 写hbase，报错：UpsertStreamTableSink requires that Table has a full primary keys if it is updated. - posted by "tiantingting5435@163.com" <ti...@163.com> on 2020/07/03 06:42:03 UTC, 0 replies.
- 回复：kafkaf To mysql 写入问题 - posted by 郑斌斌 <zh...@heint.cn> on 2020/07/03 06:56:03 UTC, 0 replies.
- flink 1.9 中 StreamTableEnvironment 注册 registerDataStream处理嵌套别名 - posted by Jun Zou <ni...@gmail.com> on 2020/07/03 07:43:22 UTC, 0 replies.
- flink 1.10 kafka collector topic 配置pattern - posted by Peihui He <pe...@gmail.com> on 2020/07/03 08:02:17 UTC, 3 replies.
- 回复：求助：FLINKSQL1.10实时统计累计UV - posted by x <35...@qq.com> on 2020/07/03 08:34:12 UTC, 6 replies.
- Flink sql 主动使数据延时一段时间有什么方案 - posted by admin <17...@163.com> on 2020/07/03 09:53:43 UTC, 6 replies.
- 回复：Flink sql 主动使数据延时一段时间有什么方案 - posted by kcz <57...@qq.com> on 2020/07/03 11:11:37 UTC, 1 replies.
- flink1.9自定义实现source的问题 - posted by guanyq <dl...@163.com> on 2020/07/03 13:00:31 UTC, 0 replies.
- Re: 求助：FLINKSQL1.10实时统计累计UV - posted by Benchao Li <li...@apache.org> on 2020/07/03 13:47:51 UTC, 2 replies.
- flink1.9读取阿里Mq问题 - posted by guanyq <dl...@163.com> on 2020/07/03 15:44:09 UTC, 1 replies.
- 回复： Flink sql 主动使数据延时一段时间有什么方案 - posted by "Sun.Zhu" <17...@163.com> on 2020/07/03 16:22:55 UTC, 0 replies.
- 回复：flink1.9读取阿里Mq问题 - posted by 李军 <ho...@163.com> on 2020/07/04 04:12:38 UTC, 0 replies.
- 回复：如何在窗口关闭的时候清除状态 - posted by JasonLee <17...@163.com> on 2020/07/04 12:29:01 UTC, 0 replies.
- Re: flink interval join后按窗口聚组问题 - posted by Benchao Li <li...@apache.org> on 2020/07/05 03:58:54 UTC, 1 replies.
- Re: Re: 为什么 flink checkpoint Checkpoint Duration (Async) 阶段耗时很慢 - posted by Congxian Qiu <qc...@gmail.com> on 2020/07/05 04:09:13 UTC, 0 replies.
- Re: flink1.9 on yarn 运行二个多月之后出现错误 - posted by Congxian Qiu <qc...@gmail.com> on 2020/07/05 04:12:58 UTC, 0 replies.
- 【Flink Join内存问题】 - posted by 忝忝向仧 <15...@qq.com> on 2020/07/05 07:50:05 UTC, 2 replies.
- 回复： flink interval join后按窗口聚组问题 - posted by "元始(Bob Hu)" <65...@qq.com> on 2020/07/05 12:48:31 UTC, 0 replies.
- 【Flink的shuffle mode】 - posted by 忝忝向仧 <15...@qq.com> on 2020/07/05 14:47:40 UTC, 2 replies.
- 答复: 回复：flink1.10 checkpoint 运行一段时间空指针异常 - posted by 陈凯 <ch...@qianxin.com> on 2020/07/06 01:53:15 UTC, 0 replies.
- flink1.10在通过TableFunction实现行转列时，Row一直是空 - posted by Jim Chen <ch...@gmail.com> on 2020/07/06 02:19:11 UTC, 2 replies.
- flink 1.11 作业执行异常 - posted by sunfulin <su...@163.com> on 2020/07/06 03:00:07 UTC, 11 replies.
- flink1.10 定义表时，把json数组声明成STRING类型的，查询出来是空 - posted by Jim Chen <ch...@gmail.com> on 2020/07/06 03:28:21 UTC, 1 replies.
- flink sql子查询状态清理不掉 - posted by op <52...@qq.com> on 2020/07/06 03:31:15 UTC, 1 replies.
- 回复：【Flink的shuffle mode】 - posted by 忝忝向仧 <15...@qq.com> on 2020/07/06 04:16:36 UTC, 3 replies.
- 滑动窗口数据存储多份问题 - posted by 张浩 <13...@163.com> on 2020/07/06 04:48:52 UTC, 6 replies.
- flink cep result DataStream no data print - posted by Zhou Zach <is...@foxmail.com> on 2020/07/06 05:11:45 UTC, 0 replies.
- 回复：如何在窗口关闭的时候清除状态 - posted by kcz <57...@qq.com> on 2020/07/06 06:15:14 UTC, 0 replies.
- Flink状态调试 - posted by Z-Z <zz...@qq.com> on 2020/07/06 08:59:35 UTC, 3 replies.
- Flink SQL 关键字 user？ - posted by 王 outlook <de...@outlook.com> on 2020/07/06 09:06:47 UTC, 2 replies.
- jemalloc dump 内存 - posted by SmileSmile <a5...@163.com> on 2020/07/06 09:36:50 UTC, 0 replies.
- Flink从SavePoint启动任务，修改的代码不生效 - posted by milan183sansiro <mi...@126.com> on 2020/07/06 11:55:13 UTC, 1 replies.
- 关于jdbc connector扩展问题 - posted by claylin <10...@qq.com> on 2020/07/06 12:10:36 UTC, 1 replies.
- 回复：Flink从SavePoint启动任务，修改的代码不生效 - posted by wujunxi <46...@qq.com> on 2020/07/06 12:32:38 UTC, 1 replies.
- Flink SQL复杂JSON解析 - posted by 王 outlook <de...@outlook.com> on 2020/07/06 13:28:55 UTC, 3 replies.
- flink 1.10.1 入 hive 格式为parquet - posted by lydata <ly...@163.com> on 2020/07/07 02:05:38 UTC, 1 replies.
- 作业从flink1.9.0迁移到1.10.1，LogicalTypeRoot变更后无法从CP恢复：No enum constant org.apache.flink.table.types.logical.LogicalTypeRoot.ANY - posted by 吴磊 <wu...@foxmail.com> on 2020/07/07 02:25:25 UTC, 2 replies.
- FlinkWebUI 参数疑问 - posted by "liuhy_email@163.com" <li...@163.com> on 2020/07/07 03:45:18 UTC, 0 replies.
- DataStream的state问题 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/07/07 04:14:57 UTC, 1 replies.
- flink sql 读写写kafka表的时候可以指定消息的key吗 - posted by op <52...@qq.com> on 2020/07/07 09:01:28 UTC, 2 replies.
- flink kafka connector中获取kafka元数据 - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/07 09:12:41 UTC, 6 replies.
- 回复： flink sql 读写写kafka表的时候可以指定消息的key吗 - posted by op <52...@qq.com> on 2020/07/07 09:16:55 UTC, 0 replies.
- 一个source多个sink的同步问题 - posted by lgs <99...@qq.com> on 2020/07/07 09:20:00 UTC, 2 replies.
- 如何在Flink SQL中使用周期性水印? - posted by noake <no...@sina.cn> on 2020/07/07 09:25:45 UTC, 4 replies.
- 嵌套 json 中string 数组的解析异常 - posted by Jun Zou <ni...@gmail.com> on 2020/07/07 09:37:59 UTC, 4 replies.
- 回复： Flink从SavePoint启动任务，修改的代码不生效 - posted by milan183sansiro <mi...@126.com> on 2020/07/07 10:35:33 UTC, 0 replies.
- Flink 1.11 SQL作业中调用UDTF 出现“No match found for function signature ”异常 - posted by 邹云鹤 <ke...@163.com> on 2020/07/07 13:43:32 UTC, 1 replies.
- Flink DataStream 统计UV问题 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/07/07 14:27:35 UTC, 2 replies.
- DataStream统计uv问题 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/07/07 14:32:51 UTC, 1 replies.
- 回复：【Flink的shuffle mode】 - posted by 忝忝向仧 <15...@qq.com> on 2020/07/07 15:35:12 UTC, 0 replies.
- 回复：Flink 1.11 SQL作业中调用UDTF 出现“No match found for function signature ”异常 - posted by 邹云鹤 <ke...@163.com> on 2020/07/07 15:44:03 UTC, 0 replies.
- flink 1.11 connector jdbc 依赖解析失败 - posted by Zhou Zach <wa...@163.com> on 2020/07/08 00:15:44 UTC, 2 replies.
- Re: [Third-party Tool] Flink memory calculator - posted by Yangze Guo <ka...@gmail.com> on 2020/07/08 02:18:36 UTC, 0 replies.
- flink 1.11 中cdc功能中，使用flink sql来操作一个kafka topic中的多张表，并保证有序？ - posted by jindy_liu <28...@qq.com> on 2020/07/08 02:30:46 UTC, 8 replies.
- State里面用guava Cache - posted by op <52...@qq.com> on 2020/07/08 02:30:52 UTC, 4 replies.
- FlinkKafkaProducer没有写入多个topic的功能 - posted by "18579099920@163.com" <18...@163.com> on 2020/07/08 02:59:06 UTC, 1 replies.
- Flink Hadoop依赖 - posted by Z-Z <zz...@qq.com> on 2020/07/08 02:59:20 UTC, 1 replies.
- 回复：FlinkKafkaProducer没有写入多个topic的功能 - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/08 03:04:40 UTC, 1 replies.
- 回复：如何在Flink SQL中使用周期性水印? - posted by 1193216154 <11...@qq.com> on 2020/07/08 03:08:08 UTC, 2 replies.
- 作业升级到flink1.11，idea运行失败 - posted by SmileSmile <a5...@163.com> on 2020/07/08 03:27:02 UTC, 1 replies.
- 回复：作业升级到flink1.11，idea运行失败 - posted by SmileSmile <a5...@163.com> on 2020/07/08 04:36:04 UTC, 0 replies.
- flink 1.11 on kubernetes 构建失败 - posted by SmileSmile <a5...@163.com> on 2020/07/08 05:03:16 UTC, 1 replies.
- flink Sql 1.11 executeSql报No operators defined in streaming topology - posted by Zhou Zach <wa...@163.com> on 2020/07/08 07:29:50 UTC, 0 replies.
- 回复：flink Sql 1.11 executeSql报No operators defined in streaming topology - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/08 07:40:41 UTC, 9 replies.
- flink state使用 - posted by "Robert.Zhang" <17...@qq.com> on 2020/07/08 07:41:01 UTC, 2 replies.
- 回复： State里面用guava Cache - posted by op <52...@qq.com> on 2020/07/08 07:52:45 UTC, 4 replies.
- 回复： flink state使用 - posted by "Robert.Zhang" <17...@qq.com> on 2020/07/08 07:58:40 UTC, 0 replies.
- 回复：flink 1.11 on kubernetes 构建失败 - posted by SmileSmile <a5...@163.com> on 2020/07/08 08:38:25 UTC, 1 replies.
- 回复：Re: 回复：flink Sql 1.11 executeSql报No operators defined in streaming topology - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/08 09:23:18 UTC, 0 replies.
- 关于 richfunction中初始化数据库连接的问题 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/07/08 10:32:18 UTC, 0 replies.
- 回复：关于 richfunction中初始化数据库连接的问题 - posted by Yichao Yang <10...@qq.com> on 2020/07/08 10:36:56 UTC, 1 replies.
- 回复: Flink SQL复杂JSON解析 - posted by hua mulan <de...@outlook.com> on 2020/07/08 12:23:54 UTC, 1 replies.
- Flink SQL如何将多个表的查询结果(列不同)聚合成一张表 - posted by zilong xiao <ac...@gmail.com> on 2020/07/08 12:54:58 UTC, 1 replies.
- flink-state问题 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/07/08 15:29:25 UTC, 1 replies.
- 回复：一个source多个sink的同步问题 - posted by "Sun.Zhu" <17...@163.com> on 2020/07/08 16:45:32 UTC, 0 replies.
- 代码中如何取消正在运行的Flink Streaming作业 - posted by Evan <ch...@foxmail.com> on 2020/07/09 01:38:01 UTC, 5 replies.
- 回复： Flink SQL如何将多个表的查询结果(列不同)聚合成一张表 - posted by cs <58...@qq.com> on 2020/07/09 01:48:15 UTC, 0 replies.
- 回复： DataStream统计uv问题 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/07/09 02:15:48 UTC, 1 replies.
- 回复：回复： DataStream统计uv问题 - posted by 1193216154 <11...@qq.com> on 2020/07/09 02:25:29 UTC, 1 replies.
- Re: Re: Flink 多Sink 数据一致性保证 - posted by jindy_liu <28...@qq.com> on 2020/07/09 02:55:35 UTC, 3 replies.
- kafka connector问题 - posted by op <52...@qq.com> on 2020/07/09 03:25:27 UTC, 1 replies.
- 回复: 回复：关于 richfunction中初始化数据库连接的问题 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/07/09 03:31:54 UTC, 0 replies.
- flink时间窗口 - posted by 爱吃鱼 <ai...@163.com> on 2020/07/09 03:37:18 UTC, 1 replies.
- 回复：kafka connector问题 - posted by lu...@126.com, lu...@126.com on 2020/07/09 04:45:50 UTC, 0 replies.
- 回复：flink时间窗口 - posted by Yichao Yang <10...@qq.com> on 2020/07/09 05:09:32 UTC, 3 replies.
- 回复：回复：关于 richfunction中初始化数据库连接的问题 - posted by Yichao Yang <10...@qq.com> on 2020/07/09 05:11:36 UTC, 0 replies.
- 回复：DataStream统计uv问题 - posted by Yichao Yang <10...@qq.com> on 2020/07/09 06:18:19 UTC, 0 replies.
- 回复：ddl es 报错 - posted by Evan <ch...@foxmail.com> on 2020/07/09 07:32:29 UTC, 0 replies.
- flink 双流join报错，java.lang.AssertionError - posted by sunfulin <su...@163.com> on 2020/07/09 08:53:34 UTC, 3 replies.
- flink 提交 offset 到 kafka - posted by liangji <ji...@gmail.com> on 2020/07/09 08:54:19 UTC, 0 replies.
- pyflink udf中发送rest api会导致udf被调用两次 - posted by lgs <99...@qq.com> on 2020/07/09 09:50:11 UTC, 9 replies.
- flink1.10.1在yarn上无法写入kafka的问题 - posted by "maqi@sinoiov.com" <ma...@sinoiov.com> on 2020/07/09 11:57:22 UTC, 7 replies.
- Re: flink 1.11 on kubernetes 构建失败 - posted by Yang Wang <da...@gmail.com> on 2020/07/09 12:02:03 UTC, 3 replies.
- flink1.10升级到flink1.11 提交到yarn失败 - posted by Zhou Zach <wa...@163.com> on 2020/07/09 13:23:07 UTC, 6 replies.
- 转发：pyflink1.11.0window - posted by 奇怪的不朽琴师 <11...@qq.com> on 2020/07/10 00:43:31 UTC, 0 replies.
- flink 1.11 使用sql写入hdfs无法自动提交分区 - posted by Jun Zhang <zh...@gmail.com> on 2020/07/10 01:07:23 UTC, 9 replies.
- flink 1.10 sql kafka format json 定制schema时, 一个字段的数据可以定义为类似json object不？ - posted by Peihui He <pe...@gmail.com> on 2020/07/10 01:12:25 UTC, 10 replies.
- Re: pyflink1.11.0window - posted by Shuiqiang Chen <ac...@gmail.com> on 2020/07/10 01:17:19 UTC, 4 replies.
- 回复：flink 1.11 on kubernetes 构建失败 - posted by SmileSmile <a5...@163.com> on 2020/07/10 02:42:23 UTC, 3 replies.
- flink 写入es失败导致数据丢失 - posted by sunfulin <su...@163.com> on 2020/07/10 02:51:07 UTC, 7 replies.
- Flink自定义Source 抽取Mysql多张表,并行抽取可以实现吗? - posted by "xiaozhennan1995@gmail.com" <xi...@gmail.com> on 2020/07/10 06:27:51 UTC, 0 replies.
- 退订 - posted by "liugh@teld.cn" <li...@teld.cn> on 2020/07/10 06:33:43 UTC, 15 replies.
- 单流的一条数据，需要先sink 至mysql，再sink至kafka，并保证两sink的原子性以及sink顺序，是否可以做到？ - posted by jindy_liu <28...@qq.com> on 2020/07/10 07:48:37 UTC, 5 replies.
- flink-benchmarks使用求助 - posted by zilong xiao <ac...@gmail.com> on 2020/07/10 07:54:30 UTC, 5 replies.
- 回复：flink 1.11 使用sql写入hdfs无法自动提交分区 - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/10 09:39:16 UTC, 0 replies.
- flink 1.11 local execution oom问题 - posted by sunfulin <su...@163.com> on 2020/07/10 15:32:33 UTC, 3 replies.
- 回复：滑动窗口数据存储多份问题 - posted by Jimmy Zhang <13...@163.com> on 2020/07/11 08:49:42 UTC, 1 replies.
- 回复：代码中如何取消正在运行的Flink Streaming作业 - posted by jianxu <rj...@163.com> on 2020/07/11 08:52:23 UTC, 0 replies.
- flink 1.11 sql作业提交JM报错 - posted by sunfulin <su...@163.com> on 2020/07/11 14:24:51 UTC, 4 replies.
- flink 1.11 es未定义pk的sink问题 - posted by sunfulin <su...@163.com> on 2020/07/11 15:32:24 UTC, 7 replies.
- 回复：滑动窗口数据存储多份问题 - posted by Jimmy Zhang <13...@163.com> on 2020/07/12 00:13:37 UTC, 0 replies.
- 回复: 回复：关于 richfunction中初始化数据库连接的问题，导致程序卡主不执行 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/07/12 05:03:25 UTC, 0 replies.
- 使用hive 作为元数据 catalag 的问题 - posted by steven chen <st...@163.com> on 2020/07/12 10:51:32 UTC, 1 replies.
- flink on yarn日志问题 - posted by 程龙 <13...@163.com> on 2020/07/13 02:49:09 UTC, 9 replies.
- flink sql连接HBase报错 - posted by flink_learner <fl...@163.com> on 2020/07/13 03:23:27 UTC, 1 replies.
- flink sql 侧输出 - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/13 03:30:53 UTC, 2 replies.
- flink1.10.1 flink sql消费kafka当parallelism大于1时不产生watermark - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/07/13 03:46:02 UTC, 2 replies.
- flink sql报错 Could not find any factory for identifier 'kafka' - posted by 王松 <sd...@gmail.com> on 2020/07/13 04:53:57 UTC, 11 replies.
- how to set table.sql-dialect in flink1.11 StreamTableEnvironment - posted by Zhou Zach <wa...@163.com> on 2020/07/13 06:01:45 UTC, 2 replies.
- Table options do not contain an option key 'connector' for discovering a connector. - posted by Zhou Zach <wa...@163.com> on 2020/07/13 06:58:21 UTC, 5 replies.
- 回复: flink1.10.1 flink sql消费kafka当parallelism大于1时不产生watermark - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/07/13 06:59:19 UTC, 0 replies.
- Flink es7 connector认证问题 - posted by 李宇彬 <li...@163.com> on 2020/07/13 07:10:29 UTC, 1 replies.
- Re: pyflink问题求助 - posted by hieule <hi...@gmail.com> on 2020/07/13 07:10:36 UTC, 1 replies.
- flink使用debezium-json format报错 - posted by 曹武 <14...@163.com> on 2020/07/13 08:20:11 UTC, 1 replies.
- pyflink connect mysql - posted by hieule <hi...@gmail.com> on 2020/07/13 08:54:38 UTC, 0 replies.
- flink 1.11 createTemporaryTable 指定 rowtime 字段报 Field null does not exist 错误 - posted by Hito Zhu <qr...@gmail.com> on 2020/07/13 09:22:54 UTC, 7 replies.
- 回复：Re: Re: Table options do not contain an option key 'connector' for discovering a connector. - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/13 09:23:34 UTC, 8 replies.
- flink 1.11写入mysql问题 - posted by 小学霸 <st...@qq.com> on 2020/07/13 09:50:22 UTC, 2 replies.
- 回复：退订 - posted by 苑士旸 <yu...@163.com> on 2020/07/13 09:57:25 UTC, 0 replies.
- 回复： Flink es7 connector认证问题 - posted by 李宇彬 <li...@163.com> on 2020/07/13 10:44:43 UTC, 0 replies.
- Re: flink任务checkpoint无法完成snapshot，且报kafka异常 - posted by Zhefu PENG <pe...@gmail.com> on 2020/07/13 11:50:59 UTC, 2 replies.
- flink 1.11 on k8s native session cluster模式报找不到configmap - posted by Yvette zhai <yv...@gmail.com> on 2020/07/13 11:59:34 UTC, 6 replies.
- flink 1.11运算结果存mysql出错 - posted by 小学生 <20...@qq.com> on 2020/07/13 12:06:35 UTC, 7 replies.
- 使用Flink Array Field Type - posted by 叶贤勋 <yx...@163.com> on 2020/07/13 12:34:22 UTC, 1 replies.
- 回复： flink 1.11运算结果存mysql出错 - posted by Zhonghan Tang <13...@163.com> on 2020/07/13 12:53:19 UTC, 0 replies.
- flink 同时sink hbase和hive，hbase少记录 - posted by Zhou Zach <wa...@163.com> on 2020/07/13 13:09:03 UTC, 4 replies.
- 回复：使用Flink Array Field Type - posted by 叶贤勋 <yx...@163.com> on 2020/07/13 13:17:40 UTC, 0 replies.
- flink state - posted by "Robert.Zhang" <17...@qq.com> on 2020/07/13 13:49:55 UTC, 1 replies.
- 回复：【Flink Join内存问题】 - posted by 忝忝向仧 <15...@qq.com> on 2020/07/13 14:30:18 UTC, 0 replies.
- flink1.9.1-消费kafka落pg库任务出错 - posted by nicygan <re...@163.com> on 2020/07/14 02:31:02 UTC, 1 replies.
- Flink SQL处理Array型的JSON - posted by hua mulan <de...@outlook.com> on 2020/07/14 02:34:26 UTC, 2 replies.
- flink 1.9.2 升级 1.10.0 任务失败不能从checkpoint恢复 - posted by Peihui He <pe...@gmail.com> on 2020/07/14 02:42:36 UTC, 20 replies.
- 自定义的sql connector在sql-cli中运行问题 - posted by admin <17...@163.com> on 2020/07/14 02:50:39 UTC, 1 replies.
- 回复: Flink SQL处理Array型的JSON - posted by hua mulan <de...@outlook.com> on 2020/07/14 02:55:37 UTC, 3 replies.
- 回复：Re: flink 同时sink hbase和hive，hbase少记录 - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/14 03:00:18 UTC, 1 replies.
- flink cep 如何处理超时事件？ - posted by drewfranklin <dr...@163.com> on 2020/07/14 03:04:40 UTC, 1 replies.
- flink1.9状态及作业迁移 - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/14 03:07:16 UTC, 3 replies.
- Flink1.10 flinksql 多表join状态ttl不成功的问题 - posted by Robin Zhang <vi...@outlook.com> on 2020/07/14 03:19:55 UTC, 5 replies.
- 回复：flink1.9状态及作业迁移 - posted by 成欢晴 <ch...@163.com> on 2020/07/14 04:16:34 UTC, 0 replies.
- 退出邮件组 - posted by 成欢晴 <ch...@163.com> on 2020/07/14 04:35:28 UTC, 0 replies.
- (无主题) - posted by 成欢晴 <ch...@163.com> on 2020/07/14 04:36:10 UTC, 8 replies.
- State 0点清除的问题 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/07/14 05:09:35 UTC, 1 replies.
- flink-1.11使用executeSql()执行DDL语句问题 - posted by "amenhub@163.com" <am...@163.com> on 2020/07/14 06:37:57 UTC, 2 replies.
- 如果解决写hdfs的文件描述符问题？ - posted by 李宇彬 <li...@163.com> on 2020/07/14 06:52:39 UTC, 0 replies.
- [flink-sql] 如何在sql运行时动态修改kafka的scan.startup.mode - posted by "Harold.Miao" <mi...@gmail.com> on 2020/07/14 07:31:45 UTC, 1 replies.
- 不能实时读取实时写入到 Hive 的数据 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/14 07:47:56 UTC, 5 replies.
- 答复: flink state - posted by zhao liang <zh...@gmail.com> on 2020/07/14 08:09:51 UTC, 0 replies.
- 回复: Re: 不能实时读取实时写入到 Hive 的数据 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/14 08:40:39 UTC, 1 replies.
- 回复：Re: 不能实时读取实时写入到 Hive 的数据 - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/14 08:43:58 UTC, 0 replies.
- Re: 回复: 不能实时读取实时写入到 Hive 的数据 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/14 08:50:03 UTC, 0 replies.
- 回复：回复: 不能实时读取实时写入到 Hive 的数据 - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/14 08:59:06 UTC, 0 replies.
- 回复： Re: Re: flink on yarn日志问题 - posted by Cayden chen <11...@qq.com> on 2020/07/14 09:07:26 UTC, 0 replies.
- 回复： flink on yarn日志问题 - posted by jianxu <rj...@163.com> on 2020/07/14 09:31:19 UTC, 1 replies.
- flink 1.11 自定义RichFlatMapFunction中使用JdbcRowDataOutputFormat 写pgsql数据问题，RuntimeContext初始化问题，空指针或RuntimeContext未初始化，哪里用的不对！ - posted by jindy_liu <28...@qq.com> on 2020/07/14 09:38:40 UTC, 2 replies.
- flink 1.11 upsert结果出错 - posted by 小学生 <20...@qq.com> on 2020/07/14 09:56:39 UTC, 13 replies.
- flink1.11.0读取mysql数据decimal类型会强转成decimal(38,18)的问题 - posted by wldd <wl...@163.com> on 2020/07/14 09:58:39 UTC, 6 replies.
- flink-1.11 DDL 设置chk目录问题 - posted by kcz <57...@qq.com> on 2020/07/14 10:56:05 UTC, 1 replies.
- flink1.11 sink hive error - posted by Zhou Zach <wa...@163.com> on 2020/07/14 11:52:10 UTC, 4 replies.
- 回复：flink-1.11 DDL 设置chk目录问题 - posted by kcz <57...@qq.com> on 2020/07/14 13:44:33 UTC, 0 replies.
- TableEnvironment 里面无法执行 Hop等窗口函数 - posted by 王双利 <al...@163.com> on 2020/07/15 01:19:57 UTC, 0 replies.
- flink sql 1.10 insert into tb select 复杂schema 失败 - posted by Peihui He <pe...@gmail.com> on 2020/07/15 01:54:08 UTC, 4 replies.
- 回复： pyflink1.11.0window - posted by 奇怪的不朽琴师 <11...@qq.com> on 2020/07/15 02:27:15 UTC, 5 replies.
- 【求助】Flink Hadoop依赖问题 - posted by Z-Z <zz...@qq.com> on 2020/07/15 02:47:39 UTC, 2 replies.
- flink1.11.0 java.lang.NoSuchMethodError: org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread - posted by dmt312_2010 <dm...@163.com> on 2020/07/15 02:48:41 UTC, 2 replies.
- Re: flink1.11.0 java.lang.NoSuchMethodError: org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread - posted by JasonLee <17...@163.com> on 2020/07/15 03:04:57 UTC, 0 replies.
- 回复：TableEnvironment 里面无法执行 Hop等窗口函数 - posted by JasonLee <17...@163.com> on 2020/07/15 03:13:51 UTC, 0 replies.
- Re: flink1.11.0 java.lang.NoSuchMethodError:org.apache.flink.streaming.connectors.kafka.internal.KafkaConsumerThread - posted by dmt312_2010 <dm...@163.com> on 2020/07/15 03:18:39 UTC, 0 replies.
- flink1.11 sql kafka 抽取事件时间 - posted by "18500348251@163.com" <18...@163.com> on 2020/07/15 07:03:55 UTC, 1 replies.
- 回复：答复: flink state - posted by "Robert.Zhang" <17...@qq.com> on 2020/07/15 07:21:38 UTC, 1 replies.
- FlinkSQL 入到 MySQL后汉字乱码 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/15 08:34:44 UTC, 0 replies.
- 回复: FlinkSQL 入到 MySQL后汉字乱码 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/15 08:47:38 UTC, 0 replies.
- Flink 1.11 submit job timed out - posted by SmileSmile <a5...@163.com> on 2020/07/15 09:04:18 UTC, 15 replies.
- springboot 2.3.1 + flink 1.11.0整合后如何从外部传入application.yml配置文件? - posted by vw17 <vw...@163.com> on 2020/07/15 09:39:24 UTC, 0 replies.
- 答复: 回复：答复: flink state - posted by zhao liang <zh...@gmail.com> on 2020/07/15 10:04:59 UTC, 0 replies.
- flink 1.11 sql类型问题 - posted by sunfulin <su...@163.com> on 2020/07/15 13:24:30 UTC, 4 replies.
- HELP，flink1.10 sql整合hbase，insert into时，提示validateSchemaAndApplyImplicitCast报错 - posted by Jim Chen <ch...@gmail.com> on 2020/07/16 02:10:34 UTC, 0 replies.
- Flink-1.11内置connector测试问题求解 - posted by "amenhub@163.com" <am...@163.com> on 2020/07/16 03:30:48 UTC, 2 replies.
- FlinkKafkaConsumer API 维表关联 - posted by 郑斌斌 <zh...@heint.cn> on 2020/07/16 03:42:56 UTC, 1 replies.
- flink sql 1.11 create hive table error - posted by Zhou Zach <wa...@163.com> on 2020/07/16 04:07:08 UTC, 2 replies.
- [sql-client] 通过sql-client提交sql怎么设置checkpointing.interval - posted by "Harold.Miao" <mi...@gmail.com> on 2020/07/16 05:27:40 UTC, 3 replies.
- Trying to eagerly schedule a task whose inputs are not ready - posted by jiafu <53...@qq.com> on 2020/07/16 05:48:48 UTC, 0 replies.
- 回复：回复：答复: flink state - posted by "Robert.Zhang" <17...@qq.com> on 2020/07/16 06:29:01 UTC, 0 replies.
- flink1.11 set yarn slots failed - posted by Zhou Zach <wa...@163.com> on 2020/07/16 06:51:26 UTC, 1 replies.
- 回复：flink1.11 set yarn slots failed - posted by flinkcx <fl...@163.com> on 2020/07/16 07:03:14 UTC, 5 replies.
- Flink yarn session exception - posted by Rainie Li <ra...@pinterest.com.INVALID> on 2020/07/16 07:46:46 UTC, 4 replies.
- FlinkSQL 是通过怎样的机制找到要执行的 Java 代码的呢？ - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/16 08:02:21 UTC, 6 replies.
- flink1.11 Application 模式下启动失败问题 - posted by Hito Zhu <qr...@gmail.com> on 2020/07/16 08:05:10 UTC, 4 replies.
- 来自李国鹏的邮件 - posted by 李国鹏 <gp...@163.com> on 2020/07/16 09:06:58 UTC, 0 replies.
- Flink 1.11 Hive Streaming Write的问题 - posted by 李佳宸 <li...@gmail.com> on 2020/07/16 10:03:10 UTC, 3 replies.
- Flink on k8s 中，Jar 任务 avatica-core 依赖和 flink-table jar 冲突问题 - posted by LakeShen <sh...@gmail.com> on 2020/07/16 10:03:11 UTC, 3 replies.
- state无法从checkpoint中恢复 - posted by sun <13...@qq.com> on 2020/07/16 10:16:45 UTC, 2 replies.
- flink1.10升级到flink1.11 jar冲突 - posted by xyq <xi...@163.com> on 2020/07/16 10:36:58 UTC, 1 replies.
- flink state问题 - posted by op <52...@qq.com> on 2020/07/16 11:16:00 UTC, 1 replies.
- [sql-client] 如何绕过交互式模式去做ddl - posted by "Harold.Miao" <mi...@gmail.com> on 2020/07/16 11:43:18 UTC, 4 replies.
- flink 1.11 checkpoint使用 - posted by 曹武 <14...@163.com> on 2020/07/16 12:04:16 UTC, 6 replies.
- Re: 【求助】flink打包到集群运行问题 - posted by Congxian Qiu <qc...@gmail.com> on 2020/07/16 12:13:09 UTC, 0 replies.
- 回复：Flink 1.11 Hive Streaming Write的问题 - posted by JasonLee <17...@163.com> on 2020/07/16 12:22:19 UTC, 0 replies.
- flink 1.11任务提交的问题 - posted by sunfulin <su...@163.com> on 2020/07/16 15:08:03 UTC, 7 replies.
- flink1.9写权限认证的es6 - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/17 02:12:31 UTC, 1 replies.
- flink connector formats问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/07/17 02:42:13 UTC, 0 replies.
- 回复：flink connector formats问题 - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/17 02:47:36 UTC, 2 replies.
- 回复：flink1.9写权限认证的es6 - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/17 02:49:48 UTC, 0 replies.
- flink-1.11 KafkaDynamicTableSouce groupBy 结果怎样发送到 kafka - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/17 05:02:00 UTC, 0 replies.
- flink-1.11 DDL 写入hdfs问题 Cannot instantiate user function - posted by kcz <57...@qq.com> on 2020/07/17 05:32:18 UTC, 1 replies.
- 回复： flink1.9写权限认证的es6 - posted by 夏帅 <jk...@dingtalk.com.INVALID> on 2020/07/17 05:57:06 UTC, 0 replies.
- 回复：flink-1.11 DDL 写入hdfs问题 Cannot instantiate user function - posted by kcz <57...@qq.com> on 2020/07/17 06:17:01 UTC, 0 replies.
- SQL 报错只有 flink runtime 的 NPE - posted by Luan Cooper <gc...@gmail.com> on 2020/07/17 06:40:11 UTC, 5 replies.
- 回复： flink-1.11 DDL 写入hdfs问题 Cannot instantiate user function - posted by kcz <57...@qq.com> on 2020/07/17 08:05:02 UTC, 0 replies.
- flink-1.11 ddl 写入json 格式数据到hdfs问题 - posted by kcz <57...@qq.com> on 2020/07/17 08:24:48 UTC, 2 replies.
- flink1.11写hive - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/17 09:05:12 UTC, 2 replies.
- connector hive依赖冲突 - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/17 09:14:19 UTC, 5 replies.
- 回复： state无法从checkpoint中恢复 - posted by sun <13...@qq.com> on 2020/07/17 09:21:41 UTC, 1 replies.
- 回复： flink-1.11 ddl 写入json 格式数据到hdfs问题 - posted by kcz <57...@qq.com> on 2020/07/17 09:26:13 UTC, 0 replies.
- flink不带参数的udf始终返回第一次调用的结果 - posted by 867127831 <86...@qq.com> on 2020/07/17 09:26:58 UTC, 2 replies.
- Flink Cli 部署问题 - posted by Z-Z <zz...@qq.com> on 2020/07/17 10:22:07 UTC, 4 replies.
- flink-1.11 集成hive-1.2.1 DDL问题 - posted by kcz <57...@qq.com> on 2020/07/17 11:29:39 UTC, 2 replies.
- Re: flink-1.11 KafkaDynamicTableSouce groupBy 结果怎样发送到 kafka - posted by Benchao Li <li...@apache.org> on 2020/07/17 12:18:14 UTC, 1 replies.
- sql 内嵌josn数组解析报类型转换报错 - posted by claylin <10...@qq.com> on 2020/07/17 12:28:27 UTC, 3 replies.
- 回复： sql 内嵌josn数组解析报类型转换报错 - posted by claylin <10...@qq.com> on 2020/07/17 12:37:09 UTC, 1 replies.
- 回复： Flink Cli 部署问题 - posted by Z-Z <zz...@qq.com> on 2020/07/17 15:10:12 UTC, 3 replies.
- 回复：state无法从checkpoint中恢复 - posted by JasonLee <17...@163.com> on 2020/07/18 01:02:49 UTC, 0 replies.
- FlinkSQL 任务提交后任务名称问题 - posted by Evan <ch...@foxmail.com> on 2020/07/18 09:47:24 UTC, 2 replies.
- 如何在ProcessAllWindowFunction中触发清除自定义的ValueState状态 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/07/18 12:37:03 UTC, 0 replies.
- flink sink到kafka - posted by smq <37...@qq.com> on 2020/07/19 13:35:23 UTC, 1 replies.
- 回复: flink sink到kafka - posted by 明启孙 <37...@qq.com> on 2020/07/20 01:15:05 UTC, 0 replies.
- 回复： (无主题) - posted by 罗显宴 <15...@163.com> on 2020/07/20 06:09:11 UTC, 7 replies.
- flink job 跑一段时间 watermark 不推进的问题 - posted by snack white <am...@gmail.com> on 2020/07/20 07:14:19 UTC, 1 replies.
- flink1.11启动问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/07/20 07:36:11 UTC, 8 replies.
- 回复：flink job 跑一段时间 watermark 不推进的问题 - posted by Cayden chen <11...@qq.com> on 2020/07/20 08:00:02 UTC, 0 replies.
- flink1.11 run - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/20 08:29:06 UTC, 6 replies.
- 测试一下社区邮件 - posted by "sjlsumaitong@163.com" <sj...@163.com> on 2020/07/20 11:26:37 UTC, 0 replies.
- 长时间运行的flink任务会有以下报错 - posted by jiafu <53...@qq.com> on 2020/07/20 11:31:28 UTC, 0 replies.
- 回复: 长时间运行的flink任务会有以下报错 - posted by "sjlsumaitong@163.com" <sj...@163.com> on 2020/07/20 11:50:30 UTC, 0 replies.
- 回复：(无主题) - posted by 罗显宴 <15...@163.com> on 2020/07/20 12:14:20 UTC, 1 replies.
- 回复： flink1.11启动问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/07/20 12:15:32 UTC, 2 replies.
- liststate - posted by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/07/21 01:27:56 UTC, 1 replies.
- 回复: 回复： pyflink1.11.0window - posted by "chengyanan1008@foxmail.com" <ch...@foxmail.com> on 2020/07/21 02:12:40 UTC, 1 replies.
- Flink整合hive之后，通过flink创建的表，hive beeline可见表，不可见字段？ - posted by felixzh <fe...@126.com> on 2020/07/21 03:31:27 UTC, 1 replies.
- 官方pyflink 例子的执行问题 - posted by chenxuying <cx...@163.com> on 2020/07/21 03:35:36 UTC, 2 replies.
- Flink 往kafka生产数据，频繁出现checkpoint失败的错误 - posted by 胡云川 <hu...@foxmail.com> on 2020/07/21 03:40:32 UTC, 0 replies.
- 想知道state写到checkpoint文件没有 - posted by sun <13...@qq.com> on 2020/07/21 03:52:54 UTC, 1 replies.
- flink 1.11 cdc: kafka中存了canal-json格式的多张表信息，需要按表解析做处理，sink至不同的下游，要怎么支持？ - posted by jindy_liu <28...@qq.com> on 2020/07/21 04:30:59 UTC, 2 replies.
- flink1.11 pyflink stream job 退出 - posted by lgs <99...@qq.com> on 2020/07/21 07:34:29 UTC, 3 replies.
- flink解析kafka json数据 - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/21 08:08:05 UTC, 6 replies.
- flink table同时作为写出及输入时下游无数据 - posted by 小学生 <20...@qq.com> on 2020/07/21 08:32:46 UTC, 5 replies.
- 回复: flink table同时作为写出及输入时下游无数据 - posted by "chengyanan1008@foxmail.com" <ch...@foxmail.com> on 2020/07/21 09:02:40 UTC, 0 replies.
- flink-1.11 ddl kafka-to-hive问题 - posted by kcz <57...@qq.com> on 2020/07/21 11:09:19 UTC, 3 replies.
- flink1.11 tablefunction - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/21 11:22:33 UTC, 8 replies.
- 回复：flink-1.11 ddl kafka-to-hive问题 - posted by JasonLee <17...@163.com> on 2020/07/21 12:38:30 UTC, 2 replies.
- Flink sql中可以使用自定义窗口触发器吗 - posted by 462329521 <46...@qq.com> on 2020/07/21 14:28:28 UTC, 1 replies.
- Flink catalog的几个疑问 - posted by "dixingxing85@163.com" <di...@163.com> on 2020/07/21 15:30:14 UTC, 4 replies.
- flinksql1.11中主键声明的问题 - posted by "1129656513@qq.com" <11...@qq.com> on 2020/07/22 02:08:56 UTC, 4 replies.
- flink1.11 web ui没有DAG - posted by 小学生 <20...@qq.com> on 2020/07/22 02:26:48 UTC, 4 replies.
- flink1.11 实现tablefunction报错 - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/22 03:24:25 UTC, 0 replies.
- flink1.11 sql - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/22 04:14:04 UTC, 2 replies.
- 答复: Flink catalog的几个疑问 - posted by 刘首维 <li...@autohome.com.cn> on 2020/07/22 04:18:25 UTC, 0 replies.
- 关于1.11Flink SQL 全新API设计的一些问题 - posted by 刘首维 <li...@autohome.com.cn> on 2020/07/22 04:34:36 UTC, 1 replies.
- flink1.11任务启动 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/07/22 04:43:03 UTC, 1 replies.
- 回复：flink1.11启动问题 - posted by JasonLee <17...@163.com> on 2020/07/22 04:48:18 UTC, 4 replies.
- Re: 关于1.11Flink SQL 全新API设计的一些问题 - posted by Jingsong Li <ji...@gmail.com> on 2020/07/22 05:26:00 UTC, 4 replies.
- 答复: 关于1.11Flink SQL 全新API设计的一些问题 - posted by 刘首维 <li...@autohome.com.cn> on 2020/07/22 05:47:25 UTC, 4 replies.
- 回复: Re: flinksql1.11中主键声明的问题 - posted by "1129656513@qq.com" <11...@qq.com> on 2020/07/22 06:13:01 UTC, 1 replies.
- 回复： flinksql1.11中主键声明的问题 - posted by 奇怪的不朽琴师 <11...@qq.com> on 2020/07/22 06:50:27 UTC, 2 replies.
- [ANNOUNCE] Apache Flink 1.11.1 released - posted by Dian Fu <di...@apache.org> on 2020/07/22 06:52:44 UTC, 0 replies.
- Re: [ANNOUNCE] Apache Flink 1.11.1 released - posted by Leonard Xu <xb...@gmail.com> on 2020/07/22 07:09:25 UTC, 10 replies.
- flink 问题排查 - posted by steven chen <st...@163.com> on 2020/07/22 07:35:09 UTC, 0 replies.
- flink stream如何为每条数据生成自增主键 - posted by "tiantingting5435@163.com" <ti...@163.com> on 2020/07/22 07:51:44 UTC, 2 replies.
- flink sqlUpdate,如何获取里面的字段，字段类型，with 等3个属性 - posted by Michael Ran <gr...@163.com> on 2020/07/22 08:10:07 UTC, 3 replies.
- Flink APP restart policy not working - posted by Rainie Li <ra...@pinterest.com.INVALID> on 2020/07/22 08:10:33 UTC, 0 replies.
- flink 问题排查补充 - posted by steven chen <st...@163.com> on 2020/07/22 09:05:40 UTC, 0 replies.
- flink 1.11 cdc相关问题 - posted by "amenhub@163.com" <am...@163.com> on 2020/07/22 09:34:13 UTC, 4 replies.
- flink row 类型 - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/22 11:21:29 UTC, 9 replies.
- flink 1.11 ddl sql 添加PROCTIME()列，读取csv错误 - posted by Asahi Lee <97...@qq.com> on 2020/07/22 16:07:39 UTC, 3 replies.
- flink sink kafka Error while confirming checkpoint - posted by Peihui He <pe...@gmail.com> on 2020/07/23 00:55:45 UTC, 0 replies.
- Re: Is it possible to do state migration with checkpoints? - posted by Sivaprasanna <si...@gmail.com> on 2020/07/23 06:18:18 UTC, 1 replies.
- application模式提交操作hive的任务相关疑问 - posted by Jun Zhang <zh...@gmail.com> on 2020/07/23 07:50:32 UTC, 3 replies.
- flink-1.11 在 windows 下怎样启动 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2020/07/23 08:00:17 UTC, 1 replies.
- flink 1.11 ddl 写mysql的问题 - posted by 曹武 <14...@163.com> on 2020/07/23 08:14:12 UTC, 2 replies.
- flink读取kafka流式数据的速率是多少 - posted by 小学生 <20...@qq.com> on 2020/07/23 08:58:23 UTC, 0 replies.
- metrics influxdb reporter 不支持https及jar放置路径问题 - posted by zz zhang <ol...@gmail.com> on 2020/07/23 09:01:18 UTC, 2 replies.
- flink sql 1.11 kafka source with子句使用新参数，下游消费不到数据 - posted by Zhou Zach <wa...@163.com> on 2020/07/23 10:13:30 UTC, 5 replies.
- flink 1.11 executeSql查询kafka表print没有输出 - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/07/23 11:21:54 UTC, 2 replies.
- 回复: flink 1.11 executeSql查询kafka表print没有输出 - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/07/23 11:33:59 UTC, 0 replies.
- 回复：application模式提交操作hive的任务相关疑问 - posted by Jun Zhang <82...@qq.com> on 2020/07/23 11:35:20 UTC, 0 replies.
- 回复： flink 1.11 ddl sql 添加PROCTIME()列，读取csv错误 - posted by Asahi Lee <97...@qq.com> on 2020/07/23 14:05:15 UTC, 0 replies.
- 自定义metrics reporter 如何不通过flink conf来注册并生效 - posted by Fisher Xiang <fi...@gmail.com> on 2020/07/23 14:14:45 UTC, 1 replies.
- Flink的broadcast - posted by 忝忝向仧 <15...@qq.com> on 2020/07/23 14:50:47 UTC, 1 replies.
- flink1.11日志上报 - posted by Dream-底限 <zh...@akulaku.com> on 2020/07/24 02:49:43 UTC, 2 replies.
- 关于 sql-client - posted by 杨荣 <sa...@gmail.com> on 2020/07/24 02:52:47 UTC, 5 replies.
- 回复：flink1.11日志上报 - posted by Cayden chen <11...@qq.com> on 2020/07/24 02:52:59 UTC, 1 replies.
- 回复：flink sql 1.11 kafka source with子句使用新参数，下游消费不到数据 - posted by Zhou Zach <wa...@163.com> on 2020/07/24 04:10:46 UTC, 0 replies.
- Flink Weekly | 每周社区动态更新 - 2020/07/24 - posted by Benchao Li <li...@apache.org> on 2020/07/24 04:25:53 UTC, 0 replies.
- flink sql 读取mysql - posted by liunaihua521 <li...@163.com> on 2020/07/24 06:14:23 UTC, 5 replies.
- Flink CPU利用率低 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/07/24 08:15:53 UTC, 1 replies.
- 回复： flink sql 读取mysql - posted by liunaihua521 <li...@163.com> on 2020/07/24 08:20:13 UTC, 0 replies.
- Could not find any factory for identifier 'kafka' - posted by RS <ti...@163.com> on 2020/07/24 09:02:04 UTC, 8 replies.
- 回复: Re: flink 1.11 cdc相关问题 - posted by "amenhub@163.com" <am...@163.com> on 2020/07/24 10:18:23 UTC, 0 replies.
- flink1.11查询结果每秒入库到mysql数量很少 - posted by 小学生 <20...@qq.com> on 2020/07/24 10:18:57 UTC, 4 replies.
- 回复: flink1.11查询结果每秒入库到mysql数量很少 - posted by "chengyanan1008@foxmail.com" <ch...@foxmail.com> on 2020/07/25 06:10:22 UTC, 1 replies.
- 【Flink sql 1.10.0问题】 - posted by 忝忝向仧 <15...@qq.com> on 2020/07/26 13:58:10 UTC, 0 replies.
- 答复: 【Flink sql 1.10.0问题】 - posted by zhao liang <zh...@gmail.com> on 2020/07/26 15:01:04 UTC, 0 replies.
- flink 聚合 job 重启问题 - posted by 郑斌斌 <zh...@heint.cn> on 2020/07/27 03:33:31 UTC, 1 replies.
- 【flink sql】flink sql insert into插入语句的问题 - posted by sl...@aliyun.com.INVALID on 2020/07/27 03:36:02 UTC, 1 replies.
- Re: Flink JOB_MANAGER_LEADER_PATH Znode的清理时机 - posted by Yang Wang <da...@gmail.com> on 2020/07/27 03:57:21 UTC, 0 replies.
- Re: Blink Planner构造Remote Env - posted by jun su <su...@gmail.com> on 2020/07/27 06:29:39 UTC, 1 replies.
- sql-client 的jdbc表出错 - posted by op <52...@qq.com> on 2020/07/27 06:45:17 UTC, 3 replies.
- Blink的Batch模式的并行度问题 - posted by jun su <su...@gmail.com> on 2020/07/27 07:49:46 UTC, 2 replies.
- Hbase connector写入问题 - posted by op <52...@qq.com> on 2020/07/27 09:09:17 UTC, 0 replies.
- 回复： sql-client 的jdbc表出错 - posted by op <52...@qq.com> on 2020/07/27 09:28:40 UTC, 1 replies.
- kafka-connect json格式适配问题？ - posted by RS <ti...@163.com> on 2020/07/27 09:31:30 UTC, 4 replies.
- Flink Sql 问题 - posted by air23 <wa...@163.com> on 2020/07/27 10:13:11 UTC, 0 replies.
- 解析kafka的mysql binlog问题 - posted by air23 <wa...@163.com> on 2020/07/27 10:16:43 UTC, 10 replies.
- flink1.11.0 执行sqlQuery时报NullPointException - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/07/27 10:49:22 UTC, 4 replies.
- 回复: flink1.11.0 执行sqlQuery时报NullPointException - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/07/27 10:55:34 UTC, 4 replies.
- 回复：解析kafka的mysql binlog问题 - posted by air23 <wa...@163.com> on 2020/07/27 11:21:51 UTC, 1 replies.
- flink1.11.1启动问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/07/27 11:41:33 UTC, 2 replies.
- kafka avro格式sink报错，NoClassDefFoundError: Could not initialize class org.apache.avro.SchemaBuilder - posted by RS <ti...@163.com> on 2020/07/27 13:57:27 UTC, 0 replies.
- 回复：flink row 类型 - posted by kcz <57...@qq.com> on 2020/07/27 14:16:32 UTC, 0 replies.
- flink1.11.1使用Table API Hive方言的executSql报错 - posted by shimin huang <hu...@gmail.com> on 2020/07/28 03:20:52 UTC, 1 replies.
- Flink-1.10 on yarn Taskmanager启动参数问题 - posted by Roc Marshal <fl...@126.com> on 2020/07/28 03:57:28 UTC, 0 replies.
- flink1.10.1/1.11.1 使用sql 进行group 和时间窗口操作后状态越来越大 - posted by 鱼子酱 <38...@qq.com> on 2020/07/28 06:45:08 UTC, 9 replies.
- 回复： flink1.11.1启动问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/07/28 06:45:51 UTC, 0 replies.
- 回复: Re: Re: 解析kafka的mysql binlog问题 - posted by 明启孙 <37...@qq.com> on 2020/07/28 08:02:30 UTC, 1 replies.
- flink 1.11 rest api saveppoint接口异常 - posted by taowang <ta...@deepglint.com> on 2020/07/28 09:04:46 UTC, 9 replies.
- Re: flink作业提交到集群执行异常 - posted by hechuan <ti...@163.com> on 2020/07/28 09:37:43 UTC, 1 replies.
- Flink操作 kafka ，hive遇到kerberos过期 - posted by lydata <ly...@163.com> on 2020/07/28 09:58:51 UTC, 1 replies.
- 回复：flink 聚合 job 重启问题 - posted by 郑斌斌 <zh...@heint.cn> on 2020/07/28 11:30:05 UTC, 0 replies.
- Flink SQL 解析复杂（嵌套）JSON的问题以及写入到hive类型映射问题 - posted by "kandy.wang" <ka...@163.com> on 2020/07/28 13:03:22 UTC, 1 replies.
- [DISCUSS] add a '--filename' parameter for sql-client - posted by Jun Zhang <zh...@gmail.com> on 2020/07/29 01:20:57 UTC, 3 replies.
- flink1.11 可以使用processtime开窗，但是无法使用eventtime开窗 - posted by 111 <ta...@163.com> on 2020/07/29 01:56:23 UTC, 1 replies.
- Sql往kafka表写聚合数据报错 - posted by op <52...@qq.com> on 2020/07/29 03:51:44 UTC, 2 replies.
- Flink提交任务时可以使用-djs参数，但没有看到相关介绍 - posted by zhoujibo <zh...@163.com> on 2020/07/29 04:14:59 UTC, 0 replies.
- Flink使用Kafka作为source时checkpoint成功提交offset的机制 - posted by shuwen zhou <ja...@gmail.com> on 2020/07/29 06:23:54 UTC, 4 replies.
- FLink1.11.1整合hadoop3.0.0 - posted by felixzh <fe...@126.com> on 2020/07/29 06:27:37 UTC, 0 replies.
- flink-1.11 hive-1.2.1 ddl 无法写入数据 - posted by kcz <57...@qq.com> on 2020/07/29 07:07:26 UTC, 2 replies.
- 回复： Flink使用Kafka作为source时checkpoint成功提交offset的机制 - posted by hk__lrzy <hk...@163.com> on 2020/07/29 08:00:05 UTC, 0 replies.
- 关于window过程中barrier的问题 - posted by shuwen zhou <ja...@gmail.com> on 2020/07/29 08:17:20 UTC, 1 replies.
- 使用datagen connector生成无界数据，一秒时间窗口的聚合操作，一直没有数据输出打印 - posted by Asahi Lee <97...@qq.com> on 2020/07/29 08:35:30 UTC, 2 replies.
- 近期使用flinksql(1.11.0)发现的一些问题 - posted by Ryiyi <18...@163.com> on 2020/07/29 08:41:58 UTC, 0 replies.
- flink on yarn 读取 hbase数据时，Task失败，具体描述如下 - posted by 张锴 <zk...@gmail.com> on 2020/07/29 09:02:24 UTC, 1 replies.
- flink1.9.1 在WebUI中查看committedOffsets指标为负值 - posted by bradyMk <zh...@126.com> on 2020/07/29 10:14:35 UTC, 3 replies.
- flink1.11 sql 发布到yarn session时找不到hbase相关的类 - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/07/29 10:39:00 UTC, 1 replies.
- Flink Weekly | 每周社区动态更新 - 2020/07/30 - posted by 王松 <sd...@gmail.com> on 2020/07/30 01:51:36 UTC, 0 replies.
- 回复: flink1.11 sql 发布到yarn session时找不到hbase相关的类 - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/07/30 02:32:08 UTC, 0 replies.
- Re: 近期使用flinksql(1.11.0)发现的一些问题 - posted by Jark Wu <im...@gmail.com> on 2020/07/30 02:36:58 UTC, 1 replies.
- 回复： Sql往kafka表写聚合数据报错 - posted by op <52...@qq.com> on 2020/07/30 02:40:55 UTC, 0 replies.
- flink消费kafka提交偏移量 - posted by 小学生 <20...@qq.com> on 2020/07/30 02:56:52 UTC, 3 replies.
- 回复： flink-1.11 hive-1.2.1 ddl 无法写入数据 - posted by kcz <57...@qq.com> on 2020/07/30 03:16:19 UTC, 0 replies.
- flink 1.11 streaming 写入hive 5min表相关问题 - posted by "kandy.wang" <ka...@163.com> on 2020/07/30 04:57:36 UTC, 1 replies.
- StatementSet 里添加多个insertsql执行 - posted by op <52...@qq.com> on 2020/07/30 07:57:22 UTC, 1 replies.
- 回复： StatementSet 里添加多个insertsql执行 - posted by op <52...@qq.com> on 2020/07/30 08:04:53 UTC, 0 replies.
- flink kafka SQL Connectors 传递kerberos 参数 - posted by lydata <ly...@163.com> on 2020/07/30 08:38:11 UTC, 4 replies.
- [flink批处理DataSet 写orc文件咨询] - posted by 胡松 <hs...@qq.com> on 2020/07/30 08:52:24 UTC, 0 replies.
- 回复：flink1.9.1 在WebUI中查看committedOffsets指标为负值 - posted by JasonLee <17...@163.com> on 2020/07/30 13:58:34 UTC, 0 replies.
- 回复: Re: Flink实现Kafka到Mysql的 End-To-End Exactly-Once中遇到的问题 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/07/31 01:21:03 UTC, 0 replies.
- [DISCUSS] FLIP-133: Rework PyFlink Documentation - posted by jincheng sun <su...@gmail.com> on 2020/07/31 02:14:58 UTC, 2 replies.
- flinksql kafka 插入mysql 的insert语法问题和唯一主键的问题 - posted by chenxuying <cx...@163.com> on 2020/07/31 08:12:40 UTC, 4 replies.
- RocksDBKeyedStateBackend如何写磁盘 - posted by jun su <su...@gmail.com> on 2020/07/31 08:37:18 UTC, 1 replies.
- 回复：RocksDBKeyedStateBackend如何写磁盘 - posted by jiafu <53...@qq.com> on 2020/07/31 08:40:36 UTC, 0 replies.
- Flink sql 转义字符问题 - posted by zilong xiao <ac...@gmail.com> on 2020/07/31 12:12:20 UTC, 4 replies.
- 回复： Flink sql 转义字符问题 - posted by Hannan Kan <ha...@foxmail.com> on 2020/07/31 13:03:51 UTC, 0 replies.
- pyflink 消费kafka protobuf数据 - posted by stephenlee <87...@qq.com> on 2020/07/31 14:27:04 UTC, 0 replies.
- Behavior for flink job running on K8S failed after restart strategy exhausted - posted by Eleanore Jin <el...@gmail.com> on 2020/07/31 16:20:55 UTC, 0 replies.