You are viewing a plain text version of this content. The canonical link for it is here.
- Re: flinksql注册udtf使用ROW类型做为输出输出时出错 - posted by Xingbo Huang <hx...@gmail.com> on 2020/10/01 12:04:37 UTC, 0 replies.
- Re: Checkpoint dir is not cleaned up after cancel the job with monitoring API - posted by Chesnay Schepler <ch...@apache.org> on 2020/10/02 09:42:28 UTC, 1 replies.
- Flink对IoTDB的支持 - posted by milan183sansiro <mi...@126.com> on 2020/10/02 11:21:03 UTC, 1 replies.
- 大佬们，有遇到Flink cdc 同步MySQL中的数据，MySQL中的数据有变化，Flink SQL中的表没有实时同步到变化，是什么原因呢？ - posted by chegg_work <ch...@163.com> on 2020/10/02 12:14:01 UTC, 1 replies.
- 请问如何模拟一个back pressure的场景,应该如何实现?谢谢 - posted by 大森林 <ap...@foxmail.com> on 2020/10/03 06:41:16 UTC, 1 replies.
- 回复：请问如何模拟一个back pressure的场景,应该如何实现?谢谢 - posted by ?? <11...@qq.com> on 2020/10/03 10:36:04 UTC, 1 replies.
- 退订 - posted by 天分 <77...@qq.com> on 2020/10/04 03:19:14 UTC, 6 replies.
- Flink的table-api不支持. - posted by 忝忝向仧 <15...@qq.com> on 2020/10/04 09:09:23 UTC, 2 replies.
- 回复：Flink的table-api不支持. - posted by 大森林 <ap...@foxmail.com> on 2020/10/04 09:55:24 UTC, 0 replies.
- rocksdb增量ckeckpoint问题 - posted by 熊云昆 <xi...@163.com> on 2020/10/06 08:53:28 UTC, 1 replies.
- 【Flink的shuffle Mode】 - posted by 忝忝向仧 <15...@qq.com> on 2020/10/06 10:04:06 UTC, 1 replies.
- flink on yarn 内存 - posted by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/10/06 13:58:19 UTC, 2 replies.
- 回复：rocksdb增量ckeckpoint问题 - posted by 大森林 <ap...@foxmail.com> on 2020/10/07 02:34:17 UTC, 4 replies.
- 订阅 - posted by 葛春法-18667112979 <tu...@163.com> on 2020/10/08 12:44:44 UTC, 1 replies.
- flink savepoint和checkpoint相关事项 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/10/09 00:59:35 UTC, 1 replies.
- checkpoint失败导致watermark不更新问题 - posted by restart <ne...@outlook.com> on 2020/10/09 03:24:25 UTC, 2 replies.
- Re: Flink 1.10.1 checkpoint失败问题 - posted by Storm☀️ <st...@163.com> on 2020/10/09 03:29:31 UTC, 6 replies.
- 回复： flink on yarn 内存 - posted by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/10/09 03:45:02 UTC, 0 replies.
- FlinkJobNotFoundException错误 - posted by 小学生 <20...@qq.com> on 2020/10/09 06:18:44 UTC, 3 replies.
- Flink Sql client on yarn 问题 - posted by air23 <wa...@163.com> on 2020/10/09 06:22:22 UTC, 1 replies.
- flink1.11流式写入hive速度慢的问题 - posted by me <me...@lishiyu.cn> on 2020/10/09 06:59:36 UTC, 4 replies.
- 【公告】Flink Forward 2020 亚洲峰会议题提交时间延长 - posted by Kurt Young <ku...@apache.org> on 2020/10/09 07:36:01 UTC, 0 replies.
- 转发：flink1.11流式写入hive速度慢的问题 - posted by me <me...@lishiyu.cn> on 2020/10/09 07:50:00 UTC, 0 replies.
- Re: Flink 1.11 submit job timed out - posted by "DONG, Weike" <ky...@connect.hku.hk> on 2020/10/09 09:09:37 UTC, 0 replies.
- Re:Re: checkpoint rocksdb hdfs 如何协调，保证数据不丢失 - posted by Michael Ran <gr...@163.com> on 2020/10/09 09:50:31 UTC, 0 replies.
- Flink SQL Create View - posted by hua mulan <de...@outlook.com> on 2020/10/09 13:17:11 UTC, 1 replies.
- 回复: Re: flink savepoint和checkpoint相关事项 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/10/10 00:43:38 UTC, 1 replies.
- 动态加载table和udf的方法 - posted by Zeahoo Z <ze...@gmail.com> on 2020/10/10 01:04:21 UTC, 1 replies.
- Flink1.10 sink to mysql SocketException - posted by "sh_0425@126.com" <sh...@126.com> on 2020/10/10 02:37:33 UTC, 2 replies.
- Re: flink1.11.2基于官网在k8s上部署是正常的,但是加了volume配置之后报错Read-only file system - posted by "cxydevelop@163.com" <cx...@163.com> on 2020/10/10 03:20:36 UTC, 1 replies.
- 回复： Flink 1.10.1 checkpoint失败问题 - posted by 大森林 <ap...@foxmail.com> on 2020/10/10 05:05:18 UTC, 0 replies.
- Re: flink1.11实时写入hive，写入速度很慢，checkpoint为60秒，并行度为1 - posted by Rui Li <li...@gmail.com> on 2020/10/10 06:34:55 UTC, 0 replies.
- Flink 1.11.1 输出Hbase，除rowkey以外全部为null - posted by TonyChen <to...@qq.com> on 2020/10/10 07:33:06 UTC, 9 replies.
- flink1.11.2 在k8s上部署,如何启动history server - posted by chenxuying <cx...@163.com> on 2020/10/10 07:56:43 UTC, 2 replies.
- Re: Re:Re: Re: Flink 1.11.1 on k8s 如何配置hadoop - posted by yang <fa...@163.com> on 2020/10/10 08:32:56 UTC, 3 replies.
- aa - posted by 任亚博 <re...@163.com> on 2020/10/10 17:19:49 UTC, 1 replies.
- 关于flink-sql Join Temporal Tables join 维表问题 - posted by 夜思流年梦 <li...@163.com> on 2020/10/12 03:55:50 UTC, 3 replies.
- Demo：从埋点日志中，统计实时的 PV 遇到的问题 - posted by Natasha <13...@163.com> on 2020/10/12 06:04:27 UTC, 4 replies.
- 回复： Demo：从埋点日志中，统计实时的 PV 遇到的问题 - posted by Natasha <13...@163.com> on 2020/10/12 06:30:28 UTC, 2 replies.
- 回复： 回复： Demo：从埋点日志中，统计实时的 PV 遇到的问题 - posted by Natasha <13...@163.com> on 2020/10/12 07:09:49 UTC, 0 replies.
- Re: 关于flink-sql Join Temporal Tables join 维表问题 - posted by Jark Wu <im...@gmail.com> on 2020/10/12 07:37:51 UTC, 1 replies.
- Re: Flink on K8s statebackend 配置 - posted by Congxian Qiu <qc...@gmail.com> on 2020/10/12 09:09:59 UTC, 0 replies.
- 回复： Flink on K8s statebackend 配置 - posted by superainbower <su...@163.com> on 2020/10/12 09:16:25 UTC, 0 replies.
- Re: Flink Kerberos认证问题 - posted by caozhen <ca...@163.com> on 2020/10/12 10:05:00 UTC, 2 replies.
- 答复: Re: Flink消费kafka，突然间任务输出结果从原来的每秒几十万降低到几万每秒 - posted by 范超 <fa...@mgtv.com> on 2020/10/12 10:07:06 UTC, 0 replies.
- Re: flink on yarn容器异常退出 - posted by caozhen <ca...@163.com> on 2020/10/12 10:08:08 UTC, 3 replies.
- Re: Flink 任务提交问题 - posted by caozhen <ca...@163.com> on 2020/10/12 10:17:44 UTC, 1 replies.
- 如何为每个flink任务分别设置metrics的reporter - posted by xiao cai <fl...@163.com> on 2020/10/12 10:17:56 UTC, 2 replies.
- 回复：如何为每个flink任务分别设置metrics的reporter - posted by 熊云昆 <xi...@163.com> on 2020/10/12 10:34:21 UTC, 0 replies.
- 如何获取flink webUI上面的DAG图 - posted by 丁浩浩 <18...@163.com> on 2020/10/12 11:15:36 UTC, 3 replies.
- flink并行度 slot taskmanager相关问题 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/10/12 11:32:39 UTC, 0 replies.
- Re: 关于stream注册成表的数据存储时长问题 - posted by caozhen <ca...@163.com> on 2020/10/12 12:00:04 UTC, 1 replies.
- flink点查时态表支持子查询 - posted by Dream-底限 <zh...@akulaku.com> on 2020/10/13 02:03:00 UTC, 3 replies.
- flink-connector-jdbc 落入mysql的时候timestamp 有时差问题 - posted by 姬洪超 <ji...@geekplus.com> on 2020/10/13 06:18:53 UTC, 2 replies.
- flink1.11.2webui界面中的任务详情页面获取不到任务的received和sent数据详情 - posted by chenxuying <cx...@163.com> on 2020/10/13 09:22:41 UTC, 11 replies.
- flink-SQL1.11版本对map类型中value的空指针异常 - posted by 奔跑的小飞袁 <s_...@126.com> on 2020/10/13 10:06:51 UTC, 6 replies.
- flink-windows-state - posted by 宁吉浩 <a9...@dingtalk.com.INVALID> on 2020/10/13 10:20:14 UTC, 3 replies.
- 回复: flink-connector-jdbc 落入mysql的时候timestamp 有时差问题 - posted by 史 正超 <sh...@outlook.com> on 2020/10/13 11:14:43 UTC, 0 replies.
- flink sink kafka过慢问题 - posted by xyq <xi...@163.com> on 2020/10/13 11:38:37 UTC, 3 replies.
- 使用最新1.11版本 flink和pyflink连接mysql出现 Required context properties mismatch 错误 - posted by helxsz <he...@gmail.com> on 2020/10/14 01:39:48 UTC, 0 replies.
- flink sql注册kafka映射表，读取数据实时写入hive报错No operators defined in streaming topology. Cannot generate StreamGraph. - posted by me <me...@lishiyu.cn> on 2020/10/14 02:09:19 UTC, 0 replies.
- 回复: flink-SQL1.11版本对map类型中value的空指针异常 - posted by 史 正超 <sh...@outlook.com> on 2020/10/14 02:19:27 UTC, 4 replies.
- flink1.11加载外部jar包进行UDF注册 - posted by "amenhub@163.com" <am...@163.com> on 2020/10/14 03:19:57 UTC, 7 replies.
- Re: Re:HistoryServer完成任务丢失的问题 - posted by zhisheng <zh...@gmail.com> on 2020/10/14 03:38:12 UTC, 0 replies.
- Re: flink 1.11.2 Table sql聚合后设置并行度为2及以上，数据无法输出 - posted by Peihui He <pe...@gmail.com> on 2020/10/14 03:52:07 UTC, 1 replies.
- 回复: 回复: flink-SQL1.11版本对map类型中value的空指针异常 - posted by 史 正超 <sh...@outlook.com> on 2020/10/14 05:22:20 UTC, 2 replies.
- 求问我的pyflink wordcount为何没有任何输出？谢谢 - posted by 大森林 <ap...@foxmail.com> on 2020/10/14 05:33:38 UTC, 0 replies.
- kafka table connector保留多久的数据 - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/10/14 08:12:21 UTC, 1 replies.
- pyflink sql select带特殊符号的字段名 - posted by whh_960101 <wh...@163.com> on 2020/10/14 08:20:56 UTC, 0 replies.
- flinksql引入flink-parquet_2.11任务提交失败 - posted by 奔跑的小飞袁 <s_...@126.com> on 2020/10/14 08:55:19 UTC, 0 replies.
- 回复：flink1.11连接mysql问题 - posted by superainbower <su...@163.com> on 2020/10/14 09:33:30 UTC, 0 replies.
- Re: flinksql如何控制结果输出的频率 - posted by smallwong <sm...@163.com> on 2020/10/14 10:08:29 UTC, 1 replies.
- pyflink sql中select,where都带udf，其中一个udf失效 - posted by whh_960101 <wh...@163.com> on 2020/10/15 03:46:28 UTC, 9 replies.
- flink sql添加 null值 字段 - posted by Dream-底限 <zh...@akulaku.com> on 2020/10/15 04:18:15 UTC, 1 replies.
- Re: blob server相关，文件找不到 - posted by janick <ja...@163.com> on 2020/10/15 06:33:08 UTC, 0 replies.
- 中午十二点的数据无法进入窗口计算 - posted by 赫里斯汀的树 <58...@qq.com> on 2020/10/15 07:47:47 UTC, 0 replies.
- pyflink Table object如何打印出其中内容方便调试 - posted by whh_960101 <wh...@163.com> on 2020/10/15 08:38:52 UTC, 1 replies.
- kafka topic字段 不全的统计场景 - posted by 史 正超 <sh...@outlook.com> on 2020/10/15 09:00:41 UTC, 1 replies.
- flink sql state queryable ？ - posted by "kandy.wang" <ka...@163.com> on 2020/10/15 09:50:58 UTC, 0 replies.
- 回复: kafka topic字段 不全的统计场景 - posted by 史 正超 <sh...@outlook.com> on 2020/10/15 12:55:11 UTC, 0 replies.
- Flink作业运行失败 - posted by gangzi <11...@qq.com> on 2020/10/15 14:05:43 UTC, 7 replies.
- 回复：中午十二点的数据无法进入窗口计算 - posted by 熊云昆 <xi...@163.com> on 2020/10/15 23:27:24 UTC, 2 replies.
- flink 自定义udf注册后不能使用 - posted by 奔跑的小飞袁 <s_...@126.com> on 2020/10/16 03:30:19 UTC, 0 replies.
- 回复: flink 自定义udf注册后不能使用 - posted by 史 正超 <sh...@outlook.com> on 2020/10/16 03:45:42 UTC, 3 replies.
- 回复：回复: flink 自定义udf注册后不能使用 - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/10/16 06:20:50 UTC, 2 replies.
- 回复: 回复：回复: flink 自定义udf注册后不能使用 - posted by 史 正超 <sh...@outlook.com> on 2020/10/16 07:26:40 UTC, 0 replies.
- 回复: 回复: flink 自定义udf注册后不能使用 - posted by "amenhub@163.com" <am...@163.com> on 2020/10/16 07:45:40 UTC, 0 replies.
- 回复：回复: 回复: flink 自定义udf注册后不能使用 - posted by 罗显宴 <15...@163.com> on 2020/10/16 08:20:38 UTC, 1 replies.
- 关于内存大小设置以及预测 - posted by Kyle Zhang <sh...@gmail.com> on 2020/10/16 09:34:07 UTC, 2 replies.
- flink sql 窗口函数对分区的这个列进行过滤 - posted by kcz <57...@qq.com> on 2020/10/16 09:50:24 UTC, 0 replies.
- Flink SQL 1.11如何获取执行计划 & StreamGraph - posted by zilong xiao <ac...@gmail.com> on 2020/10/16 12:56:13 UTC, 1 replies.
- hive streaning 问题请教 - posted by McClone <ab...@163.com> on 2020/10/16 13:31:55 UTC, 1 replies.
- flink sql count distinct结果会变小 - posted by 867127831 <86...@qq.com> on 2020/10/17 08:24:24 UTC, 0 replies.
- 请问pyflink的udf是否必须是python3.5谢谢！ - posted by 大森林 <ap...@foxmail.com> on 2020/10/17 09:54:07 UTC, 2 replies.
- registerTableSink方法未来如何变化？ - posted by hua mulan <de...@outlook.com> on 2020/10/17 11:59:09 UTC, 1 replies.
- 求问这段flink sql代码中的 result如何输出 - posted by 大森林 <ap...@foxmail.com> on 2020/10/18 03:26:56 UTC, 1 replies.
- 回复：flink sql count distinct结果会变小 - posted by 熊云昆 <xi...@163.com> on 2020/10/19 00:03:46 UTC, 2 replies.
- flink table转datastream失败 - posted by Dream-底限 <zh...@akulaku.com> on 2020/10/19 02:50:33 UTC, 4 replies.
- 回复： 请问pyflink的udf是否必须是python3.5谢谢！ - posted by 大森林 <ap...@foxmail.com> on 2020/10/19 03:21:39 UTC, 2 replies.
- How to use - posted by fangzhou ding <no...@gmail.com> on 2020/10/19 04:10:03 UTC, 1 replies.
- pyflink下同时读查mysql优化求助 - posted by 小学生 <20...@qq.com> on 2020/10/19 05:19:34 UTC, 1 replies.
- 求助：如何处理数据不连续导致状态无法清理 - posted by x <35...@qq.com> on 2020/10/19 06:54:54 UTC, 1 replies.
- SQL interval join 问题 - posted by Mic <sh...@163.com> on 2020/10/19 07:03:54 UTC, 2 replies.
- 请问现在Flink支持动态扩缩容吗？ - posted by 林影 <br...@gmail.com> on 2020/10/19 07:06:42 UTC, 1 replies.
- Re:Re: flink sql 更新mysql字段 - posted by Michael Ran <gr...@163.com> on 2020/10/19 07:09:25 UTC, 0 replies.
- flink1.10 stop with a savepoint失败 - posted by Robin Zhang <vi...@outlook.com> on 2020/10/19 07:42:06 UTC, 4 replies.
- flinkSQL1.11写出数据到jdbc fleld type do not match - posted by 奔跑的小飞袁 <s_...@126.com> on 2020/10/19 08:29:10 UTC, 1 replies.
- Flink 1.11里如何parse出未解析的执行计划 - posted by 马阳阳 <ma...@163.com> on 2020/10/19 09:57:47 UTC, 1 replies.
- 回复： 求助：如何处理数据不连续导致状态无法清理 - posted by x <35...@qq.com> on 2020/10/19 10:23:25 UTC, 0 replies.
- flink1.10.0 batch模式写入hive失败，找不到TableSinkFactory - posted by Allen <91...@qq.com> on 2020/10/19 16:31:57 UTC, 2 replies.
- 回复：请问现在Flink支持动态扩缩容吗？ - posted by 熊云昆 <xi...@163.com> on 2020/10/19 23:15:02 UTC, 1 replies.
- 答复: Flink 1.11里如何parse出未解析的执行计划 - posted by 刘首维 <li...@autohome.com.cn> on 2020/10/20 02:22:10 UTC, 1 replies.
- pyflink1.11.0 kafka connector如果有访问权限 - posted by whh_960101 <wh...@163.com> on 2020/10/20 02:23:16 UTC, 0 replies.
- flink更换scala版本问题 - posted by 赵一旦 <hi...@gmail.com> on 2020/10/20 03:13:16 UTC, 0 replies.
- 关于flink-sql count/sum 数据如何每天重新计算 - posted by 夜思流年梦 <li...@163.com> on 2020/10/20 03:57:37 UTC, 1 replies.
- 单任务多条流的逻辑报错 - posted by "freeza1982@outlook.com" <fr...@outlook.com> on 2020/10/20 05:48:20 UTC, 2 replies.
- flinksql报错Could not find any factory for identifier 'elasticsearch-6' that implements 'org.apache.flink.table.factories.DynamicTableSinkFactory' in the classpath. - posted by 奔跑的小飞袁 <s_...@126.com> on 2020/10/20 06:36:59 UTC, 6 replies.
- flink cdc读取mysql，执行sql业务逻辑， sink到mysql的bug - posted by air23 <wa...@163.com> on 2020/10/20 07:45:53 UTC, 0 replies.
- flink 报错 java.io.IOException: GET operation failed: Server side error: BLOB size exceeds the maximum size (2 GB). - posted by 欧阳苗 <a9...@qq.com> on 2020/10/20 07:57:59 UTC, 0 replies.
- 回复：flink 报错 java.io.IOException: GET operation failed: Server side error: BLOB size exceeds the maximum size (2 GB). - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/10/20 09:39:35 UTC, 0 replies.
- 求教，如果想要从flinksql中提取出列级别的血缘关系，请问有什么好的方案吗 - posted by dawangli <da...@163.com> on 2020/10/20 10:42:01 UTC, 2 replies.
- pyflink1.11.0 报错JobExecutionException: Job execution failed. - posted by whh_960101 <wh...@163.com> on 2020/10/20 11:38:20 UTC, 4 replies.
- cep调用pattern前使用keyby报错：getBufferBuilder越界 - posted by Wz <32...@qq.com> on 2020/10/20 12:41:31 UTC, 0 replies.
- flink slot资源隔离 - posted by 赵一旦 <hi...@gmail.com> on 2020/10/21 02:06:24 UTC, 3 replies.
- 回复：flink slot资源隔离 - posted by 吴磊 <wu...@foxmail.com> on 2020/10/21 02:12:17 UTC, 0 replies.
- 几十G状态数据时，savepoint失败 - posted by 廖辉轩 <72...@qq.com> on 2020/10/21 06:09:45 UTC, 2 replies.
- Re:Re: flink sql ddl 是否支持映射多层json - posted by Roc Marshal <fl...@126.com> on 2020/10/21 06:35:58 UTC, 1 replies.
- 请教 table /sql API, 窗口frist/last value - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/10/21 08:27:14 UTC, 3 replies.
- StreamSQL 进行窗口计算的疑问 - posted by Roc Marshal <fl...@126.com> on 2020/10/21 09:09:29 UTC, 3 replies.
- Job manager 异常信息 - posted by Qishang <zh...@gmail.com> on 2020/10/21 09:17:40 UTC, 1 replies.
- Flink-1.11.1 Rest API使用 - posted by "amenhub@163.com" <am...@163.com> on 2020/10/21 11:11:05 UTC, 5 replies.
- flink sql CDC 同步到 hive的问题咨询 - posted by zhongbaoluo <zh...@shxgroup.net> on 2020/10/21 11:55:21 UTC, 0 replies.
- 在使用hive catalog的情况下 json format 大小写问题 - posted by 王刚 <wa...@autohome.com.cn> on 2020/10/21 12:08:08 UTC, 1 replies.
- 回复: flink sql CDC 同步到 hive的问题咨询 - posted by 史 正超 <sh...@outlook.com> on 2020/10/21 14:23:10 UTC, 0 replies.
- 回复：Re:flink1.10.0 batch模式写入hive失败，找不到TableSinkFactory - posted by Allen <91...@qq.com> on 2020/10/21 14:37:35 UTC, 2 replies.
- 回复：Flink 1.11里如何parse出未解析的执行计划 - posted by kcz <57...@qq.com> on 2020/10/22 01:38:01 UTC, 0 replies.
- FlinkSQL 窗口内排序使用方法疑问 - posted by Roc Marshal <fl...@126.com> on 2020/10/22 02:51:41 UTC, 1 replies.
- FlinkSQL 窗口使用问题 - posted by Roc Marshal <fl...@126.com> on 2020/10/22 03:09:09 UTC, 2 replies.
- pyflink1.11.0 如果elasticsearch host有访问权限，connector如何写入用户名密码 - posted by whh_960101 <wh...@163.com> on 2020/10/22 07:47:16 UTC, 7 replies.
- flink sql 写入hive问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/10/22 09:22:10 UTC, 1 replies.
- Flink1.10 history server无法监控 FlinkSQL任务 - posted by Robin Zhang <vi...@outlook.com> on 2020/10/22 10:11:31 UTC, 4 replies.
- pyflink和pyspark中引用包不兼容，li例如pyspark 中pandas版本1.1.4 而pyflink是>=0.23<0.25 - posted by xuzh <hu...@qq.com> on 2020/10/22 10:37:50 UTC, 1 replies.
- 使用Flink Table API & SQL编写流应用，SQL中的NOW()等时间函数如何理解 - posted by Longdexin <27...@qq.com> on 2020/10/22 12:13:03 UTC, 2 replies.
- Re:Re: Flink 读取 Kafka 多个 Partition 问题， - posted by Lynn Chen <al...@163.com> on 2020/10/22 16:13:34 UTC, 4 replies.
- 请问Oracle作为维表注册到flinksql环境怎么支持？ - posted by Bruce <65...@qq.com> on 2020/10/23 01:26:02 UTC, 0 replies.
- pyflink和flink版本的兼容性问题 - posted by whh_960101 <wh...@163.com> on 2020/10/23 03:40:48 UTC, 1 replies.
- 请问flink1.11版本如何设置checkpoint的默认保存个数 - posted by chenxuying <cx...@163.com> on 2020/10/23 06:05:32 UTC, 2 replies.
- Flink mysqlCDC ,然后jdbc sink 到mysql 乱序问题 - posted by air23 <wa...@163.com> on 2020/10/23 06:21:19 UTC, 3 replies.
- 回复：Flink mysqlCDC ,然后jdbc sink 到mysql 乱序问题 - posted by 熊云昆 <xi...@163.com> on 2020/10/23 11:12:20 UTC, 5 replies.
- pyflink问题求助（入门级） - posted by 洗你的头 <12...@qq.com> on 2020/10/25 10:41:14 UTC, 3 replies.
- window和timeWindow的区别 - posted by Natasha <13...@163.com> on 2020/10/25 13:19:13 UTC, 1 replies.
- flink任务启动报错 Cannot instantiate user function - posted by "freeza1982@outlook.com" <fr...@outlook.com> on 2020/10/25 14:18:19 UTC, 0 replies.
- 回复：window和timeWindow的区别 - posted by Natasha <13...@163.com> on 2020/10/26 00:58:45 UTC, 0 replies.
- 关于flink1.11 新版本使用dataStreamEnv.execute 和tableEnv.execute出现No operators defined in streaming topology. Cannot generate StreamGraph.的问题 - posted by me <me...@lishiyu.cn> on 2020/10/26 01:12:41 UTC, 1 replies.
- 回复: Flink mysqlCDC ,然后jdbc sink 到mysql 乱序问题 - posted by 史 正超 <sh...@outlook.com> on 2020/10/26 04:11:59 UTC, 1 replies.
- 回复： pyflink问题求助（入门级） - posted by 洗你的头 <12...@qq.com> on 2020/10/26 04:20:28 UTC, 0 replies.
- flinksql指定kafka多topic - posted by 奔跑的小飞袁 <s_...@126.com> on 2020/10/26 06:08:26 UTC, 0 replies.
- 回复：flinksql指定kafka多topic - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/10/26 06:16:03 UTC, 1 replies.
- 回复：回复：flinksql指定kafka多topic - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/10/26 06:29:03 UTC, 1 replies.
- flink state.savepoints.dir 目录配置问题 - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/10/26 06:37:44 UTC, 4 replies.
- 回复：回复：回复：flinksql指定kafka多topic - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/10/26 06:45:55 UTC, 2 replies.
- 求助：kafka broker 宕机重启后，程序卡住无法继续 - posted by x <35...@qq.com> on 2020/10/26 07:19:13 UTC, 0 replies.
- flinksql 不支持 % 运算 - posted by 夜思流年梦 <li...@163.com> on 2020/10/26 08:16:16 UTC, 3 replies.
- 回复：关于flink1.11 新版本使用dataStreamEnv.execute 和tableEnv.execute出现No operators defined in streaming topology. Cannot generate StreamGraph.的问题 - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/10/26 08:23:43 UTC, 0 replies.
- pyflink 如何正确设置高速度？（如何提速） - posted by 洗你的头 <12...@qq.com> on 2020/10/26 08:32:18 UTC, 2 replies.
- 提交pyflink作业到YARN集群报错 - posted by whh_960101 <wh...@163.com> on 2020/10/26 08:38:50 UTC, 1 replies.
- Re: Flink 1.11 SQL作业中调用UDTF 出现“No match found for function signature ”异常 - posted by tonychen <to...@qq.com> on 2020/10/26 10:48:50 UTC, 1 replies.
- 回复： pyflink 如何正确设置高速度？（如何提速） - posted by 洗你的头 <12...@qq.com> on 2020/10/26 15:04:14 UTC, 0 replies.
- sql-client 连接hive报错 TTransportException - posted by RS <ti...@163.com> on 2020/10/27 01:57:12 UTC, 2 replies.
- 容忍checkpoint 失败次数和重启策略冲突吗 - posted by smq <37...@qq.com> on 2020/10/27 03:25:42 UTC, 1 replies.
- Heartbeat of TaskManager with id xxx timed out - posted by "freeza1982@outlook.com" <fr...@outlook.com> on 2020/10/27 05:45:34 UTC, 1 replies.
- 回复：容忍checkpoint 失败次数和重启策略冲突吗 - posted by smq <37...@qq.com> on 2020/10/27 05:57:48 UTC, 0 replies.
- 请问我把checkpoint恢复到了23号的时间，为什么启动服务后，kafka消息还是从最新的开始消费， 不是应该从23号开始消费吗？ - posted by sun <13...@qq.com> on 2020/10/27 06:30:10 UTC, 0 replies.
- pyflink读取csv源表时，如何跳过标题行？如何选取特定的列？ - posted by 洗你的头 <12...@qq.com> on 2020/10/27 06:36:17 UTC, 1 replies.
- Re: Re:无法从checkpoint中恢复state - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/10/27 07:51:19 UTC, 1 replies.
- 关于flink-sql 维表join问题 - posted by 夜思流年梦 <li...@163.com> on 2020/10/27 08:08:30 UTC, 3 replies.
- LocalBufferPoo死锁 - posted by 1548069580 <15...@qq.com> on 2020/10/27 10:50:45 UTC, 2 replies.
- 回复：LocalBufferPoo死锁 - posted by 熊云昆 <xi...@163.com> on 2020/10/27 11:19:33 UTC, 0 replies.
- 请问批处理有反压嘛？ - posted by 请叫我雷锋 <85...@qq.com> on 2020/10/27 12:02:18 UTC, 1 replies.
- Re: flink1.11日志上报 - posted by Storm☀️ <st...@163.com> on 2020/10/27 12:37:09 UTC, 2 replies.
- the remote task manager was lost - posted by guanxianchun <ps...@163.com> on 2020/10/28 02:57:57 UTC, 0 replies.
- Flink是否可以动态调整任务并行度 - posted by "ZT.Ren" <18...@163.com> on 2020/10/28 07:53:41 UTC, 2 replies.
- flinkSQL针对join操作设置不同窗口 - posted by 奔跑的小飞袁 <s_...@126.com> on 2020/10/28 08:06:39 UTC, 1 replies.
- 回复: Re: 关于flink-sql 维表join问题 - posted by 史 正超 <sh...@outlook.com> on 2020/10/28 08:12:46 UTC, 0 replies.
- flink hive Streaming查询不到数据的问题 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/10/28 08:13:44 UTC, 3 replies.
- tumbling的窗口更新随着job运行时间越长，delay越久，sliding不会 - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/10/28 09:21:24 UTC, 1 replies.
- 通过算子的构造方法传递变量失效 - posted by "freeza1982@outlook.com" <fr...@outlook.com> on 2020/10/28 09:29:58 UTC, 1 replies.
- 关于并行下watermark不生成 - posted by BenChen <ha...@163.com> on 2020/10/28 10:54:22 UTC, 3 replies.
- No pooled slot available and request to ResourceManager for new slot failed - posted by "marble.zhong@coinflex.com.INVALID" <ma...@coinflex.com.INVALID> on 2020/10/28 10:57:59 UTC, 2 replies.
- flink集群安装后启动报错 - posted by 赫里斯汀的树 <58...@qq.com> on 2020/10/28 11:14:53 UTC, 0 replies.
- Checkpoint size的问题 - posted by gsralex <gs...@163.com> on 2020/10/28 11:17:18 UTC, 1 replies.
- 官方后续会有支持kafka lag metric的计划吗 - posted by silence <sl...@aliyun.com.INVALID> on 2020/10/28 11:54:50 UTC, 3 replies.
- 维表选择 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/10/29 01:36:27 UTC, 0 replies.
- flink1.11 kafka connector - posted by Dream-底限 <zh...@akulaku.com> on 2020/10/29 03:26:07 UTC, 3 replies.
- flink1.11 elasticsearch connector - posted by 赵帅 <zh...@2b13c.com> on 2020/10/29 07:36:53 UTC, 1 replies.
- Flink消费LDAP Kafka - posted by hua mulan <de...@outlook.com> on 2020/10/29 07:47:50 UTC, 0 replies.
- JDBC 并发写入量大时挂掉 - posted by LittleFall <15...@qq.com> on 2020/10/29 08:18:25 UTC, 3 replies.
- Flink程序连接Kafka类型不匹配问题 - posted by Natasha <13...@163.com> on 2020/10/29 09:52:00 UTC, 4 replies.
- 【咨询JM磁盘磁盘打满问题】 - posted by void <20...@qq.com> on 2020/10/29 10:49:25 UTC, 1 replies.
- 回复：Flink程序连接Kafka类型不匹配问题 - posted by Natasha <13...@163.com> on 2020/10/29 11:42:16 UTC, 0 replies.
- 讨论分析：数据类型对于shuffle时数据传输IO速度的影响（数十倍的差距） - posted by Husky Zeng <56...@qq.com> on 2020/10/30 02:22:54 UTC, 7 replies.
- flink cep超时事件的问题 - posted by sunfulin <su...@163.com> on 2020/10/30 03:01:23 UTC, 2 replies.
- flink实时流中如何实时获取当前时间 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/10/30 03:17:27 UTC, 0 replies.
- 回复： Flink程序连接Kafka类型不匹配问题 - posted by Natasha <13...@163.com> on 2020/10/30 03:27:11 UTC, 1 replies.
- minibatch+状态ttl设置不生效问题如何优化 - posted by 雨后彩虹 <29...@qq.com> on 2020/10/30 03:45:21 UTC, 1 replies.
- flink任务挂掉后自动重启 - posted by bradyMk <zh...@126.com> on 2020/10/30 03:51:29 UTC, 2 replies.
- 回复: flink实时流中如何实时获取当前时间 - posted by 史 正超 <sh...@outlook.com> on 2020/10/30 06:48:22 UTC, 0 replies.
- TUMBLE函数不支持 回撤流 - posted by 夜思流年梦 <li...@163.com> on 2020/10/30 06:48:31 UTC, 3 replies.
- 回复: 回复: flink实时流中如何实时获取当前时间 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/10/30 06:50:00 UTC, 0 replies.
- 回复: flink任务挂掉后自动重启 - posted by 史 正超 <sh...@outlook.com> on 2020/10/30 07:05:38 UTC, 1 replies.
- Flink Jdbc sink写入多表如何实现 - posted by 张健 <zh...@163.com> on 2020/10/30 08:10:33 UTC, 2 replies.
- SQL从1.9迁移到1.11的问题 - posted by izual <iz...@163.com> on 2020/10/30 09:03:44 UTC, 0 replies.
- Flink反压定位算子 - posted by 赵一旦 <hi...@gmail.com> on 2020/10/30 09:42:22 UTC, 2 replies.
- 回复：Flink反压定位算子 - posted by 范瑞 <83...@qq.com> on 2020/10/30 09:47:07 UTC, 0 replies.
- flink-cdc-mysql 使用时遇到的问题 - posted by yangxusun9 <ya...@163.com> on 2020/10/30 09:58:31 UTC, 2 replies.
- 单个sink表 和多个source表的统计 - posted by 史 正超 <sh...@outlook.com> on 2020/10/30 10:27:02 UTC, 0 replies.
- 回复：flink cep超时事件的问题 - posted by 熊云昆 <xi...@163.com> on 2020/10/30 10:59:05 UTC, 0 replies.
- flink 1.11.2 keyby 更换partition - posted by Peihui He <pe...@gmail.com> on 2020/10/30 11:23:31 UTC, 0 replies.
- 回复: flink 1.11.2 keyby 更换partition - posted by Zhang Yuxiao <yx...@outlook.com> on 2020/10/31 01:37:55 UTC, 0 replies.
- Re: 数据类型对于shuffle时数据传输IO速度有影响吗？ - posted by Husky Zeng <56...@qq.com> on 2020/10/31 01:41:37 UTC, 0 replies.
- flink mysql cdc + hive streaming疑问 - posted by 陈帅 <ca...@gmail.com> on 2020/10/31 04:06:14 UTC, 2 replies.
- 回复：flink mysql cdc + hive streaming疑问 - posted by 罗显宴 <15...@163.com> on 2020/10/31 05:25:52 UTC, 0 replies.
- pyflink的where该如何使用？如何筛选？ - posted by 洗你的头 <12...@qq.com> on 2020/10/31 13:15:16 UTC, 0 replies.
- RichFlatMapFunction => NoClassDefFoundError - posted by Lynn Chen <al...@163.com> on 2020/10/31 16:36:07 UTC, 0 replies.