You are viewing a plain text version of this content. The canonical link for it is here.
- 请教 如何使用TableAPI connector将一个字段定义为rowtime属性 - posted by hegongyin <he...@huawei.com> on 2019/08/01 02:26:21 UTC, 0 replies.
- Re: env.readFile只读取新文件 - posted by Biao Liu <mm...@gmail.com> on 2019/08/01 06:06:29 UTC, 0 replies.
- Re: StreamingFileSink自定义输出的文件名 - posted by Biao Liu <mm...@gmail.com> on 2019/08/01 06:13:56 UTC, 0 replies.
- BucketingSink 内存使用分析 - posted by 九思 <10...@qq.com> on 2019/08/01 10:06:59 UTC, 1 replies.
- Re: 请教Flink SQL watermark遇到未来时间的处理问题 - posted by zhisheng <zh...@gmail.com> on 2019/08/01 10:49:36 UTC, 0 replies.
- Buffer pool is destroyed - posted by 李龙 <l9...@163.com> on 2019/08/05 02:41:21 UTC, 1 replies.
- 回复: Buffer pool is destroyed - posted by "tangjunliang@huitongjy.com" <ta...@huitongjy.com> on 2019/08/05 03:26:19 UTC, 0 replies.
- flink基于yarn的方式,整合Promethues,如何确定jm和tm? - posted by 陈帅 <ch...@gmail.com> on 2019/08/05 03:42:11 UTC, 1 replies.
- flink 动态表输出问题 - posted by 金圣哲 <ki...@icloud.com.INVALID> on 2019/08/06 03:26:06 UTC, 0 replies.
- Flink RocksDBStateBackend 问题 - posted by lvwenyuan <lv...@163.com> on 2019/08/06 03:39:30 UTC, 5 replies.
- jobmanager 日志异常 - posted by 戴嘉诚 <a7...@gmail.com> on 2019/08/06 03:39:43 UTC, 2 replies.
- 答复: Re: Flink RocksDBStateBackend 问题 - posted by 戴嘉诚 <a7...@gmail.com> on 2019/08/06 04:01:52 UTC, 0 replies.
- Flink sql join问题 - posted by huang <hu...@126.com> on 2019/08/06 06:27:52 UTC, 1 replies.
- 答复: jobmanager 日志异常 - posted by 戴嘉诚 <a7...@gmail.com> on 2019/08/06 08:02:41 UTC, 0 replies.
- 任务异常捕获疑问 - posted by zq wang <wa...@gmail.com> on 2019/08/06 09:28:47 UTC, 0 replies.
- submit jobGraph error on server side - posted by 王智 <be...@foxmail.com> on 2019/08/06 11:12:41 UTC, 2 replies.
- AsyncIO 用Redis做缓存 - posted by 王佩 <wa...@cmcm.com> on 2019/08/06 14:09:14 UTC, 2 replies.
- 如何获取Flink table api/sql code gen 代码 - posted by Vincent Cai <ca...@foxmail.com> on 2019/08/06 16:02:32 UTC, 1 replies.
- Flink官网barrier疑问 - posted by ❄ <83...@qq.com> on 2019/08/07 06:11:10 UTC, 1 replies.
- 回复:Re: submit jobGraph error on server side - posted by 王智 <be...@foxmail.com> on 2019/08/07 06:32:42 UTC, 0 replies.
- 关于event-time的定义与产生时间戳位置的问题。 - posted by "xiaohei.info" <xi...@gmail.com> on 2019/08/07 07:47:41 UTC, 3 replies.
- flink-1.8.1 yarn per job模式使用 - posted by 李玉环 <bd...@gmail.com> on 2019/08/07 11:15:28 UTC, 3 replies.
- 回复:Re: Re: submit jobGraph error on server side - posted by 王智 <be...@foxmail.com> on 2019/08/08 06:05:22 UTC, 0 replies.
- flink 结合canal统计订单gmv - posted by 王飞 <wa...@163.com> on 2019/08/08 08:53:14 UTC, 4 replies.
- Fwd: need help - posted by 陈某 <cl...@gmail.com> on 2019/08/08 11:32:53 UTC, 2 replies.
- CsvTableSink 目录没有写入具体的数据 - posted by "wanglei2@geekplus.com.cn" <wa...@geekplus.com.cn> on 2019/08/08 11:37:24 UTC, 4 replies.
- 如何讓兩個 SQL 使用相同的 KafkaTableSource - posted by Tony Wei <to...@gmail.com> on 2019/08/09 02:46:40 UTC, 0 replies.
- 恢复savepoint,除了命令行,能通过代码获取吗? - posted by liu zhongfeng <zh...@outlook.com> on 2019/08/09 02:56:18 UTC, 1 replies.
- 关于外部请求支持sql的方式。 - posted by 白京京 <ba...@jd.com> on 2019/08/09 05:53:17 UTC, 0 replies.
- 有一些TaskManager的slot不可用,尽管没有任务正在运行 - posted by "pengchenglin@bonc.com.cn" <pe...@bonc.com.cn> on 2019/08/09 08:05:31 UTC, 3 replies.
- flink1.10版本连接hive报错 - posted by 苏 欣 <se...@live.com> on 2019/08/09 09:40:48 UTC, 1 replies.
- 回复: flink 结合canal统计订单gmv - posted by 1101300123 <hd...@163.com> on 2019/08/09 12:08:01 UTC, 0 replies.
- 答复: 恢复savepoint,除了命令行,能通过代码获取吗? - posted by 戴嘉诚 <a7...@gmail.com> on 2019/08/09 12:54:49 UTC, 0 replies.
- Flink命令提交任务时是否支持配置文件与任务jar包分离 - posted by "jinxiaolong_along@163.com" <ji...@163.com> on 2019/08/09 16:33:27 UTC, 0 replies.
- flink源码编译可以不编译scala代码吗 - posted by 苟刚 <go...@163.com> on 2019/08/10 15:08:45 UTC, 2 replies.
- 回复:Flink命令提交任务时是否支持配置文件与任务jar包分离 - posted by huanqinghappy <hu...@aliyun.com.INVALID> on 2019/08/10 16:48:05 UTC, 2 replies.
- 回复: flink1.10版本连接hive报错 - posted by "athlon512@gmail.com" <at...@gmail.com> on 2019/08/12 01:35:49 UTC, 0 replies.
- 答复: 回复: flink 1.8.1 时间窗口无法关闭以及消息丢失的问题 - posted by "Yuan,Youjun" <yu...@baidu.com> on 2019/08/12 05:45:18 UTC, 0 replies.
- 回复: Flink命令提交任务时是否支持配置文件与任务jar包分离 - posted by venn <wx...@163.com> on 2019/08/12 05:53:00 UTC, 0 replies.
- 答复: flink1.10版本连接hive报错 - posted by 苏 欣 <se...@live.com> on 2019/08/12 11:10:26 UTC, 0 replies.
- Re: [Discuss] What should the "Data Source" be translated into Chinese - posted by Kurt Young <yk...@gmail.com> on 2019/08/13 08:15:39 UTC, 13 replies.
- flink on yarn,提交方式是per job的话,如何保证高可用? - posted by 陈帅 <ch...@gmail.com> on 2019/08/13 08:51:14 UTC, 2 replies.
- 回复:Re: [Discuss] What should the "Data Source" be translated into Chinese - posted by da...@sina.com on 2019/08/13 10:07:04 UTC, 0 replies.
- 回复: [Discuss] What should the "Data Source" be translated into Chinese - posted by hsw <hs...@cjyun.org> on 2019/08/13 10:22:58 UTC, 1 replies.
- flink KeyedBroadcastProcessFunction 不能触发onTimer - posted by "athlon512@gmail.com" <at...@gmail.com> on 2019/08/14 02:14:00 UTC, 0 replies.
- 回复: flink KeyedBroadcastProcessFunction 不能触发onTimer - posted by "athlon512@gmail.com" <at...@gmail.com> on 2019/08/14 02:34:32 UTC, 0 replies.
- How to load udf jars in flink program - posted by 刘建刚 <li...@gmail.com> on 2019/08/15 09:31:33 UTC, 3 replies.
- 答复: How to load udf jars in flink program - posted by 苏 欣 <se...@live.com> on 2019/08/15 09:54:25 UTC, 0 replies.
- 请问TableAPI如何中一个FileSystem数据源如何指定多个文件夹作为path - posted by hegongyin <he...@huawei.com> on 2019/08/16 04:14:58 UTC, 0 replies.
- flink提交offset失败 - posted by 孙福 <su...@163.com> on 2019/08/16 09:27:41 UTC, 0 replies.
- 回复:flink提交offset失败 - posted by 龚中强 <76...@qq.com> on 2019/08/16 09:34:16 UTC, 2 replies.
- Flink 在什么时候检查算子中对象的序列化? - posted by wxy <da...@163.com> on 2019/08/16 11:17:49 UTC, 1 replies.
- Weekly Community Update 2019/33, Personal Chinese Version - posted by Zili Chen <wa...@gmail.com> on 2019/08/19 04:27:21 UTC, 3 replies.
- 用python写flink程序,从哪里import各种operation? - posted by 孙永超 <10...@tongji.edu.cn> on 2019/08/20 07:39:32 UTC, 1 replies.
- build Flink master brach fail due to npm - posted by 刘波 <10...@qq.com> on 2019/08/20 08:22:53 UTC, 0 replies.
- Flink CEP 支持Pattern以贪婪量词结尾吗? - posted by 庞泳佑 <18...@163.com> on 2019/08/20 08:51:06 UTC, 0 replies.
- Flink编译问题 - posted by 戴嘉诚 <a7...@gmail.com> on 2019/08/20 09:52:27 UTC, 0 replies.
- Re: build Flink master brach fail due to npm - posted by Biao Liu <mm...@gmail.com> on 2019/08/21 02:34:08 UTC, 0 replies.
- flink任务提交问题 - posted by IORI <32...@qq.com> on 2019/08/21 09:32:23 UTC, 0 replies.
- flink频繁报向kafka提交offset失败的错误 - posted by ye...@sina.com on 2019/08/21 12:26:16 UTC, 1 replies.
- FLINK WEEKLY 2019/33 - posted by Zili Chen <wa...@gmail.com> on 2019/08/21 13:44:22 UTC, 0 replies.
- Flink-Netty-Connector收到消息后如何回复消息? - posted by 278391968 <27...@qq.com> on 2019/08/22 02:11:36 UTC, 0 replies.
- flink启动等待10分钟问题 - posted by 々守护々 <34...@qq.com> on 2019/08/22 03:04:09 UTC, 2 replies.
- 回复: flink启动等待10分钟问题 - posted by 々守护々 <34...@qq.com> on 2019/08/22 03:18:22 UTC, 5 replies.
- Springboot整合Flink - posted by "jiang512bo@163.com" <ji...@163.com> on 2019/08/22 03:30:08 UTC, 1 replies.
- 回复: 回复: flink启动等待10分钟问题 - posted by 々守护々 <34...@qq.com> on 2019/08/22 03:32:46 UTC, 2 replies.
- 回复: 回复: flink启动等待10分钟问题 - posted by "tangjunliang@huitongjy.com" <ta...@huitongjy.com> on 2019/08/22 03:34:27 UTC, 0 replies.
- 回复: Springboot整合Flink - posted by "tangjunliang@huitongjy.com" <ta...@huitongjy.com> on 2019/08/22 03:35:46 UTC, 0 replies.
- 回复: Re: 流表在与维表join时,维表没有动态查询 - posted by "sjlsumaitong@163.com" <sj...@163.com> on 2019/08/22 06:19:55 UTC, 0 replies.
- Flink Kafka Connector相关问题 - posted by 戴鑫铉 <da...@gmail.com> on 2019/08/22 11:21:23 UTC, 2 replies.
- Flink 实时监控目录下的新文件会有文件被遗漏 - posted by 王佩 <wa...@cmcm.com> on 2019/08/23 01:25:36 UTC, 2 replies.
- FLINK TABLE API 自定义聚合函数UDAF从check point恢复任务报状态序列化不兼容问题( For heap backends, the new state serializer must not be incompatible) - posted by orlando qi <qi...@gmail.com> on 2019/08/23 03:08:04 UTC, 2 replies.
- flink1.9.0 LOCAL_WEBSERVER 问题 - posted by hb <34...@163.com> on 2019/08/23 05:21:42 UTC, 17 replies.
- flink-1.9 打包问题 - posted by Jimmy Wong <wa...@163.com> on 2019/08/23 08:56:57 UTC, 0 replies.
- 回复: flink-1.9 打包问题 - posted by 苏 欣 <se...@live.com> on 2019/08/23 09:21:27 UTC, 0 replies.
- test - posted by 张金 <ch...@icloud.com.INVALID> on 2019/08/24 04:45:19 UTC, 0 replies.
- PathIsNotEmptyDirectoryException 异常 - posted by 王佩 <wa...@cmcm.com> on 2019/08/24 08:49:36 UTC, 3 replies.
- flink1.9 blink planner table ddl 使用问题 - posted by hb <34...@163.com> on 2019/08/26 01:52:25 UTC, 4 replies.
- 任务内存增长 - posted by 张坤 <ku...@okcoin.net> on 2019/08/26 02:45:36 UTC, 4 replies.
- FLINK WEEKLY 2019/34 - posted by Zili Chen <wa...@gmail.com> on 2019/08/26 03:00:00 UTC, 0 replies.
- Re: flink 1.9.0 StreamTableEnvironment 编译错误 - posted by Zili Chen <wa...@gmail.com> on 2019/08/26 03:22:21 UTC, 3 replies.
- kafka消费倾斜问题 - posted by zq wang <wa...@gmail.com> on 2019/08/26 04:31:16 UTC, 0 replies.
- flink 1.9 消费kafka报错 - posted by ddwcg <31...@qq.com> on 2019/08/26 06:56:43 UTC, 5 replies.
- 回复: Re: flink1.9 blink planner table ddl 使用问题 - posted by "pengchenglin@bonc.com.cn" <pe...@bonc.com.cn> on 2019/08/26 07:23:19 UTC, 2 replies.
- 关于elasticSearch table sink 构造过于复杂 - posted by "aven.wu" <da...@163.com> on 2019/08/26 08:33:27 UTC, 5 replies.
- Elasticsearch6UpsertTableSink 的构造方法过于复杂 - posted by 巫旭阳 <da...@163.com> on 2019/08/26 08:41:32 UTC, 0 replies.
- 关于row number over的用法 - posted by ddwcg <31...@qq.com> on 2019/08/26 11:02:18 UTC, 1 replies.
- flink1.7.2如何进行hdfs的kerberos认证 - posted by 杨文生-java开发 <yw...@126.com> on 2019/08/26 13:05:11 UTC, 0 replies.
- 关于flink状态后端使用Rocksdb序列化问题 - posted by 1900 <57...@qq.com> on 2019/08/26 13:43:07 UTC, 2 replies.
- 答复: 关于elasticSearch table sink 构造过于复杂 - posted by "aven.wu" <da...@163.com> on 2019/08/27 01:10:54 UTC, 0 replies.
- flink1.9中关于blink的文档在哪看呀 - posted by "rockeycui@163.com" <ro...@163.com> on 2019/08/27 02:18:08 UTC, 2 replies.
- 实时计算占比的问题 - posted by ddwcg <31...@qq.com> on 2019/08/27 03:37:36 UTC, 0 replies.
- 关于flink中kafka状态及数据回溯问题 - posted by 1900 <57...@qq.com> on 2019/08/27 05:57:46 UTC, 0 replies.
- 关于flink中端对端的精确一次性理解问题 - posted by 1900 <57...@qq.com> on 2019/08/27 06:15:59 UTC, 2 replies.
- 在子查询上使用row_number over返回的rn都是1 - posted by ddwcg <31...@qq.com> on 2019/08/27 07:16:21 UTC, 4 replies.
- kafka流与hive表join问题 - posted by like <li...@163.com> on 2019/08/27 09:08:47 UTC, 5 replies.
- Re: flink1.7.2如何进行hdfs的kerberos认证 - posted by Jeff Zhang <zj...@gmail.com> on 2019/08/27 09:22:44 UTC, 0 replies.
- 回复: kafka流与hive表join问题 - posted by like <li...@163.com> on 2019/08/27 09:25:57 UTC, 2 replies.
- flink基于yarn的方式提交,log在web上看太卡了。能不能直接看log文件? - posted by 陈帅 <ch...@gmail.com> on 2019/08/27 09:55:21 UTC, 1 replies.
- flink基于yarn提交,需要依赖很多第三方的包,有没有办法添加classpath之类的,本地测试总是报错 - posted by 陈帅 <ch...@gmail.com> on 2019/08/27 09:57:50 UTC, 0 replies.
- flink 1.8 sql rowtime window 问题 - posted by 1142632215 <11...@qq.com> on 2019/08/27 09:58:28 UTC, 0 replies.
- Re: Re:回复: Re: flink1.9 blink planner table ddl 使用问题 - posted by 徐骁 <ff...@gmail.com> on 2019/08/27 09:59:55 UTC, 0 replies.
- Checkpoint使用 - posted by yanggang_it_job <ya...@163.com> on 2019/08/27 10:08:24 UTC, 3 replies.
- flink异常恢复 - posted by 王金海 <cs...@163.com> on 2019/08/27 10:13:51 UTC, 1 replies.
- maven配置错误百出 - posted by like <li...@163.com> on 2019/08/27 10:49:25 UTC, 0 replies.
- Re: flink1.9 blink planner table ddl 使用问题 - posted by Jark Wu <im...@gmail.com> on 2019/08/27 10:49:30 UTC, 1 replies.
- flink日志级别问题 - posted by 陈思 <58...@qq.com> on 2019/08/27 10:55:39 UTC, 1 replies.
- 回复: flink日志级别问题 - posted by 王金海 <cs...@163.com> on 2019/08/27 11:46:01 UTC, 4 replies.
- flink1.9 hadoop3 on yarn "StoppableFunction not found" - posted by Michael Ran <gr...@163.com> on 2019/08/27 12:40:29 UTC, 0 replies.
- flink1.9 Blink planner create view 问题 - posted by hb <34...@163.com> on 2019/08/28 03:39:59 UTC, 1 replies.
- 回复: 回复: flink日志级别问题 - posted by 陈思 <58...@qq.com> on 2019/08/28 06:30:58 UTC, 0 replies.
- 回复: 关于flink中端对端的精确一次性理解问题 - posted by 1900 <57...@qq.com> on 2019/08/28 06:47:14 UTC, 0 replies.
- flink不清理state,从checkpoint恢复任务能重置kafka的offset讨论 - posted by 蒋涛涛 <jt...@gmail.com> on 2019/08/29 02:00:54 UTC, 5 replies.
- 全局并行度和算子并行度的关系 - posted by ddwcg <31...@qq.com> on 2019/08/29 02:18:33 UTC, 1 replies.
- 回复: 全局并行度和算子并行度的关系 - posted by "pengchenglin@bonc.com.cn" <pe...@bonc.com.cn> on 2019/08/29 02:54:21 UTC, 0 replies.
- 关于定期清理state,但是checkpoint size大小一直在增加的疑问 - posted by 陈赋赟 <as...@163.com> on 2019/08/29 07:17:14 UTC, 4 replies.
- 一个FlinkJob消费多个kafka topic消息问题 - posted by 史 正超 <sh...@outlook.com> on 2019/08/29 08:10:50 UTC, 0 replies.
- 关于flink 写于kafka时的transactionId 生成问题 - posted by ddwcg <31...@qq.com> on 2019/08/29 09:13:36 UTC, 3 replies.
- flink to HDFS Couldn't create proxy provider class ***.ha.ConfiguredFailoverProxyProvider - posted by 马晓稳 <ma...@163.com> on 2019/08/29 13:31:41 UTC, 1 replies.