You are viewing a plain text version of this content. The canonical link for it is here.
- Re: flink1.12 执行sql_query(),同样的数据源表,pyflink执行时间9min,java执行3s - posted by Xingbo Huang <hx...@gmail.com> on 2021/03/01 01:54:49 UTC, 8 replies.
- Pyflink如何对接HBase? - posted by 瞿叶奇 <38...@qq.com> on 2021/03/01 02:17:10 UTC, 1 replies.
- flink job 一直失败重试, 生产者id 没有被分配事务 id - posted by Lynn Chen <al...@163.com> on 2021/03/01 03:10:30 UTC, 0 replies.
- Flink 1.12 ApplicationMode运行在阿里云托管Kubernetes报错 - posted by 王 羽凡 <wa...@gmail.com> on 2021/03/01 05:01:26 UTC, 2 replies.
- flink 1.12.2-rc2 被挖矿 - posted by macdoor <ma...@gmail.com> on 2021/03/01 05:12:10 UTC, 6 replies.
- flink 1.10.2 Unknown operation 108 - posted by xushanshan <13...@qq.com> on 2021/03/01 06:46:53 UTC, 1 replies.
- Flink-SQL-Connector扩展问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2021/03/01 06:55:44 UTC, 0 replies.
- flink如何在无数据流的情况下也能实现state定时输出的功能 - posted by dushang <18...@qq.com> on 2021/03/01 07:16:33 UTC, 0 replies.
- 回复:flink如何在无数据流的情况下也能实现state定时输出的功能 - posted by Hongyuan Ma <cs...@163.com> on 2021/03/01 07:28:11 UTC, 4 replies.
- 退订 - posted by china_tao <ta...@163.com> on 2021/03/01 07:56:22 UTC, 37 replies.
- Re: 回复:Flink checkpoint 速度慢问题请教 - posted by Jacob <17...@163.com> on 2021/03/02 02:34:30 UTC, 7 replies.
- 关于rebalance和forward的性能 - posted by yidan zhao <hi...@gmail.com> on 2021/03/02 02:56:14 UTC, 2 replies.
- flink on kubernetes - posted by "Robert.Zhang" <17...@qq.com> on 2021/03/02 09:31:34 UTC, 0 replies.
- UDF 重复调用的问题、 - posted by Qishang <zh...@gmail.com> on 2021/03/02 10:50:02 UTC, 5 replies.
- 编译Flink1.11的flink-runtime-web失败 - posted by Natasha <na...@foxmail.com> on 2021/03/03 02:34:23 UTC, 1 replies.
- 理性规律异常,停止任务后,再提交会导致JobManager进程失败。 - posted by yidan zhao <hi...@gmail.com> on 2021/03/03 02:52:36 UTC, 1 replies.
- 回复:编译Flink1.11的flink-runtime-web失败 - posted by Natasha <na...@foxmail.com> on 2021/03/03 02:55:06 UTC, 3 replies.
- flink Application Native k8s使用oss作为backend日志偶尔报错 - posted by 王 羽凡 <wa...@gmail.com> on 2021/03/03 03:23:34 UTC, 2 replies.
- 如何动态配置 flink run 的 client日志文件的路径? - posted by 小旋锋 <wh...@qq.com> on 2021/03/03 04:11:57 UTC, 1 replies.
- Flink启动后某个TM的某个slot不工作,看起来像是直接没任何通信。 - posted by yidan zhao <hi...@gmail.com> on 2021/03/03 06:47:27 UTC, 0 replies.
- Re: Flink 1.11.2运行一段时间后,会报ResourceManager leader changed to new address null的异常 - posted by yidan zhao <hi...@gmail.com> on 2021/03/03 06:58:27 UTC, 1 replies.
- flink TableEnvironment.sqlUpdate不支持update 多表关联更新吗 - posted by JackJia <co...@126.com> on 2021/03/03 08:28:30 UTC, 2 replies.
- flink-savepoint问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2021/03/03 10:52:44 UTC, 4 replies.
- flink sql中如何使用异步io关联维表? - posted by "casel.chen" <ca...@126.com> on 2021/03/03 14:54:29 UTC, 3 replies.
- Flink SQL upsert-kafka connector 生成的 Stage ChangelogNormalize 算子的疑问 - posted by Qishang <zh...@gmail.com> on 2021/03/04 07:30:11 UTC, 3 replies.
- yarn.containers.vcores使用问题 - posted by 阿华田 <a1...@163.com> on 2021/03/04 08:34:05 UTC, 1 replies.
- 远程提交flink sql设置了checkpoint,flink sql没有jar包如何恢复呢? - posted by huayuan <d_...@qq.com> on 2021/03/04 08:48:00 UTC, 0 replies.
- flink sql没有jar包如何恢复? - posted by huayuan <d_...@qq.com> on 2021/03/04 08:54:10 UTC, 0 replies.
- flink sql没有jar包如何恢复 - posted by huayuan <d_...@qq.com> on 2021/03/04 09:30:33 UTC, 0 replies.
- sql 动态修改参数问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2021/03/04 11:37:12 UTC, 2 replies.
- flink 1.12分支写入hive decimal类型jar冲突 - posted by "kandy.wang" <ka...@163.com> on 2021/03/04 11:44:05 UTC, 0 replies.
- Re: [DISCUSS] Deprecation and removal of the legacy SQL planner - posted by Timo Walther <tw...@apache.org> on 2021/03/04 12:40:55 UTC, 2 replies.
- Flink能否实现从一个流中读取sql并动态执行? - posted by 星夜 <16...@qq.com> on 2021/03/04 14:13:30 UTC, 0 replies.
- flink作业报 task manager连接错误 - posted by 星夜 <16...@qq.com> on 2021/03/05 01:41:33 UTC, 1 replies.
- Flink1.12 如何使用代码提交Batch的Sql - posted by shougou <80...@qq.com> on 2021/03/05 01:59:01 UTC, 2 replies.
- flink+iceberg/hudi 在大数据量下的表现如何? - posted by Husky Zeng <56...@qq.com> on 2021/03/05 02:40:30 UTC, 0 replies.
- 消息队列量级特别如何优化消费 - posted by allanqinjy <al...@163.com> on 2021/03/05 02:47:41 UTC, 2 replies.
- 消息积压如何优化 - posted by allanqinjy <al...@163.com> on 2021/03/05 03:05:14 UTC, 1 replies.
- 回复: yarn.containers.vcores使用问题 - posted by 阿华田 <a1...@163.com> on 2021/03/05 06:09:16 UTC, 0 replies.
- 回复:消息积压如何优化 - posted by allanqinjy <al...@163.com> on 2021/03/05 06:39:40 UTC, 1 replies.
- 状态恢复参数顺序 -s - posted by dushang <18...@qq.com> on 2021/03/05 06:57:25 UTC, 0 replies.
- 回复:状态恢复参数顺序 -s - posted by allanqinjy <al...@163.com> on 2021/03/05 07:03:34 UTC, 1 replies.
- flink dataStream多次sink DAG重复驱动执行? - posted by lp <97...@qq.com> on 2021/03/05 09:31:47 UTC, 1 replies.
- 回复: flink sql中如何使用异步io关联维表? - posted by 黑色 <xi...@qq.com> on 2021/03/05 09:55:39 UTC, 0 replies.
- [sql]TimeStamp和异常格式的字符串进行比较时会报空指针 - posted by silence <sl...@aliyun.com.INVALID> on 2021/03/05 10:51:55 UTC, 0 replies.
- 回复:消息队列量级特别如何优化消费 - posted by smq <37...@qq.com> on 2021/03/05 11:19:41 UTC, 2 replies.
- Flink Job 如何集成到自己的系统,方便管理 - posted by Jacob <17...@163.com> on 2021/03/06 08:00:13 UTC, 10 replies.
- flink 1.12.2版本,DataStream转为Table时设置rowtime列,日期转换错误 - posted by Asahi Lee <97...@qq.com> on 2021/03/06 08:50:40 UTC, 0 replies.
- 【flink 访问 Kerberos认证的hive 】 - posted by guoyb <86...@qq.com> on 2021/03/07 02:33:22 UTC, 0 replies.
- 关于statement输出结果疑问 - posted by 刘杰鸿 <wu...@foxmail.com> on 2021/03/07 03:56:34 UTC, 3 replies.
- 【flink sql-client 读写 Kerberos认证的hive】 - posted by "861277329@qq.com" <86...@qq.com> on 2021/03/07 09:49:24 UTC, 3 replies.
- 关于Watermark的使用调试问题 - posted by Xavier <xa...@gmail.com> on 2021/03/07 11:51:22 UTC, 2 replies.
- 问一下哈,使用idea开发程序,把状态存在本地电脑里,怎么样可以从本地的checkpioint中恢复状态 - posted by "hezongjin12@qq.com" <he...@qq.com> on 2021/03/08 01:51:18 UTC, 0 replies.
- flink sql 这种实时计算结果如何与离线计算的结果做数据比对? - posted by jindy_liu <28...@qq.com> on 2021/03/08 04:01:47 UTC, 4 replies.
- 如何在Flink中调用使用C++写的算法? - posted by 苏喜 张 <15...@163.com> on 2021/03/08 06:06:31 UTC, 0 replies.
- 回复:【flink sql-client 读写 Kerberos认证的hive】 - posted by guoyb <86...@qq.com> on 2021/03/08 06:15:13 UTC, 1 replies.
- 频繁发生 'ResourceManager leader changed to new address null' 异常导致任务重启 - posted by yidan zhao <hi...@gmail.com> on 2021/03/08 06:37:54 UTC, 8 replies.
- 自定义窗口触发器 Trigger - posted by smq <37...@qq.com> on 2021/03/08 07:30:57 UTC, 0 replies.
- 回复:自定义窗口触发器 Trigger - posted by smq <37...@qq.com> on 2021/03/08 07:33:39 UTC, 0 replies.
- BUG :DataStream 转 Table 后无法 触发窗口计算 - posted by HunterXHunter <13...@qq.com> on 2021/03/08 08:01:29 UTC, 6 replies.
- pyflink 如何使用session window对相同pv数据聚合 - posted by kk <22...@qq.com> on 2021/03/08 11:03:42 UTC, 1 replies.
- 回复:pyflink 如何使用session window对相同pv数据聚合 - posted by Hongyuan Ma <cs...@163.com> on 2021/03/08 11:10:16 UTC, 1 replies.
- 什么原因导致 Could not connect to BlobServer ? - posted by macdoor <ma...@gmail.com> on 2021/03/08 18:23:09 UTC, 0 replies.
- Re: rowtime 的类型序列化问题 - posted by JudeZhu <24...@qq.com> on 2021/03/09 02:56:48 UTC, 1 replies.
- flink 与 hive版本选择 - posted by 张锴 <zk...@gmail.com> on 2021/03/09 03:39:20 UTC, 0 replies.
- Re: Flink RocksDBStateBackend 可以设置阿里云 OSS 存储吗? - posted by seuzxc <ze...@gmail.com> on 2021/03/09 04:15:17 UTC, 0 replies.
- PyFlink UDTF 运行一段时间后报 NullPointerException - posted by 梁丁文 <do...@qq.com> on 2021/03/09 09:27:04 UTC, 1 replies.
- flink 1.12.2版本,批环境和流批一体模式下的批模式的数据处理方式 - posted by Asahi Lee <97...@qq.com> on 2021/03/09 12:01:48 UTC, 0 replies.
- Pyflink 提交到本地集群报错 - posted by Huilin_WU <59...@qq.com> on 2021/03/09 13:33:14 UTC, 3 replies.
- MapState 无法更新问题 - posted by chaos <ji...@163.com> on 2021/03/10 04:34:46 UTC, 0 replies.
- 回复:MapState 无法更新问题 - posted by smq <37...@qq.com> on 2021/03/10 05:37:26 UTC, 1 replies.
- flinkx增量采集 - posted by 王瑞冬 <18...@qq.com> on 2021/03/10 06:01:17 UTC, 0 replies.
- flinkx增量同步(多表) - posted by 王瑞冬 <18...@qq.com> on 2021/03/10 06:06:36 UTC, 0 replies.
- 如何自定义web-ui上对taskmanager的标识符 - posted by yidan zhao <hi...@gmail.com> on 2021/03/10 06:27:35 UTC, 1 replies.
- 回复: 回复:MapState 无法更新问题 - posted by 明启 孙 <37...@qq.com> on 2021/03/10 06:48:44 UTC, 2 replies.
- Re: 回复: Re:回复: flink-1.11.2 执行checkpoint失败 - posted by smallwong <sm...@163.com> on 2021/03/10 07:42:44 UTC, 0 replies.
- flink standalone 模式运行任务的问题 - posted by Lei Wang <le...@gmail.com> on 2021/03/10 08:22:56 UTC, 0 replies.
- 如何定义时态表 - posted by superainbower <su...@163.com> on 2021/03/10 09:29:44 UTC, 1 replies.
- 如何使用flink对时间跨度为1年的历史数据流进行处理,快速得到结果 - posted by Hongyuan Ma <cs...@163.com> on 2021/03/10 14:10:16 UTC, 0 replies.
- 提交两个SQL任务,其中一个不生效。 - posted by eriendeng <er...@tencent.com> on 2021/03/10 14:17:42 UTC, 4 replies.
- flink sql sink多数据源问题 - posted by "casel.chen" <ca...@126.com> on 2021/03/11 00:11:21 UTC, 0 replies.
- flink cdc遇到数据源大事务怎么处理? - posted by "casel.chen" <ca...@126.com> on 2021/03/11 00:30:34 UTC, 0 replies.
- Flink savepoint迁移问题 - posted by 赵 建云 <zh...@outlook.com> on 2021/03/11 02:43:36 UTC, 5 replies.
- flink sql如何从远程加载jar包中的udf - posted by chenxyz <ch...@163.com> on 2021/03/11 02:44:29 UTC, 5 replies.
- 将每个tm的slot数从2降低到1,任务反而无法启动 - posted by lzwang <lz...@iflytek.com> on 2021/03/11 06:34:08 UTC, 1 replies.
- 回复:将每个tm的slot数从2降低到1,任务反而无法启动 - posted by xuhaiLong <xi...@163.com> on 2021/03/11 06:55:09 UTC, 0 replies.
- 疑问:当开启state.backend.incremental 后 Checkpointed Data Size 会不断变大 - posted by HunterXHunter <13...@qq.com> on 2021/03/11 07:55:27 UTC, 0 replies.
- 回复:flink sql如何从远程加载jar包中的udf - posted by 邓从宝 <de...@dingtalk.com.INVALID> on 2021/03/11 08:49:45 UTC, 0 replies.
- flink 在不同的 operator 之间传递通过基类方式,在 operator 中能转换为子类型吗? - posted by Lei Wang <le...@gmail.com> on 2021/03/11 08:52:21 UTC, 0 replies.
- 回复: Flink savepoint迁移问题 - posted by allanqinjy <al...@163.com> on 2021/03/11 14:50:15 UTC, 0 replies.
- flink-kinesis setParallelism 之后 shard 分布不均匀 - posted by mo jia <li...@gmail.com> on 2021/03/11 16:12:24 UTC, 0 replies.
- Flink sql中插入null值失败 - posted by Jimmy Zhang <zh...@163.com> on 2021/03/12 02:42:56 UTC, 0 replies.
- Flink-1.11.2版本 Filesystem-connector 问题 - posted by 史 正超 <sh...@outlook.com> on 2021/03/12 03:00:47 UTC, 1 replies.
- Flink-1.11.2版本FileSystem connector问题 - posted by 史 正超 <sh...@outlook.com> on 2021/03/12 03:14:37 UTC, 0 replies.
- 关于pyflink LATERAL TABLE 问题请教 - posted by 陈康 <84...@qq.com> on 2021/03/12 08:24:10 UTC, 4 replies.
- flinksql 1.12.1 row中字段访问报错 - posted by Peihui He <pe...@gmail.com> on 2021/03/12 10:30:21 UTC, 1 replies.
- 回复: 关于statement输出结果疑问 - posted by 刘杰鸿 <wu...@foxmail.com> on 2021/03/12 14:52:44 UTC, 0 replies.
- Pyflink dataset没有支持相关map reduce函数 - posted by "nova.he" <no...@qq.com> on 2021/03/13 02:54:03 UTC, 1 replies.
- Re: flink-提交jar 隔断时间自己重启问题 - posted by shawn <lx...@163.com> on 2021/03/13 12:16:37 UTC, 2 replies.
- flink sql滑动窗口TOPN,输出结果有问题 - posted by me <me...@lishiyu.cn> on 2021/03/13 13:37:30 UTC, 0 replies.
- pyflink中 datastream没有实现windows方法 - posted by he...@gmail.com,
he...@gmail.com on 2021/03/14 02:37:53 UTC, 0 replies.
- pyflink使用的一些疑问 - posted by qian he <he...@gmail.com> on 2021/03/14 10:59:25 UTC, 4 replies.
- Flink sql 实现全局row_number()分组排序 - posted by Tian Hengyu <TI...@gmail.com> on 2021/03/15 02:12:11 UTC, 2 replies.
- 1.12 yarn-per-job提交作业失败 - posted by smq <37...@qq.com> on 2021/03/15 02:22:47 UTC, 1 replies.
- 请问在哪里可以看到flink 相关的性能测试报告,读取kafka,mysql等 - posted by Asahi Lee <97...@qq.com> on 2021/03/15 03:14:50 UTC, 0 replies.
- Upsert Kafka 的format 为什么要求是INSERT-ONLY的 - posted by 刘首维 <li...@autohome.com.cn> on 2021/03/15 03:48:03 UTC, 2 replies.
- 回复:1.12 yarn-per-job提交作业失败 - posted by smq <37...@qq.com> on 2021/03/15 04:34:35 UTC, 1 replies.
- flink1.12版本,使用yarn-application模式提交任务失败 - posted by todd <to...@163.com> on 2021/03/15 06:22:28 UTC, 2 replies.
- 答复: Upsert Kafka 的format 为什么要求是INSERT-ONLY的 - posted by 刘首维 <li...@autohome.com.cn> on 2021/03/15 06:39:26 UTC, 0 replies.
- flink 1.12 使用流式写入hive报错,Failed to create Hive RecordWriter - posted by william <71...@qq.com> on 2021/03/15 08:32:37 UTC, 2 replies.
- Flink Temporal Join Two union Hive Table Error - posted by macia kk <pr...@gmail.com> on 2021/03/15 10:55:35 UTC, 1 replies.
- flink yarn-perjob提交任务无法启动 - posted by 刘朋强 <li...@126.com> on 2021/03/15 13:59:38 UTC, 0 replies.
- Flink shuffle vs rebalance - posted by 赢峰 <si...@163.com> on 2021/03/15 14:01:28 UTC, 1 replies.
- 请问有flink + hudi或iceberg + aliyun oss的示例吗? - posted by "casel.chen" <ca...@126.com> on 2021/03/16 00:27:19 UTC, 0 replies.
- Connection reset by peer - posted by yidan zhao <hi...@gmail.com> on 2021/03/16 02:07:41 UTC, 0 replies.
- 回复:flink yarn-perjob提交任务无法启动 - posted by lian <lz...@126.com> on 2021/03/16 04:57:23 UTC, 0 replies.
- flink sql 的 count(distinct )问题 - posted by op <52...@qq.com> on 2021/03/16 06:58:15 UTC, 1 replies.
- Temproal Tables - posted by superainbower <su...@163.com> on 2021/03/16 07:11:52 UTC, 1 replies.
- (无主题) - posted by 黄志高 <hu...@163.com> on 2021/03/16 07:27:53 UTC, 0 replies.
- 使用codehaus.janino动态生成类,在map函数中自动映射json对象,找不到我自动生成的类 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2021/03/16 08:46:26 UTC, 0 replies.
- FlinkSql 的一些疑问 - posted by "songzhongshun@kedacom.com" <so...@kedacom.com> on 2021/03/17 03:12:27 UTC, 0 replies.
- 回复:关于statement输出结果疑问 - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2021/03/17 07:33:20 UTC, 0 replies.
- Re: flinksql读取format为avro的kafka topic 报错 ArrayIndexOutOfBoundsException - posted by wxpcc <wx...@outlook.com> on 2021/03/17 09:08:05 UTC, 0 replies.
- 【flink sql group by 时间窗口】 - posted by guoyb <86...@qq.com> on 2021/03/17 09:43:27 UTC, 0 replies.
- interval join 如何用 process time - posted by guomuhua <66...@qq.com> on 2021/03/17 09:59:23 UTC, 4 replies.
- 回复:【flink sql group by 时间窗口】 - posted by guoyb <86...@qq.com> on 2021/03/17 10:16:03 UTC, 0 replies.
- 重复class应如何选择 - posted by nicygan <re...@163.com> on 2021/03/18 01:28:42 UTC, 0 replies.
- Flink 1.12.0 隔几个小时Checkpoint就会失败 - posted by Frost Wong <fr...@hotmail.com> on 2021/03/18 02:38:22 UTC, 3 replies.
- 在FlinkKafkaProducer获取sink表的建表key - posted by Jimmy Zhang <13...@163.com> on 2021/03/18 02:40:22 UTC, 0 replies.
- pyflink UDTF求助! - posted by 陈康 <84...@qq.com> on 2021/03/18 03:32:09 UTC, 3 replies.
- Flink1.11如何实现Tumble Window后基于event time倒序取第一条作统计 - posted by Hush <ls...@163.com> on 2021/03/18 04:14:39 UTC, 1 replies.
- 回复: Flink 1.12.0 隔几个小时Checkpoint就会失败 - posted by Frost Wong <fr...@hotmail.com> on 2021/03/18 04:28:30 UTC, 0 replies.
- Flink SQL JDBC connector不能checkpoint - posted by Gengshen Zhao <gs...@aibee.com> on 2021/03/18 07:20:48 UTC, 5 replies.
- MySQL cdc时态表join - posted by guoyb <86...@qq.com> on 2021/03/18 08:41:14 UTC, 1 replies.
- mysql cdc配置问题求助 - posted by 信华哺 <la...@163.com> on 2021/03/18 09:01:09 UTC, 0 replies.
- 回复:mysql cdc配置问题求助 - posted by steve <yb...@qq.com> on 2021/03/18 15:20:13 UTC, 1 replies.
- Flink-1.12 OnYarn模式下HA咨询 - posted by Yapor <17...@163.com> on 2021/03/19 06:13:29 UTC, 1 replies.
- Flink on yarn per-job HA - posted by Ink足迹 <in...@qq.com> on 2021/03/19 06:21:31 UTC, 0 replies.
- Flink1.11执行sql当判空使用<> null,程序直接结束 - posted by datayangl <da...@gmail.com> on 2021/03/19 08:02:17 UTC, 3 replies.
- flink 1.12 使用流式写入hive报错,Container exited with a non-zero exit code 239 - posted by william <71...@qq.com> on 2021/03/20 02:39:31 UTC, 0 replies.
- flink 使用yarn部署,报错:Maximum Memory: 8192 Requested: 10240MB. Please check the 'yarn.scheduler.maximum-allocation-mb' and the 'yarn.nodemanager.resource.memory-mb' configuration values - posted by william <71...@qq.com> on 2021/03/20 02:57:23 UTC, 2 replies.
- 邮件组退订 - posted by 李朋辉 <li...@126.com> on 2021/03/20 09:05:07 UTC, 0 replies.
- flink 1.11.2 使用rocksdb时出现org.apache.flink.util.SerializedThrowable错误 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2021/03/20 14:07:03 UTC, 1 replies.
- 回复: flink 1.11.2 使用rocksdb时出现org.apache.flink.util.SerializedThrowable错误 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2021/03/20 16:36:04 UTC, 0 replies.
- flink cdc 在做全量同步时Lock wait timeout - posted by 王敏超 <mi...@163.com> on 2021/03/22 01:45:26 UTC, 0 replies.
- Flink job manager HA 是否可以像 Hadoop Name Node 一样手动重启? - posted by macdoor <ma...@gmail.com> on 2021/03/22 02:33:21 UTC, 0 replies.
- flink1.11.2集群出现了3种连接拒绝,导致任务失败 - posted by chaiyi <ch...@163.com> on 2021/03/22 03:23:17 UTC, 1 replies.
- flink1.12 Standalone模式发送python脚本任务报错: java.lang.ClassNotFoundException: org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat - posted by xiaoyue <18...@163.com> on 2021/03/22 05:43:02 UTC, 2 replies.
- 关于KafkaTableSourceBase未实现ProjectableTableSource接口的疑问 - posted by 刘医生 <ea...@gmail.com> on 2021/03/22 06:53:29 UTC, 0 replies.
- flink on yarn session模式与yarn通信失败 (job模式可以成功)的问题 - posted by 刘乘九 <li...@163.com> on 2021/03/22 09:25:51 UTC, 0 replies.
- flink on yarn session模式与yarn通信失败的问题 (job模式可以成功) - posted by 刘乘九 <li...@163.com> on 2021/03/22 09:28:04 UTC, 2 replies.
- flink-1.11.2版本,客户端如何设置dynamic properties - posted by 刘医生 <ea...@gmail.com> on 2021/03/23 01:13:59 UTC, 1 replies.
- Flink 消费kafka ,写ORC文件 - posted by Jacob <17...@163.com> on 2021/03/23 02:02:00 UTC, 2 replies.
- flink sql count distonct 优化 - posted by guomuhua <66...@qq.com> on 2021/03/23 12:02:43 UTC, 6 replies.
- flink sql 并行度问题 - posted by ggc <63...@qq.com> on 2021/03/23 12:13:58 UTC, 0 replies.
- flink sql 写hive并行度设置问题 - posted by ggc <63...@qq.com> on 2021/03/23 12:17:34 UTC, 0 replies.
- FileSystemTableSink支持自定义分隔符写入 - posted by 刘医生 <ea...@gmail.com> on 2021/03/24 03:44:18 UTC, 1 replies.
- 相同的作业配置 ,Flink1.12 版本的作业checkpoint耗时增加以及制作失败,Flink1.9的作业运行正常 - posted by Haihang Jing <ge...@gmail.com> on 2021/03/24 04:05:45 UTC, 1 replies.
- 【疑问】RocksDBStateBackend为什么使用单独封装的frocksdbjni,而不用RocksDB官方提供的RocksJava - posted by zoltar9264 <zo...@163.com> on 2021/03/24 05:48:25 UTC, 1 replies.
- 回复: flink 1.12.0 k8s session部署异常 - posted by "18756225770@163.com" <18...@163.com> on 2021/03/24 09:45:24 UTC, 0 replies.
- yarn模式下应用的core/hdfs/yarn site不生效 - posted by 崔博 <75...@qq.com> on 2021/03/24 10:59:05 UTC, 0 replies.
- Re: flink 1.12.0 k8s session部署异常 - posted by Yang Wang <da...@gmail.com> on 2021/03/25 05:18:13 UTC, 0 replies.
- Flink Native Kubernetes 部署模式下,如何开启Queryable State? - posted by tian lin <ty...@163.com> on 2021/03/25 08:42:46 UTC, 1 replies.
- 【MySQL cdc 的数据不能聚合】 - posted by guoyb <86...@qq.com> on 2021/03/25 09:35:05 UTC, 0 replies.
- Flink on Native K8S模式下如何配置StandBy做高可用? - posted by "casel.chen" <ca...@126.com> on 2021/03/26 00:23:40 UTC, 1 replies.
- 优化hadoop#configuration - posted by 崔博 <75...@qq.com> on 2021/03/26 01:51:18 UTC, 0 replies.
- 【数据加工流程求助】 - posted by guoyb <86...@qq.com> on 2021/03/26 02:31:52 UTC, 0 replies.
- flink 1.11 cp size越来越大 - posted by liangji <ji...@gmail.com> on 2021/03/26 08:38:29 UTC, 0 replies.
- Re: 自定义窗口触发器 Trigger - posted by Kezhu Wang <ke...@gmail.com> on 2021/03/28 03:47:12 UTC, 0 replies.
- ransient 关键字加上和去掉单机执行结果一样,transient 关键字加上有什么作用,什么情况下会有区别? - posted by <th...@yahoo.com.INVALID> on 2021/03/28 11:11:42 UTC, 0 replies.
- Re: 在FlinkKafkaProducer获取sink表的建表key - posted by Qishang <zh...@gmail.com> on 2021/03/29 03:26:44 UTC, 0 replies.
- 回复:在FlinkKafkaProducer获取sink表的建表key - posted by 小鲲鹏 <xx...@163.com> on 2021/03/29 04:02:20 UTC, 0 replies.
- 转发:在FlinkKafkaProducer获取sink表的建表key - posted by Jimmy Zhang <zh...@163.com> on 2021/03/29 06:09:06 UTC, 0 replies.
- Re: Re:flink 1.11.1 使用mysql作为维表进行temporal join时,偶尔会报超时异常导致数据更新失败,请教解决方案 - posted by suisuimu <72...@qq.com> on 2021/03/29 08:57:04 UTC, 0 replies.
- flink-1.12.2 TM无法使用自定的serviceAccount访问configmap - posted by 1120344670 <11...@qq.com> on 2021/03/29 09:09:29 UTC, 3 replies.
- 回复:flink 1.11 cp size越来越大 - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2021/03/29 09:26:46 UTC, 0 replies.
- image - posted by 张颖 <qu...@163.com> on 2021/03/29 09:42:05 UTC, 3 replies.
- 回复:退订 - posted by 黯蓝 <47...@qq.com> on 2021/03/29 09:46:15 UTC, 0 replies.
- union operation cannot support data type : map on flink 1.12 - posted by 张颖 <qu...@163.com> on 2021/03/29 10:20:47 UTC, 0 replies.
- Flink任务中写Kafka超时导致任务超时 - posted by Frost Wong <fr...@hotmail.com> on 2021/03/29 10:24:01 UTC, 0 replies.
- Flink Window算子在WebUI中Bytes/Records Sent为0 - posted by 王 浩成 <wh...@gmail.com> on 2021/03/29 14:09:57 UTC, 0 replies.
- flink Container exited with a non-zero exit code 2. Error file: prelaunch.err. Last 4096 bytes of prelaunch.err - posted by flink2021 <ye...@163.com> on 2021/03/30 01:37:44 UTC, 1 replies.
- 回复:Flink Window算子在WebUI中Bytes/Records Sent为0 - posted by allanqinjy <al...@163.com> on 2021/03/30 02:03:20 UTC, 0 replies.
- flink 从mysql读取数据异常 - posted by air23 <wa...@163.com> on 2021/03/30 02:24:59 UTC, 2 replies.
- 回复:flink 从mysql读取数据异常 - posted by guoyb <86...@qq.com> on 2021/03/30 02:31:51 UTC, 2 replies.
- (无主题) - posted by 于林之下 <si...@163.com> on 2021/03/30 02:37:44 UTC, 1 replies.
- flink-sql 客户端采用execution.target: yarn-per-job 模式,如何指定提交的队列?? - posted by 飞翔 <yb...@qq.com> on 2021/03/30 03:00:50 UTC, 0 replies.
- pyflink1.12 报错:org.apache.beam.vendor.guava.v26_0_jre.com.google.common.util.concurrent.UncheckedExecutionException: java.lang.IllegalStateException: Process died with exit code 0 - posted by xiaoyue <18...@163.com> on 2021/03/30 09:19:26 UTC, 0 replies.
- Flink 写ORC失败 - posted by Jacob <17...@163.com> on 2021/03/30 09:44:20 UTC, 0 replies.
- flinkSQL + pythonUDF问题 - posted by guaishushu1103 <gu...@163.com> on 2021/03/30 11:34:37 UTC, 0 replies.
- Checkpoint Aligned问题 - posted by 张韩 <ha...@163.com> on 2021/03/31 02:41:11 UTC, 0 replies.
- Container is running beyond physical memory limits. Current usage: 5.0 GB of 5 GB physical memory used; 7.0 GB of 25 GB virtual memory used. Killing container. - posted by admin <wy...@163.com> on 2021/03/31 05:57:00 UTC, 0 replies.
- [讨论] Flink Connector 并行写入数据方案 - posted by jie mei <me...@gmail.com> on 2021/03/31 07:02:55 UTC, 0 replies.
- flink1.12.0 python udf任务,集群可正常执行,本地执行报错:java.lang.RuntimeException: Failed to create stage bundle factory! - posted by xiaoyue <18...@163.com> on 2021/03/31 07:29:07 UTC, 0 replies.
- yarn-per-job模式下,sql-client如何指定提交yarn的资源队列 - posted by 飞翔 <yb...@qq.com> on 2021/03/31 07:45:04 UTC, 2 replies.
- flink 小文件合并及分区没数据无法提交问题 - posted by "kandy.wang" <ka...@163.com> on 2021/03/31 08:23:17 UTC, 1 replies.
- 对于多张亿级事实表的历史全量数据 regular join,通过mysql cdc怎样避免OOM,以及优化 - posted by 王敏超 <mi...@163.com> on 2021/03/31 08:38:51 UTC, 0 replies.
- FLIP-146中TableSource并行度设置预计哪个版本做? - posted by Luna Wong <gf...@gmail.com> on 2021/03/31 13:45:58 UTC, 2 replies.
- 转发:FLIP-146中TableSource并行度设置预计哪个版本做? - posted by 张立志 <sp...@163.com> on 2021/03/31 14:00:05 UTC, 0 replies.