You are viewing a plain text version of this content. The canonical link for it is here.
- 退订 - posted by "zhaorui_9303@163.com" <zh...@163.com> on 2021/04/01 01:03:25 UTC, 20 replies.
- Flink 1.12.2 sql api 使用parquet格式报错 - posted by 霍米会 <mi...@126.com> on 2021/04/01 02:14:53 UTC, 8 replies.
- Re: [讨论] Flink Connector 并行写入数据方案 - posted by Shengkai Fang <fs...@gmail.com> on 2021/04/01 04:41:42 UTC, 0 replies.
- Re: 关于无法被看作POJO的类型,怎么转变可以让其不当作GenericType呢? - posted by Lin Hou <li...@gmail.com> on 2021/04/01 05:55:22 UTC, 0 replies.
- 关于flink CheckPoint 状态数据保存的问题 - posted by lp <97...@qq.com> on 2021/04/01 07:48:00 UTC, 5 replies.
- jdbc connectors - posted by liujian <13...@qq.com> on 2021/04/01 08:01:29 UTC, 1 replies.
- flink 1.12.2 sql-cli 写入Hive报错 is_generic - posted by HunterXHunter <13...@qq.com> on 2021/04/01 08:07:48 UTC, 8 replies.
- 定时批量任务导致 OutOfMemoryError: Metaspace 问题 - posted by 太平洋 <49...@qq.com> on 2021/04/01 08:18:58 UTC, 2 replies.
- 关于Flink水位线与时间戳分配的疑问 - posted by 陈柏含 <ch...@163.com> on 2021/04/01 08:19:13 UTC, 1 replies.
- Re: Connection reset by peer - posted by 骆凡 <90...@qq.com> on 2021/04/01 08:41:38 UTC, 0 replies.
- 现在的flink1.12支持批流混合的作业吗? - posted by 键盘击打者 <ce...@outlook.com> on 2021/04/01 08:50:32 UTC, 0 replies.
- 回复:现在的flink1.12支持批流混合的作业吗? - posted by 飞翔 <yb...@qq.com> on 2021/04/01 09:32:05 UTC, 1 replies.
- FS StateBackend 到 RocksDB StateBackend 状态恢复问题 - posted by LakeShen <sh...@gmail.com> on 2021/04/01 11:15:36 UTC, 2 replies.
- 回复:FS StateBackend 到 RocksDB StateBackend 状态恢复问题 - posted by 范瑞 <83...@qq.com> on 2021/04/01 11:29:30 UTC, 0 replies.
- blink planner里的Scala代码,未来会由Java改写吗? - posted by Luna Wong <gf...@gmail.com> on 2021/04/02 02:36:19 UTC, 0 replies.
- 求助:通过实时 Pipeline 的手段消费 Hive Table 报java.lang.ArrayIndexOutOfBoundsException: -1,谢谢! - posted by "samuel.qiu@ubtrobot.com" <sa...@ubtrobot.com> on 2021/04/02 02:41:17 UTC, 0 replies.
- flink集群提交任务挂掉 - posted by bowen li <ch...@gmail.com> on 2021/04/02 02:48:05 UTC, 1 replies.
- 给大家推荐一个不错的开源可视化flink web客户端 - posted by zhp <49...@qq.com> on 2021/04/02 03:44:27 UTC, 0 replies.
- 回复:给大家推荐一个不错的开源可视化flink web客户端 - posted by liujian <13...@qq.com> on 2021/04/02 08:24:45 UTC, 0 replies.
- flink connector用户密码 - posted by guoyb <86...@qq.com> on 2021/04/02 08:58:30 UTC, 1 replies.
- Re: flink-sql 客户端采用execution.target: yarn-per-job 模式,如何指定提交的队列?? - posted by JasonLee <17...@163.com> on 2021/04/02 10:21:53 UTC, 1 replies.
- Flink1.2对 key 进行分区,和 hash 分区有什么区别? - posted by 刘文 <th...@163.com> on 2021/04/04 06:52:40 UTC, 0 replies.
- flink kubernetes application频繁重启TaskManager问题 - posted by "casel.chen" <ca...@126.com> on 2021/04/05 02:05:25 UTC, 1 replies.
- Flink1.12.0版本 FlinkStreaming如何将偏移量提交到kafka - posted by guanyq <dl...@163.com> on 2021/04/05 08:52:16 UTC, 0 replies.
- Re: Flink启动后某个TM的某个slot不工作,看起来像是直接没任何通信。 - posted by yidan zhao <hi...@gmail.com> on 2021/04/06 03:15:42 UTC, 0 replies.
- 遇到很奇怪的错误(在网上搜不到),可以帮忙看看吗?谢谢 - posted by 83315898 <83...@qq.com> on 2021/04/06 03:33:49 UTC, 0 replies.
- pyflink资源优化问题,请教 - posted by 苗红宾 <ho...@126.com> on 2021/04/06 03:36:18 UTC, 1 replies.
- 回复:pyflink资源优化问题,请教 - posted by 郭华威 <gh...@163.com> on 2021/04/06 03:43:53 UTC, 0 replies.
- (无主题) - posted by 郭华威 <gh...@163.com> on 2021/04/06 03:46:50 UTC, 3 replies.
- 如何手动读取Savepoints中的内容? - posted by xingoo <23...@qq.com> on 2021/04/06 06:54:10 UTC, 1 replies.
- 回复:(无主题) - posted by yangxiaofei <ya...@163.com> on 2021/04/06 07:57:52 UTC, 2 replies.
- 回复: Flink 1.12.2 sql api 使用parquet格式报错 - posted by 太平洋 <49...@qq.com> on 2021/04/06 08:10:04 UTC, 1 replies.
- Flink1.12.0版本 FlinkStreaming 如何将偏移量提交到kafka 0.11 - posted by guanyq <dl...@163.com> on 2021/04/06 09:59:52 UTC, 0 replies.
- CheckpointedFunction#snapshotState访问键控状态报错 - posted by cs <58...@qq.com> on 2021/04/06 13:52:20 UTC, 1 replies.
- Re: flink 创建hbase出错 - posted by 巫烨 <lu...@xiaoying.com> on 2021/04/06 14:48:44 UTC, 0 replies.
- Re: Flink1.2对 key 进行分区,和 hash 分区有什么区别? - posted by yidan zhao <hi...@gmail.com> on 2021/04/07 05:40:40 UTC, 0 replies.
- kafka数据源jar包使用异常 - posted by 小猫爱吃鱼 <18...@qq.com> on 2021/04/07 07:27:10 UTC, 1 replies.
- flink 1.12.0 FileSystem 读取 hdfs 文件 - posted by Ink足迹 <in...@qq.com> on 2021/04/07 07:55:06 UTC, 1 replies.
- flink api的疑问 - posted by op <52...@qq.com> on 2021/04/07 08:22:48 UTC, 0 replies.
- 从kafka sink 到hbase丢失数据 - posted by 夜思流年梦 <li...@163.com> on 2021/04/07 08:59:37 UTC, 0 replies.
- flink sink kafka 报错 - posted by lp <97...@qq.com> on 2021/04/07 12:32:14 UTC, 1 replies.
- Flink-SQL将多条查询结果合并保存至Map中 - posted by RL_LEE <li...@126.com> on 2021/04/07 12:53:49 UTC, 0 replies.
- Flink-SQL合并多条记录到Map中 - posted by RL_LEE <li...@126.com> on 2021/04/07 13:06:34 UTC, 1 replies.
- flink on native kubernetes application Rest服务暴露问题 - posted by "casel.chen" <ca...@126.com> on 2021/04/07 15:28:59 UTC, 0 replies.
- Temporal join 選擇特定幾行 - posted by Chongaih Hau <ch...@shopee.com> on 2021/04/08 01:06:20 UTC, 0 replies.
- Flink任务重启导致集群无限重启的问题 - posted by yidan zhao <hi...@gmail.com> on 2021/04/08 02:17:26 UTC, 0 replies.
- flink kafka connector 偶现报错 Permission denied: connect - posted by lp <97...@qq.com> on 2021/04/08 02:36:46 UTC, 0 replies.
- FlinkSQL + pythonUDF问题 flink-1.12.2版本 - posted by 岳江帆 <gu...@163.com> on 2021/04/08 06:24:12 UTC, 0 replies.
- flink cdc读取Maxwell格式的binlog,如何获取表名等元信息 - posted by chen310 <22...@163.com> on 2021/04/08 09:16:59 UTC, 2 replies.
- 求问Hive DDL TBLPROPERTIES不生效 - posted by eriendeng <er...@tencent.com> on 2021/04/08 09:37:17 UTC, 3 replies.
- SinkFunction与OutputFormat选择哪个? - posted by Luna Wong <gf...@gmail.com> on 2021/04/08 09:41:50 UTC, 1 replies.
- GenericRowData与BinaryRowData的转换 - posted by Luna Wong <gf...@gmail.com> on 2021/04/08 11:35:41 UTC, 1 replies.
- 读取两个没有关联关系的文件,使用Flink不知道怎么表达 - posted by ggc <63...@qq.com> on 2021/04/08 13:55:18 UTC, 0 replies.
- 算子调度 - posted by 刘阳buaa <18...@qq.com> on 2021/04/09 03:06:03 UTC, 0 replies.
- Re: yarn-per-job模式下,sql-client如何指定提交yarn的资源队列 - posted by guanxianchun <ps...@163.com> on 2021/04/09 06:23:59 UTC, 0 replies.
- flink消费kafka数据open()方法初始换多次的问题 - posted by "guoxb__123@sina.com" <gu...@sina.com> on 2021/04/09 06:35:23 UTC, 1 replies.
- getMetricGroup is not supported when optimizing - posted by ab...@163.com on 2021/04/09 08:48:33 UTC, 0 replies.
- flink的cpu和内存资源分配 - posted by "penguin." <bx...@126.com> on 2021/04/11 13:16:08 UTC, 3 replies.
- 分组滚动窗口 无法触发计算,由于 watermark 没有被生成,或者被计算。 - posted by jie mei <me...@gmail.com> on 2021/04/11 17:49:17 UTC, 4 replies.
- flink集群自己重启,求助! - posted by "penguin." <bx...@126.com> on 2021/04/12 02:23:12 UTC, 1 replies.
- flink过一会就自动重启 - posted by "penguin." <bx...@126.com> on 2021/04/12 02:43:59 UTC, 0 replies.
- npm 打包0.9branch 前端包一直报错 - posted by housezhang <zh...@gmail.com> on 2021/04/12 02:50:10 UTC, 0 replies.
- 回复:Re: CheckpointedFunction#snapshotState访问键控状态报错 - posted by cs <58...@qq.com> on 2021/04/12 03:29:47 UTC, 1 replies.
- "flink 1.12.2升级之后恢复任务出现异常" - posted by 张锴 <zk...@gmail.com> on 2021/04/12 06:11:06 UTC, 0 replies.
- flink hive维表关联报错snappy压缩问题 - posted by "kandy.wang" <ka...@163.com> on 2021/04/12 06:18:06 UTC, 0 replies.
- Does it support gpu coding in flink? - posted by 张颖 <qu...@163.com> on 2021/04/12 06:34:06 UTC, 1 replies.
- flink -conf.yaml修改 - posted by smq <37...@qq.com> on 2021/04/12 06:34:12 UTC, 1 replies.
- flink sql join 内存占用以及数据延迟问题咨询 - posted by 董建 <62...@163.com> on 2021/04/12 06:37:50 UTC, 0 replies.
- Does it support rate-limiting in flink 1.12? - posted by 张颖 <qu...@163.com> on 2021/04/12 06:40:46 UTC, 0 replies.
- Re:回复:flink sql join 内存占用以及数据延迟问题咨询 - posted by 董建 <62...@163.com> on 2021/04/12 07:29:43 UTC, 0 replies.
- 回复: 退订 - posted by "541122477@qq.com" <54...@qq.com> on 2021/04/12 07:32:25 UTC, 0 replies.
- 回复:flink -conf.yaml修改 - posted by 熊云昆 <xi...@163.com> on 2021/04/12 10:47:55 UTC, 1 replies.
- 回复: 回复:flink -conf.yaml修改 - posted by 明启 孙 <37...@qq.com> on 2021/04/12 11:11:51 UTC, 0 replies.
- Re: flink on yarn 多TaskManager 拒绝连接问题 - posted by haihua <95...@qq.com> on 2021/04/13 03:22:45 UTC, 0 replies.
- 请教 Yarn Per-Job 模式下,多个 executeAsync() 与 execute() 的区别 - posted by 键盘击打者 <ce...@outlook.com> on 2021/04/13 04:26:53 UTC, 0 replies.
- apache-flink - posted by 杨扬 <ya...@cupdata.com> on 2021/04/13 06:40:22 UTC, 0 replies.
- 回复:退订 - posted by maozhaolin <ma...@163.com> on 2021/04/13 07:03:55 UTC, 0 replies.
- Job结束后,JobMaster没有及时GC掉, 导致JobManager OOM - posted by jun su <su...@gmail.com> on 2021/04/13 07:18:18 UTC, 2 replies.
- flink run是否支持读取oss://或hdfs://路径下的jar文件? - posted by "casel.chen" <ca...@126.com> on 2021/04/13 15:53:42 UTC, 0 replies.
- flink sql 客户端连接hive 3.1.0出现connection refused异常 - posted by 张锴 <zk...@gmail.com> on 2021/04/14 02:42:08 UTC, 1 replies.
- subscribed - posted by boyi <zh...@163.com> on 2021/04/14 02:49:26 UTC, 0 replies.
- Re: Flink CEP 使用Keyby之后无法输出结果 - posted by yue ma <ma...@gmail.com> on 2021/04/14 03:07:15 UTC, 1 replies.
- Flink job消费kafka 失败,无法拿到offset值 - posted by Jacob <17...@163.com> on 2021/04/14 04:12:58 UTC, 2 replies.
- 关于状态恢复后计算加快的疑问 - posted by 刘阳buaa <18...@qq.com> on 2021/04/14 04:14:30 UTC, 0 replies.
- Re: ������������������������������������������ - posted by ��������� <ly...@gmail.com> on 2021/04/14 06:28:29 UTC, 0 replies.
- 关于Flink SQL中Interval Join使用时watermark的疑惑 - posted by xuty <28...@qq.com> on 2021/04/14 07:18:05 UTC, 2 replies.
- Re:使用了流应用中使用了mysql jdbc的source,Execution处于FINISHED状态无法生成检查点 - posted by anonnius <an...@126.com> on 2021/04/14 08:47:04 UTC, 3 replies.
- pyflink 运行提示:Function class 'class org.apache.flink.table.functions.python.PythonScalarFunction' is not serializable - posted by magichuang <ma...@88.com> on 2021/04/14 08:57:22 UTC, 4 replies.
- flink1.12版本,yarn-application模式Flink web ui看不到日志 - posted by todd <to...@163.com> on 2021/04/14 11:11:24 UTC, 0 replies.
- 提交flink-sql 出现无法部署到yarn集群 - posted by 张锴 <zk...@gmail.com> on 2021/04/14 12:00:40 UTC, 2 replies.
- 关于1.13的Changelog状态管理 - posted by 刘阳buaa <18...@qq.com> on 2021/04/14 12:53:48 UTC, 0 replies.
- yarn-application模式下pipeline.classpaths绑定的资源包,应该一起上传 - posted by todd <to...@163.com> on 2021/04/14 12:54:17 UTC, 1 replies.
- Re: BUG :DataStream 转 Table 后无法 触发窗口计算 - posted by HunterXHunter <13...@qq.com> on 2021/04/15 05:41:42 UTC, 0 replies.
- mysql-cdc模式下无法显示源表数据 - posted by 海天一色 <10...@qq.com> on 2021/04/15 06:34:50 UTC, 0 replies.
- Flink CEP事件查询,如何在flink运行中动态更新cep规则 - posted by Asahi Lee <97...@qq.com> on 2021/04/15 07:07:14 UTC, 2 replies.
- 阿里云oss - posted by superainbower <su...@163.com> on 2021/04/15 07:38:28 UTC, 0 replies.
- Clean up old chk-xxx directory strategy optimization - posted by 范瑞 <83...@qq.com> on 2021/04/15 07:49:26 UTC, 0 replies.
- mysql-cdc 无法显示源表数据的问题 - posted by 海天一色 <10...@qq.com> on 2021/04/15 07:56:53 UTC, 0 replies.
- flink1.12.2 StreamingFileSink 问题 - posted by 张锴 <zk...@gmail.com> on 2021/04/15 09:16:14 UTC, 5 replies.
- flink1.12.1 Sink数据到ES7,遇到 Invalid lambda deserialization 问题 - posted by william <71...@qq.com> on 2021/04/15 09:40:01 UTC, 4 replies.
- flink sql写filesystem问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2021/04/15 12:35:23 UTC, 0 replies.
- flink sql 写hdfs问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2021/04/15 12:37:23 UTC, 2 replies.
- 回复:flink1.12.2 StreamingFileSink 问题 - posted by guoyb <86...@qq.com> on 2021/04/15 14:00:51 UTC, 0 replies.
- [ANNOUNCE] Apache Flink Stateful Functions 3.0.0 released - posted by "Tzu-Li (Gordon) Tai" <tz...@apache.org> on 2021/04/15 15:08:35 UTC, 0 replies.
- 回复:阿里云oss - posted by superainbower <su...@163.com> on 2021/04/16 01:09:25 UTC, 0 replies.
- 找不到kafka ConsumerRecord包 - posted by guoyb <86...@qq.com> on 2021/04/16 02:46:59 UTC, 0 replies.
- native k8s flink 更新configmap获取锁失败 - posted by 1120344670 <11...@qq.com> on 2021/04/16 04:13:31 UTC, 0 replies.
- flinksql 批写并行度疑问 - posted by chenlei677 <15...@qq.com> on 2021/04/16 07:22:45 UTC, 1 replies.
- FlatMap 报错Invalid timestamp: -1. - posted by lp <97...@qq.com> on 2021/04/16 09:44:37 UTC, 1 replies.
- Flink1.10 flinksql 单表流汇总计算数据不对 - posted by LiangbinZhang <vi...@outlook.com> on 2021/04/16 10:52:54 UTC, 1 replies.
- (无主题) - posted by maozhaolin <ma...@163.com> on 2021/04/17 02:59:27 UTC, 1 replies.
- flink-kafka-connector Producer.setWriteTimestampToKafka(true) 导致的问题 - posted by lp <97...@qq.com> on 2021/04/17 03:01:49 UTC, 0 replies.
- flink cdc是否可以以配置的方式来实现在全量读取时,不阻塞chk来实现at least once,结合hudi的upsert语义,最终实现exactly once. - posted by 王敏超 <mi...@163.com> on 2021/04/17 08:58:19 UTC, 0 replies.
- Flink-kafka-connector Consumer配置警告 - posted by lp <97...@qq.com> on 2021/04/18 11:45:08 UTC, 2 replies.
- flink on yarn 启动报错 - posted by Bruce Zhang <zh...@163.com> on 2021/04/19 03:12:13 UTC, 0 replies.
- flink在k8s上部署,如何修改默认的lib目录 - posted by "cxydevelop@163.com" <cx...@163.com> on 2021/04/19 05:16:57 UTC, 0 replies.
- 回复: Flink-kafka-connector Consumer配置警告 - posted by 飞翔 <yb...@qq.com> on 2021/04/19 09:12:54 UTC, 0 replies.
- pyflink kafka connector报错 - posted by qianhuan <81...@qq.com> on 2021/04/19 09:34:38 UTC, 4 replies.
- GroupWindowAggregate doesn't support consuming update and delete changes - posted by "casel.chen" <ca...@126.com> on 2021/04/19 10:24:00 UTC, 0 replies.
- flink1.11版本 -C 指令并未上传udf jar包 - posted by todd <to...@163.com> on 2021/04/19 14:21:51 UTC, 2 replies.
- Re:Re: 如果输入有回撤流的话,group by时间窗口会遇到GroupWindowAggregate doesn't support consuming update and delete changes - posted by "casel.chen" <ca...@126.com> on 2021/04/20 01:11:49 UTC, 2 replies.
- Re: flink-sql-connector-elasticsearch6_2.11_1.10.0 与 flink-connector-elasticsearch6_2.11_1.10.0 并存问题 - posted by william <71...@qq.com> on 2021/04/20 06:13:04 UTC, 1 replies.
- flink sql 不支持 mysql cdc 以 canal json 格式发到kafka吗? - posted by "casel.chen" <ca...@126.com> on 2021/04/20 10:17:32 UTC, 1 replies.
- flink流、批场景下kafka拉取速率问题:每批次拉取多少条?是动态吗还是可以设置 - posted by 李一飞 <ku...@163.com> on 2021/04/20 10:19:27 UTC, 3 replies.
- 如何将flink sql 查询语句的count值取出 - posted by 张锴 <zk...@gmail.com> on 2021/04/20 13:06:49 UTC, 1 replies.
- Application application_1618931441017_0004 - posted by "tanggen911@163.com" <ta...@163.com> on 2021/04/20 15:42:29 UTC, 0 replies.
- flink任务日志告警:This does not compromise Flink's checkpoint integrity. - posted by "guoxb__123@sina.com" <gu...@sina.com> on 2021/04/21 01:28:52 UTC, 1 replies.
- 回复:如何将flink sql 查询语句的count值取出 - posted by guoyb <86...@qq.com> on 2021/04/21 03:27:32 UTC, 0 replies.
- PyFlink调查问卷 - posted by Dian Fu <di...@gmail.com> on 2021/04/21 04:32:47 UTC, 0 replies.
- 回复: flink sql 不支持 mysql cdc 以 canal json 格式发到kafka吗? - posted by 飞翔 <yb...@qq.com> on 2021/04/21 06:18:42 UTC, 1 replies.
- flink sql消费kafka join普通表为何会性能爬坡? - posted by Vincent Dong <dy...@163.com> on 2021/04/21 06:36:36 UTC, 1 replies.
- 設置look up table source - posted by Chongaih Hau <ch...@shopee.com> on 2021/04/21 08:04:53 UTC, 3 replies.
- 回复:flink流、批场景下kafka拉取速率问题:每批次拉取多少条?是动态吗还是可以设置 - posted by 熊云昆 <xi...@163.com> on 2021/04/21 11:10:17 UTC, 1 replies.
- [Flink-1.8.1]POJO类型状态升级后字段赋值不正确 - posted by Edc <58...@qq.com> on 2021/04/21 12:20:46 UTC, 0 replies.
- 关于Flink 非blink planer下自持listagg - posted by 张海深 <18...@163.com> on 2021/04/21 13:32:24 UTC, 0 replies.
- flink在yarn集群上启动的问题 - posted by "tanggen911@163.com" <ta...@163.com> on 2021/04/21 15:47:03 UTC, 0 replies.
- flink sql cdc发到kafka消息表名信息缺失问题 - posted by "casel.chen" <ca...@126.com> on 2021/04/22 01:41:01 UTC, 0 replies.
- 回复:flink sql cdc发到kafka消息表名信息缺失问题 - posted by 飞翔 <yb...@qq.com> on 2021/04/22 03:01:22 UTC, 2 replies.
- 自定义RocketMqSource出现位点重置现象 - posted by zelin jin <fr...@gmail.com> on 2021/04/22 03:03:12 UTC, 0 replies.
- 回复: flink sql消费kafka join普通表为何会性能爬坡? - posted by 飞翔 <yb...@qq.com> on 2021/04/22 03:21:55 UTC, 4 replies.
- flink mysql cdc疑问 - posted by 流弊 <13...@qq.com> on 2021/04/22 06:22:18 UTC, 1 replies.
- 请问在使用processfunction 中的processelement()和onTimer()需要考虑并发问题吗? - posted by x2009438 <x2...@126.com> on 2021/04/22 07:35:07 UTC, 1 replies.
- Re: 疑问:当开启state.backend.incremental 后 Checkpointed Data Size 会不断变大 - posted by tianxy <lu...@163.com> on 2021/04/22 09:16:36 UTC, 1 replies.
- flink1.12.2使用rocksdb状态后端,checkpoint size变大 - posted by tianxy <lu...@163.com> on 2021/04/22 09:40:22 UTC, 0 replies.
- flink1.12.2,interval join并没有 inProcessingTime() and inEventTime() - posted by tianxy <lu...@163.com> on 2021/04/22 10:00:30 UTC, 0 replies.
- 关于upsert-kafka connector的问题 - posted by op <52...@qq.com> on 2021/04/22 10:05:13 UTC, 4 replies.
- Re: Flink 1.12.0 隔几个小时Checkpoint就会失败 - posted by 张锴 <zk...@gmail.com> on 2021/04/22 12:56:08 UTC, 0 replies.
- 回复:Flink 1.12.0 隔几个小时Checkpoint就会失败 - posted by 田向阳 <lu...@163.com> on 2021/04/22 14:05:50 UTC, 0 replies.
- flink run命令是否支持读取远程文件系统中的jar文件? - posted by "casel.chen" <ca...@126.com> on 2021/04/22 16:01:50 UTC, 1 replies.
- 回复: 关于upsert-kafka connector的问题 - posted by op <52...@qq.com> on 2021/04/23 01:46:01 UTC, 1 replies.
- flink native k8s 启动问题 - posted by 刘 <22...@qq.com> on 2021/04/23 02:42:32 UTC, 0 replies.
- 多个复杂算子保证精准一次性 - posted by Colar <52...@qq.com> on 2021/04/23 03:22:53 UTC, 2 replies.
- Re: Flinkjob消费kafka 失败,无法拿到offset值 - posted by Qingsheng Ren <re...@gmail.com> on 2021/04/23 04:54:17 UTC, 0 replies.
- InitializeOnMaster和FinalizeOnMaster接口为什么只有OutputFormat能用,InputFormat为什么不能用? - posted by kanata163 <ka...@163.com> on 2021/04/23 09:42:27 UTC, 2 replies.
- temporarily unavailable due to an ongoing leader election - posted by tianxy <lu...@163.com> on 2021/04/23 10:51:33 UTC, 0 replies.
- 官网文档和样例的不完整性和不严谨性的问题 - posted by "xuefli@outlook.com" <xu...@outlook.com> on 2021/04/23 19:02:00 UTC, 1 replies.
- flink cdc 消费mysql binlog 每次都是从头开始消费问题 - posted by 董建 <62...@163.com> on 2021/04/24 03:54:36 UTC, 0 replies.
- 撤回机制不起作用 - posted by Natasha <na...@foxmail.com> on 2021/04/25 03:43:38 UTC, 0 replies.
- flink撤回机制不起作用 - posted by Natasha <na...@foxmail.com> on 2021/04/25 03:46:17 UTC, 0 replies.
- Flink撤回机制不起作用 - posted by Natasha <na...@foxmail.com> on 2021/04/25 03:47:43 UTC, 1 replies.
- 回复:Flink撤回机制不起作用 - posted by 黄志高 <hu...@163.com> on 2021/04/25 05:01:25 UTC, 1 replies.
- Flink SQL Metrics中Kafka Offset请教 - posted by 邮件帮助中心 <yi...@163.com> on 2021/04/25 06:36:23 UTC, 2 replies.
- flink sql 使用cdc 同步postgresql的数据到ES,报错: org.postgresql.util.PSQLException: 错误: 内存用尽 - posted by william <71...@qq.com> on 2021/04/25 06:54:29 UTC, 0 replies.
- flink如何从流中取出自定义的数据结构并赋值给变量 - posted by 张锴 <zk...@gmail.com> on 2021/04/25 09:41:35 UTC, 2 replies.
- 提交FlinkSQLKafka表报异常cannt load user class - posted by "maker_dong@foxmail.com" <ma...@foxmail.com> on 2021/04/25 09:49:04 UTC, 3 replies.
- flinksql当一个job的kafka连接信息错误时,会导致整个session集群无法正常发布任务 - posted by chenxuying <cx...@163.com> on 2021/04/25 12:20:45 UTC, 0 replies.
- Dynamic Table Options 被优化器去掉了 - posted by macia kk <pr...@gmail.com> on 2021/04/25 16:31:08 UTC, 1 replies.
- flinkKafkaConsumer的offset提交的问题 - posted by lp <97...@qq.com> on 2021/04/26 02:51:18 UTC, 0 replies.
- Flink消费Kafka数据积压 - posted by Back moon <cc...@gmail.com> on 2021/04/26 03:48:57 UTC, 0 replies.
- DataStreamAPI 与flink sql疑问 - posted by 张锴 <zk...@gmail.com> on 2021/04/26 07:04:35 UTC, 2 replies.
- flink sql 使用cdc 同步数据到ES7,报错 Detail: 无法为包含1073741350字节的字符串缓冲区扩大525个更多字节 - posted by william <71...@qq.com> on 2021/04/26 07:14:43 UTC, 0 replies.
- flink sql 使用自定义函数 ,返回嵌套行, 查询报错 scala.MatchError - posted by gen <li...@outlook.com> on 2021/04/26 09:46:23 UTC, 5 replies.
- Flink消费Kafka报错:ByteArraySerializer is not an instance of org.apache.kafka.common.serialization.Serializer - posted by Colar <52...@qq.com> on 2021/04/26 10:04:57 UTC, 2 replies.
- flink 侧输出流类型转换问题 - posted by 张锴 <zk...@gmail.com> on 2021/04/26 11:17:40 UTC, 2 replies.
- 问题:flink 1.13编译 flink-parquet报错 -类重复:org.apache.flink.formats.parquet.generated.SimpleRecord - posted by HunterXHunter <13...@qq.com> on 2021/04/27 02:50:47 UTC, 2 replies.
- flink1.12.2 CLI连接hive出现异常 - posted by 张锴 <zk...@gmail.com> on 2021/04/27 05:59:15 UTC, 5 replies.
- flink cdc 查询mysql binlog时,在 streaming模式下,如果无法获得reload权限应该如何配置参数 - posted by 疾鹰击皓月 <17...@qq.com> on 2021/04/27 06:46:37 UTC, 0 replies.
- 回复:flink cdc 查询mysql binlog时,在 streaming模式下,如果无法获得reload权限应该如何配置参数 - posted by MOBIN <18...@163.com> on 2021/04/27 07:15:32 UTC, 1 replies.
- 使用processor api生成savepoints,运行后报的错误 - posted by 张美玲 <18...@163.com> on 2021/04/27 08:08:03 UTC, 0 replies.
- recovery from savepoint appear java.lang.NullPointerException - posted by 张美玲 <18...@163.com> on 2021/04/27 08:20:25 UTC, 0 replies.
- 解析kafka 非标准JSON问题 - posted by guoyb <86...@qq.com> on 2021/04/27 09:55:43 UTC, 1 replies.
- 回复:解析kafka 非标准JSON问题 - posted by guoyb <86...@qq.com> on 2021/04/27 10:55:00 UTC, 2 replies.
- 回复:Fwd: flink1.12.2 CLI连接hive出现异常 - posted by guoyb <86...@qq.com> on 2021/04/28 02:55:55 UTC, 0 replies.
- 使用Table&SQL API怎么构造多个sink - posted by Han Han1 Yue <yu...@lenovo.com> on 2021/04/28 06:29:34 UTC, 2 replies.
- org.apache.flink.util.FlinkRuntimeException: Error while retrieving data from RocksDB - posted by a593700624 <59...@qq.com> on 2021/04/28 07:17:17 UTC, 0 replies.
- 流跑着跑着,报出了rocksdb层面的错误 Error while retrieving data from RocksDB - posted by a593700624 <59...@qq.com> on 2021/04/28 07:19:47 UTC, 1 replies.
- flink sql 1.12 minibatch的问题 - posted by op <52...@qq.com> on 2021/04/28 08:53:47 UTC, 0 replies.
- flink 1.12.1 savepoint 重启问题 - posted by chaos <ji...@163.com> on 2021/04/28 09:00:23 UTC, 0 replies.
- 回复:flink 1.12.1 savepoint 重启问题 - posted by 田向阳 <lu...@163.com> on 2021/04/28 09:47:45 UTC, 0 replies.
- Re: 流跑着跑着,报出了rocksdb层面的错误 Error while retrieving data from RocksDB - posted by Peihui He <pe...@gmail.com> on 2021/04/28 12:20:40 UTC, 0 replies.
- flink 背压问题 - posted by Bruce Zhang <zh...@163.com> on 2021/04/29 03:45:17 UTC, 3 replies.
- Table-api sql 预检查 - posted by Michael Ran <gr...@163.com> on 2021/04/29 03:57:09 UTC, 6 replies.
- 回复:wd: flink1.12.2 CLI连接hive出现异常 - posted by 田向阳 <lu...@163.com> on 2021/04/29 04:09:57 UTC, 0 replies.
- Re: flink 1.10.2 Unknown operation 108 - posted by yeburan <bo...@126.com> on 2021/04/29 07:50:08 UTC, 0 replies.
- flink on yarn kerberos认证问题 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2021/04/30 07:04:33 UTC, 0 replies.
- Re: es线程死锁问题 - posted by satellite <18...@163.com> on 2021/04/30 07:33:19 UTC, 0 replies.
- flink on k8s 的flink-web-ui 访问问题 - posted by spoon_lz <sp...@126.com> on 2021/04/30 07:34:53 UTC, 0 replies.
- flink on yarn更新文件后重启失败 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2021/04/30 07:53:56 UTC, 0 replies.
- flink Kafka producer执行出错 - posted by "tanggen911@163.com" <ta...@163.com> on 2021/04/30 09:07:31 UTC, 0 replies.
- Flink SQL问题请教:Flink SQL中支持在一个TableEnvionment中多个DML语句提交时共用一个Yarn任务来运行吗? - posted by "yinghua_zh@163.com" <yi...@163.com> on 2021/04/30 09:13:53 UTC, 0 replies.
- flink watermark 合并策略机制 - posted by 张锴 <zk...@gmail.com> on 2021/04/30 09:22:02 UTC, 0 replies.