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

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

- Re: [DISCUSS] FLIP-133: Rework PyFlink Documentation - posted by Hequn Cheng <he...@apache.org> on 2020/08/01 00:40:51 UTC, 9 replies.
- Re:Re: flinksql kafka 插入mysql 的insert语法问题和唯一主键的问题 - posted by chenxuying <cx...@163.com> on 2020/08/01 02:32:03 UTC, 0 replies.
- flinksql insert overwrite 报错 INSERT OVERWRITE requires JDBC:MySQL DynamicTableSink to implement SupportsOverwrite interface - posted by chenxuying <cx...@163.com> on 2020/08/01 11:20:16 UTC, 4 replies.
- Re: Flink sql 转义字符问题 - posted by zilong xiao <ac...@gmail.com> on 2020/08/01 11:39:18 UTC, 0 replies.
- 数据预览 - posted by forideal <fs...@163.com> on 2020/08/01 11:48:44 UTC, 2 replies.
- Re: RocksDBKeyedStateBackend如何写磁盘 - posted by Congxian Qiu <qc...@gmail.com> on 2020/08/02 06:10:21 UTC, 1 replies.
- 回复：回复: Re: Flink实现Kafka到Mysql的 End-To-End Exactly-Once中遇到的问题 - posted by 王伟军 <22...@qq.com> on 2020/08/02 10:16:02 UTC, 0 replies.
- flink 1.11.0 conenctor-jdbc 报错 - posted by song wang <sd...@gmail.com> on 2020/08/03 02:16:24 UTC, 3 replies.
- UDF：Type is not supported: ANY - posted by zilong xiao <ac...@gmail.com> on 2020/08/03 02:43:10 UTC, 8 replies.
- Flink 1.11.1 消费带SASL的Kafka报错: java.lang.IllegalArgumentException: No serviceName defined in either JAAS or Kafka config - posted by RS <ti...@163.com> on 2020/08/03 02:53:19 UTC, 0 replies.
- flink中ScalarFunction函数疑问 - posted by 小学生 <20...@qq.com> on 2020/08/03 03:49:37 UTC, 2 replies.
- Re: pyflink 消费kafka protobuf数据 - posted by Benchao Li <li...@apache.org> on 2020/08/03 04:01:11 UTC, 0 replies.
- Re: flink1.9.1 在WebUI中查看committedOffsets指标为负值 - posted by bradyMk <zh...@126.com> on 2020/08/03 04:11:59 UTC, 0 replies.
- stream sink hive 在hdfs ha模式下 - posted by air23 <wa...@163.com> on 2020/08/03 05:32:04 UTC, 4 replies.
- Re: flink1.10.1/1.11.1 使用sql 进行group 和时间窗口操作后状态越来越大 - posted by 鱼子酱 <38...@qq.com> on 2020/08/03 05:50:43 UTC, 12 replies.
- 回复： flink1.10.1/1.11.1 使用sql 进行group 和时间窗口操作后状态越来越大 - posted by op <52...@qq.com> on 2020/08/03 06:17:49 UTC, 5 replies.
- 退订 - posted by "baiyg25281@hundsun.com" <ba...@hundsun.com> on 2020/08/03 08:27:32 UTC, 7 replies.
- Re: Behavior for flink job running on K8S failed after restart strategy exhausted - posted by Till Rohrmann <tr...@apache.org> on 2020/08/03 09:09:07 UTC, 12 replies.
- flink run-application 怎样设置配置文件的环境变量 - posted by Zhou Zach <wa...@163.com> on 2020/08/03 10:35:07 UTC, 2 replies.
- flink on yarn 读取 hbase数据时，Task失败，具体描述如下 - posted by 张锴 <zk...@gmail.com> on 2020/08/03 11:11:51 UTC, 0 replies.
- flink-1.11 模拟背压 - posted by kcz <57...@qq.com> on 2020/08/03 11:28:53 UTC, 2 replies.
- 回复：flink-1.11 模拟背压 - posted by kcz <57...@qq.com> on 2020/08/03 16:41:02 UTC, 0 replies.
- flink中Heartbeat问题 - posted by 小学生 <20...@qq.com> on 2020/08/04 01:22:26 UTC, 2 replies.
- arm，centos7下部署pyflink - posted by 琴师 <11...@qq.com> on 2020/08/04 01:29:55 UTC, 3 replies.
- 回复： arm，centos7下部署pyflink - posted by 琴师 <11...@qq.com> on 2020/08/04 02:19:29 UTC, 2 replies.
- flink1.9.1任务已经fail掉了，但在yarn上这个application还是在running - posted by bradyMk <zh...@126.com> on 2020/08/04 03:38:19 UTC, 11 replies.
- Flink DDL 写 Hive parquet 是否支持 snappy压缩 - posted by lydata <ly...@163.com> on 2020/08/04 03:39:20 UTC, 0 replies.
- 有界数据中batch和stream的区别 - posted by chenxuying <cx...@163.com> on 2020/08/04 03:43:55 UTC, 4 replies.
- Re: Flink DDL 写 Hive parquet 是否支持 snappy压缩 - posted by godfrey he <go...@gmail.com> on 2020/08/04 04:06:08 UTC, 0 replies.
- flink table api 中数据库字段大小写问题 - posted by lgs <99...@qq.com> on 2020/08/04 06:57:49 UTC, 3 replies.
- Kerberos 动态参数认证问题 - posted by sl...@aliyun.com.INVALID on 2020/08/04 08:07:27 UTC, 1 replies.
- Flink 通过sql client 启动的任务，kill掉之后，是否可以指定checkpoint恢复？ - posted by mispower <mi...@163.com> on 2020/08/04 08:28:12 UTC, 0 replies.
- 回复：flink1.9.1任务已经fail掉了，但在yarn上这个application还是在running - posted by JasonLee <17...@163.com> on 2020/08/04 08:32:49 UTC, 0 replies.
- 回复：Flink 通过sql client 启动的任务，kill掉之后，是否可以指定checkpoint恢复？ - posted by JasonLee <17...@163.com> on 2020/08/04 08:40:29 UTC, 0 replies.
- 维表实现无法加载配置文件 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/08/04 08:54:13 UTC, 1 replies.
- FLINK SQL view的数据复用问题 - posted by "kandy.wang" <ka...@163.com> on 2020/08/04 09:19:59 UTC, 5 replies.
- slot计算问题 - posted by ★猛★ <zh...@qq.com> on 2020/08/04 11:53:25 UTC, 1 replies.
- 求助：Flink有没有类似Storm的ack机制呢？ - posted by Bruce <br...@qq.com> on 2020/08/05 01:32:38 UTC, 1 replies.
- 回复： slot计算问题 - posted by ★猛★ <zh...@qq.com> on 2020/08/05 03:17:39 UTC, 0 replies.
- 回复：求助：Flink有没有类似Storm的ack机制呢？ - posted by Bruce <br...@qq.com> on 2020/08/05 05:44:24 UTC, 0 replies.
- 写入hive 问题 - posted by air23 <wa...@163.com> on 2020/08/05 07:38:26 UTC, 2 replies.
- The bytecode of the class does not match the source code - posted by 魏子涵 <wz...@163.com> on 2020/08/05 07:57:15 UTC, 3 replies.
- flink sql eos - posted by sl...@aliyun.com.INVALID on 2020/08/05 08:23:10 UTC, 1 replies.
- 回复： flink-1.11 模拟背压 - posted by kcz <57...@qq.com> on 2020/08/05 10:28:18 UTC, 0 replies.
- Flink Mysql sink按时间分库分表 - posted by 张健 <zh...@163.com> on 2020/08/05 12:36:31 UTC, 1 replies.
- 请教：用flink实现实时告警的功能 - posted by "samuel.qiu@ubtrobot.com" <sa...@ubtrobot.com> on 2020/08/06 02:26:19 UTC, 2 replies.
- 回复：请教：用flink实现实时告警的功能 - posted by 静谧雨寒 <fr...@vip.qq.com> on 2020/08/06 03:06:34 UTC, 0 replies.
- flink1.11 es connector - posted by Dream-底限 <zh...@akulaku.com> on 2020/08/06 03:20:20 UTC, 4 replies.
- In the future，the community plans to extend its functionality by providing a REST-based SQL - posted by air23 <wa...@163.com> on 2020/08/06 07:19:11 UTC, 1 replies.
- flink-OOME_Java heap space - posted by Roc Marshal <fl...@126.com> on 2020/08/06 08:28:17 UTC, 1 replies.
- flink timerservice注册的timer定时器只有少部分触发 - posted by 钟昊（zhonghao01）-商业智能部 <zh...@qiyi.com> on 2020/08/06 09:31:36 UTC, 4 replies.
- flink sql 添加全局唯一id 字段 - posted by drewfranklin <dr...@163.com> on 2020/08/06 10:27:03 UTC, 1 replies.
- 请教：时间属性字段传递问题，有办法解决吗？ - posted by Tianwang Li <li...@gmail.com> on 2020/08/06 13:12:29 UTC, 2 replies.
- 回复：请教：时间属性字段传递问题，有办法解决吗？ - posted by kcz <57...@qq.com> on 2020/08/06 15:03:50 UTC, 0 replies.
- Sql-client的checkpoint问题 - posted by king <ki...@163.com> on 2020/08/07 00:23:17 UTC, 0 replies.
- 转发：Sql-client的checkpoint问题 - posted by king <ki...@163.com> on 2020/08/07 01:05:54 UTC, 1 replies.
- flink-sql-connector-elasticsearch6_2.11_1.10.0 与 flink-connector-elasticsearch6_2.11_1.10.0 并存问题 - posted by 费文杰 <we...@zhangmen.com> on 2020/08/07 01:26:32 UTC, 2 replies.
- 回复：flink-sql-connector-elasticsearch6_2.11_1.10.0 与 flink-connector-elasticsearch6_2.11_1.10.0 并存问题 - posted by JasonLee <17...@163.com> on 2020/08/07 01:31:59 UTC, 0 replies.
- flinksql写出到kafka - posted by leiyanrui <11...@qq.com> on 2020/08/07 02:07:27 UTC, 0 replies.
- Re: stream sink hive 在hdfs ha模式下 java.net.UnknownHostException: nameservices1 - posted by "chengyanan1008@foxmail.com" <ch...@foxmail.com> on 2020/08/07 02:43:28 UTC, 0 replies.
- 使用StreamTableEnvironment.createTemporarySystemFunction注册UD(T)F异常 - posted by zz zhang <ol...@gmail.com> on 2020/08/07 03:00:00 UTC, 1 replies.
- flinksql jdbc异步维表 - posted by todd <to...@163.com> on 2020/08/07 03:03:12 UTC, 1 replies.
- Flink 1.10 on Yarn - posted by xuhaiLong <xi...@163.com> on 2020/08/07 03:37:59 UTC, 5 replies.
- Flink 1.11.1 on k8s 如何配置hadoop - posted by RS <ti...@163.com> on 2020/08/07 03:57:33 UTC, 5 replies.
- flinksql连接kafka，数据里面有个字段名字是time - posted by leiyanrui <11...@qq.com> on 2020/08/07 03:58:36 UTC, 7 replies.
- Re: 【PyFlink】对于数据以Csv()格式写入kafka报错，以及使用python udf时无法启动udf - posted by lgs <99...@qq.com> on 2020/08/07 05:44:58 UTC, 1 replies.
- flink1.11 DDL定义kafka source报错 - posted by 阿华田 <a1...@163.com> on 2020/08/07 05:49:20 UTC, 1 replies.
- 回复：flink1.11 DDL定义kafka source报错 - posted by 阿华田 <a1...@163.com> on 2020/08/07 06:03:03 UTC, 1 replies.
- 怎么把自己从list中取消,我想换个邮箱 - posted by 何宗谨 <he...@300.cn> on 2020/08/07 06:14:24 UTC, 1 replies.
- flink-jdbc_2.11:1.11.1依赖找不到 - posted by lydata <ly...@163.com> on 2020/08/07 06:47:29 UTC, 2 replies.
- Table Api执行sql如何设置sink并行度 - posted by wldd <wl...@163.com> on 2020/08/07 07:16:14 UTC, 3 replies.
- flink elasticsearch sink 反压如何解决 - posted by 大头糯米丸子 <yu...@gmail.com> on 2020/08/07 07:21:17 UTC, 0 replies.
- 使用flink-sql-connector-elasticsearch6_2.11_1.10.0.jar执行任务失败 - posted by 费文杰 <we...@zhangmen.com> on 2020/08/07 07:56:16 UTC, 2 replies.
- flink sql csv格式字段分隔符问题 - posted by "kandy.wang" <ka...@163.com> on 2020/08/07 08:27:40 UTC, 1 replies.
- 回复： Re: Table Api执行sql如何设置sink并行度 - posted by Cayden chen <11...@qq.com> on 2020/08/07 08:56:30 UTC, 1 replies.
- 回复：flink elasticsearch sink 反压如何解决 - posted by Cayden chen <11...@qq.com> on 2020/08/07 09:05:13 UTC, 0 replies.
- 回复： Flink 1.11.1 on k8s 如何配置hadoop - posted by Matt Wang <wa...@163.com> on 2020/08/07 09:05:42 UTC, 0 replies.
- 关于Flink1.11 CSV Format的一些疑问 - posted by WeiXubin <18...@163.com> on 2020/08/08 03:39:57 UTC, 2 replies.
- flink1.8中无法使用lettuce - posted by wujunxi <46...@qq.com> on 2020/08/08 05:30:57 UTC, 0 replies.
- Re: AsyncIO 用Redis做缓存 - posted by KrisWu <46...@qq.com> on 2020/08/08 09:15:08 UTC, 0 replies.
- flink sink redis - posted by leiyanrui <11...@qq.com> on 2020/08/08 09:16:44 UTC, 0 replies.
- flink1.8中应该使用lettuce哪个版本 - posted by 462329521 <46...@qq.com> on 2020/08/09 07:05:19 UTC, 0 replies.
- flinksql1.11 使用eventime消费kafka多分区时,没有水位线信息,聚合计算也不出结果 - posted by zhanglachun <zh...@163.com> on 2020/08/09 13:38:12 UTC, 2 replies.
- 来自郭华威的邮件 - posted by 郭华威 <gh...@163.com> on 2020/08/10 02:21:38 UTC, 4 replies.
- flink sql状态清理问题 - posted by op <52...@qq.com> on 2020/08/10 02:27:34 UTC, 2 replies.
- 回复： flink sql状态清理问题 - posted by op <52...@qq.com> on 2020/08/10 02:50:08 UTC, 2 replies.
- flink krb5.conf配置 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/08/10 07:09:02 UTC, 1 replies.
- 回复: flink krb5.conf配置 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/08/10 07:14:50 UTC, 0 replies.
- Flink slot 可以跨 job 共享吗？ - posted by "wanglei2@geekplus.com" <wa...@geekplus.com> on 2020/08/10 07:39:07 UTC, 2 replies.
- Flink任务大状态使用filesystem反压 - posted by Yang Peng <ya...@gmail.com> on 2020/08/10 07:55:03 UTC, 4 replies.
- flink集群搭建 - posted by Dream-底限 <zh...@akulaku.com> on 2020/08/10 08:21:15 UTC, 1 replies.
- 回复：回复： flink sql状态清理问题 - posted by op <52...@qq.com> on 2020/08/10 08:49:08 UTC, 0 replies.
- 读取hive表的数据转化为流；按照jdbc两阶段提交方式写入oracle数据库,没有异常但是checkpoint失败 - posted by Bruce <br...@qq.com> on 2020/08/10 09:01:36 UTC, 2 replies.
- 回复：flink集群搭建 - posted by Matt Wang <wa...@163.com> on 2020/08/10 09:57:13 UTC, 0 replies.
- 回复：读取hive表的数据转化为流；按照jdbc两阶段提交方式写入oracle数据库,没有异常但是checkpoint失败 - posted by Bruce <br...@qq.com> on 2020/08/10 10:12:10 UTC, 0 replies.
- 关于FlinkSQL的文档中flinksql的connector和catalog划分以及hive catalog和hive connector是否必须配合使用的问题。 - posted by "Zhao,Yi(SEC)" <zh...@baidu.com> on 2020/08/10 12:14:06 UTC, 9 replies.
- 请教flink计算一些报表需求的实现 - posted by lfgy <15...@163.com> on 2020/08/10 15:35:40 UTC, 1 replies.
- 请教flink计算一些报表需求的实现(附带任务图) - posted by lfgy <15...@163.com> on 2020/08/10 15:52:12 UTC, 0 replies.
- 改动source或sink operator后无法从savepoint恢复作业 - posted by Eleanore Jin <el...@gmail.com> on 2020/08/10 16:36:31 UTC, 0 replies.
- 答复: 请教flink计算一些报表需求的实现(附带任务图) - posted by zhao liang <zh...@gmail.com> on 2020/08/11 02:33:41 UTC, 0 replies.
- 请教关闭部署的问题 - posted by ab...@163.com on 2020/08/11 03:08:20 UTC, 1 replies.
- flink-1.10.1 想用 DDL 入 ES5.6 - posted by kcz <57...@qq.com> on 2020/08/11 03:18:09 UTC, 4 replies.
- no print - posted by 弦 <25...@qq.com> on 2020/08/11 03:30:24 UTC, 0 replies.
- Re: 请教关于部署的问题 - posted by "Zhao,Yi(SEC)" <zh...@baidu.com> on 2020/08/11 03:42:02 UTC, 0 replies.
- 一系列关于基于状态重启任务的问题 - posted by "Zhao,Yi(SEC)" <zh...@baidu.com> on 2020/08/11 03:55:08 UTC, 1 replies.
- 回复：no print - posted by jacky-cui <82...@qq.com> on 2020/08/11 03:57:34 UTC, 0 replies.
- Flink 1.10.1版本StreamingFileSink写入HDFS失败 - posted by Jian Wang <wa...@seagroup.com> on 2020/08/11 05:48:21 UTC, 1 replies.
- 回复： flink1.11 es connector - posted by jacky-cui <82...@qq.com> on 2020/08/11 06:33:34 UTC, 1 replies.
- flink 1.11 使用sql将流式数据写入hive - posted by "liyakun@huimin100.cn" <li...@huimin100.cn> on 2020/08/11 07:19:42 UTC, 3 replies.
- Table api son schema - posted by "Zhao,Yi(SEC)" <zh...@baidu.com> on 2020/08/11 07:39:46 UTC, 3 replies.
- 回复：flink 1.11 使用sql将流式数据写入hive - posted by liujian <13...@qq.com> on 2020/08/11 07:52:56 UTC, 0 replies.
- Flink 1.10 堆外内存一直在增加 - posted by ReignsDYL <19...@qq.com> on 2020/08/11 08:01:25 UTC, 1 replies.
- 关于FLinkSQL如何创建类json无限扩展的表结构问题 - posted by "Zhao,Yi(SEC)" <zh...@baidu.com> on 2020/08/11 08:03:34 UTC, 0 replies.
- 答复: 关于FLinkSQL如何创建类json无限扩展的表结构问题 - posted by zhao liang <zh...@gmail.com> on 2020/08/11 08:23:01 UTC, 1 replies.
- 自定义PatternProcessFunction编译出错，type erasure相关。 - posted by lgs <99...@qq.com> on 2020/08/11 08:53:51 UTC, 0 replies.
- Re: 答复: 关于FLinkSQL如何创建类json无限扩展的表结构问题 - posted by "Zhao,Yi(SEC)" <zh...@baidu.com> on 2020/08/11 08:58:17 UTC, 0 replies.
- Flink SQL No Watermark - posted by forideal <fs...@163.com> on 2020/08/11 09:13:01 UTC, 10 replies.
- flink 1.11 StreamingFileWriter及sql-client问题 - posted by "kandy.wang" <ka...@163.com> on 2020/08/11 13:15:03 UTC, 10 replies.
- flink1.11 sql使用问题 - posted by 魏烽 <we...@nequal.com> on 2020/08/11 14:26:53 UTC, 2 replies.
- Flink SQL CDC 的实时数据同步方案，替代debezium的问题 - posted by 陈韬 <to...@qq.com> on 2020/08/12 01:00:26 UTC, 0 replies.
- 关于flink sql的内置函数实现与debug - posted by shizk233 <wa...@gmail.com> on 2020/08/12 02:39:02 UTC, 3 replies.
- Re: Flink SQL CDC 的实时数据同步方案，替代debezium的问题 - posted by Jark Wu <im...@gmail.com> on 2020/08/12 02:59:03 UTC, 2 replies.
- 当数据源产生的速度过快时使用AscendingTimestampExtractor并没有忽略非递增的事件时间数据 - posted by SSY <56...@qq.com> on 2020/08/12 04:24:42 UTC, 2 replies.
- flink sql client：cdc 至elasticsearch 有问题（版本1.11.0）,提交任务成功，但web dashbord上却看不到任务！求看是不是bug?还是我配置有问题？ - posted by jindy_liu <28...@qq.com> on 2020/08/12 05:31:08 UTC, 1 replies.
- flink1.10.0任务失败但是application仍然在yarn运行不会自动kill - posted by 魏烽 <we...@nequal.com> on 2020/08/12 05:57:52 UTC, 2 replies.
- 关于FlinkSQL的一些最佳实践咨询 - posted by "Zhao,Yi(SEC)" <zh...@baidu.com> on 2020/08/12 06:20:24 UTC, 3 replies.
- flink中同时有多个大数据组件开启kerberos时keytab的选择 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/08/12 06:39:04 UTC, 0 replies.
- 回复: flink中同时有多个大数据组件开启kerberos时keytab的选择 - posted by "zjfplayer@hotmail.com" <zj...@hotmail.com> on 2020/08/12 06:46:42 UTC, 0 replies.
- flink 1.10.1 sql limit 不生效 - posted by Peihui He <pe...@gmail.com> on 2020/08/12 07:03:14 UTC, 6 replies.
- AppendStreamTableSink doesn't support consuming update changes - posted by xiao cai <fl...@163.com> on 2020/08/12 07:40:48 UTC, 2 replies.
- flink slot之间内存隔离问题 - posted by Cayden chen <11...@qq.com> on 2020/08/12 07:55:08 UTC, 1 replies.
- 使用Kafka Sink时报错：AppendStreamTableSink doesn't support consuming update changes - posted by xiao cai <fl...@163.com> on 2020/08/12 07:58:50 UTC, 2 replies.
- pyflink 1.11.1 execute_sql sql_update执行问题，下面三种情况只有第一种情况执行成功, 但是该方法是被Deprecated - posted by 徐振华 <hu...@foxmail.com> on 2020/08/12 08:00:04 UTC, 1 replies.
- 回复：使用Kafka Sink时报错：AppendStreamTableSink doesn't support consuming update changes - posted by xuzh <hu...@foxmail.com> on 2020/08/12 08:04:56 UTC, 0 replies.
- Re: pyflink 1.11.1 execute_sql sql_update执行问题，下面三种情况只有第一种情况执行成功, 但是该方法是被Deprecated - posted by Xingbo Huang <hx...@gmail.com> on 2020/08/12 08:11:46 UTC, 0 replies.
- 回复: flink 1.11 使用sql写入hdfs无法自动提交分区 - posted by "xuefli@outlook.com" <xu...@outlook.com> on 2020/08/12 08:21:22 UTC, 0 replies.
- 回复： pyflink 1.11.1 execute_sql sql_update执行问题，下面三种情况只有第一种情况执行成功, 但是该方法是被Deprecated - posted by xuzh <hu...@foxmail.com> on 2020/08/12 08:38:38 UTC, 0 replies.
- 用hive streaming写 orc文件的问题 - posted by "18579099920@163.com" <18...@163.com> on 2020/08/12 09:14:04 UTC, 7 replies.
- flink 1.11 udtf动态定义返回类型 - posted by 李强 <li...@skyon.com.cn> on 2020/08/12 09:32:17 UTC, 1 replies.
- FlinkSQL even time 定义问题 - posted by "Zhao,Yi(SEC)" <zh...@baidu.com> on 2020/08/12 09:36:30 UTC, 1 replies.
- 关于Flink CDC问题第二弹 - posted by 陈韬 <to...@qq.com> on 2020/08/12 12:07:30 UTC, 2 replies.
- Flink sql TUMBLE window 不支持offset吗 - posted by "Zhao,Yi(SEC)" <zh...@baidu.com> on 2020/08/12 12:14:38 UTC, 5 replies.
- 请问在flinksql中如何使用聚合函数 LISTAGG - posted by chenxuying <cx...@163.com> on 2020/08/12 13:25:17 UTC, 2 replies.
- flink 1.11 发布sql任务到yarn session报java.lang.NoClassDefFoundError: Could not initialize class org.apache.hadoop.hbase.util.ByteStringer - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/08/13 02:09:25 UTC, 1 replies.
- flink 1.11 udtf只能通过注解定义输出字段个数和类型吗？ - posted by 李强 <li...@skyon.com.cn> on 2020/08/13 02:09:38 UTC, 0 replies.
- 回复：关于FlinkSQL的一些最佳实践咨询 - posted by 靳亚洽 <ji...@163.com> on 2020/08/13 03:00:07 UTC, 0 replies.
- flink1.11错误 - posted by 小学生 <20...@qq.com> on 2020/08/13 03:05:03 UTC, 2 replies.
- flink1.11.1 flink on yarn 任务启动报错 - posted by 郭华威 <gh...@163.com> on 2020/08/13 03:05:09 UTC, 0 replies.
- TableColumn为啥不包含comment - posted by "Harold.Miao" <mi...@gmail.com> on 2020/08/13 03:08:25 UTC, 3 replies.
- 答复: 关于FlinkSQL的一些最佳实践咨询 - posted by zhao liang <zh...@gmail.com> on 2020/08/13 03:26:29 UTC, 0 replies.
- 如何设置FlinkSQL并行度 - posted by "Zhao,Yi(SEC)" <zh...@baidu.com> on 2020/08/13 03:44:57 UTC, 12 replies.
- Re: Re: 对于维表频繁更新，状态越来越大的场景如何保证数据的准确性 - posted by Jim Chen <ch...@gmail.com> on 2020/08/13 03:52:59 UTC, 2 replies.
- 请教关于Flink算子FINISHED状态时无法保存Checkpoint的问题 - posted by 杨豫鲁 <yj...@139.com> on 2020/08/13 03:55:27 UTC, 7 replies.
- FlinkSQL命令行方式提交sql任务的jar依赖问题 - posted by "Zhao,Yi(SEC)" <zh...@baidu.com> on 2020/08/13 05:01:56 UTC, 5 replies.
- Re: flink1.11.1 flink on yarn 任务启动报错 - posted by Congxian Qiu <qc...@gmail.com> on 2020/08/13 06:08:07 UTC, 1 replies.
- HBase Sink报错：UpsertStreamTableSink requires that Table has a full primary keys - posted by xiao cai <fl...@163.com> on 2020/08/13 06:26:36 UTC, 2 replies.
- flink 1.11 SQL Client 流式 join 出现了不应有的含 null 的行 - posted by LittleFall <15...@qq.com> on 2020/08/13 06:39:02 UTC, 0 replies.
- 只有一个节点消费flink - posted by 平常心 <11...@qq.com> on 2020/08/13 06:58:28 UTC, 0 replies.
- flink 1.11.1 sql client 流式 join 出现预期之外的含 null 行 - posted by LittleFall <15...@qq.com> on 2020/08/13 07:14:25 UTC, 2 replies.
- FLINK1.11.1 对OGG数据入HIVE的问题咨询 - posted by USERNAME <or...@126.com> on 2020/08/13 07:27:04 UTC, 2 replies.
- flink 1.11 日志不能正常打印问题 - posted by caozhen <ca...@163.com> on 2020/08/13 07:38:55 UTC, 8 replies.
- user-zh - posted by "15037433285@163.com" <15...@163.com> on 2020/08/13 07:39:31 UTC, 1 replies.
- 求助：flink 1.11.1 yarn perjob 模式配置zookeeper的HA后application提交超时，1.10时正常的 - posted by x2009438 <x2...@126.com> on 2020/08/13 09:35:06 UTC, 1 replies.
- 请问在 flink sql 中建立的多张表应当怎样分辨接收 kafka 传来的 canal-json？ - posted by LittleFall <15...@qq.com> on 2020/08/13 11:55:59 UTC, 2 replies.
- 关于flink升级 - posted by 引领 <yr...@163.com> on 2020/08/14 01:15:53 UTC, 1 replies.
- 回复：关于flink升级 - posted by "蒋佳成(Jiacheng Jiang)" <92...@qq.com> on 2020/08/14 01:24:54 UTC, 2 replies.
- 回复：关于flink升级 - posted by 引领 <yr...@163.com> on 2020/08/14 03:09:00 UTC, 0 replies.
- flink 1.11 SQL idea调试无数据也无报错 - posted by DanielGu <61...@qq.com> on 2020/08/14 03:44:51 UTC, 4 replies.
- 请教大佬一个在flink调用kafka数据源时'scan.startup.mode'参数的使用问题 - posted by yulu yang <yj...@gmail.com> on 2020/08/14 04:44:03 UTC, 4 replies.
- Flink任务写入kafka 开启了EOS，statebackend为rocksdb，任务反压source端日志量堆积从cp恢复失败 - posted by Yang Peng <ya...@gmail.com> on 2020/08/14 05:01:28 UTC, 10 replies.
- 回复：请教大佬一个在flink调用kafka数据源时'scan.startup.mode'参数的使用问题 - posted by 魏子涵 <wz...@163.com> on 2020/08/14 05:19:35 UTC, 1 replies.
- 回复：请教关于Flink算子FINISHED状态时无法保存Checkpoint的问题 - posted by 吴磊 <wu...@foxmail.com> on 2020/08/14 05:48:49 UTC, 0 replies.
- 回复：Flink任务写入kafka 开启了EOS，statebackend为rocksdb，任务反压source端日志量堆积从cp恢复失败 - posted by 宇 <fr...@qq.com> on 2020/08/14 05:57:30 UTC, 0 replies.
- flink sql作业state size一直增加 - posted by sunfulin <su...@163.com> on 2020/08/14 06:05:40 UTC, 3 replies.
- 回复: flink 1.11 发布sql任务到yarn session报java.lang.NoClassDefFoundError: Could not initialize class org.apache.hadoop.hbase.util.ByteStringer - posted by "wind.fly.vip@outlook.com" <wi...@outlook.com> on 2020/08/14 10:37:12 UTC, 0 replies.
- flink1.9.1用采用-d（分离模式提交）作业报错，但是不加-d是可以正常跑的 - posted by bradyMk <zh...@126.com> on 2020/08/14 10:51:45 UTC, 6 replies.
- FlinkSQL tableEnv 依赖问题 - posted by 赵一旦 <hi...@gmail.com> on 2020/08/14 11:13:24 UTC, 9 replies.
- 答复: HBase Sink报错：UpsertStreamTableSink requires that Table has a full primary keys - posted by xiao cai <fl...@163.com> on 2020/08/14 16:05:26 UTC, 0 replies.
- Flink参数配置设置不生效 - posted by 魏烽 <we...@nequal.com> on 2020/08/15 01:44:17 UTC, 3 replies.
- 通过Flink web ui上传jar包时无响应 - posted by Shiyuan L <ha...@gmail.com> on 2020/08/15 02:44:11 UTC, 1 replies.
- flink state ttl状态清理和重新计算的疑问 - posted by sunfulin <su...@163.com> on 2020/08/15 05:15:26 UTC, 4 replies.
- 不使用minibatch时状态丢失的异常 - posted by sunfulin <su...@163.com> on 2020/08/15 07:36:36 UTC, 1 replies.
- 回复：Flink参数配置设置不生效 - posted by 魏烽 <we...@nequal.com> on 2020/08/15 14:51:28 UTC, 0 replies.
- Re: flink interval join后按窗口聚组问题 - posted by Tianwang Li <li...@gmail.com> on 2020/08/16 02:40:13 UTC, 3 replies.
- 如何在KeyedProcessFunction中获取processingTime - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/08/16 11:49:35 UTC, 2 replies.
- 在sink 执行notifyCheckpointComplete 方法时能否收到上游 snapshot collect 发送的数据？ - posted by key lou <lo...@gmail.com> on 2020/08/16 13:17:17 UTC, 3 replies.
- 回复：flink-1.10.1 想用 DDL 入 ES5.6 - posted by kcz <57...@qq.com> on 2020/08/17 00:34:47 UTC, 2 replies.
- flink1.11任务资源分批 - posted by Dream-底限 <zh...@akulaku.com> on 2020/08/17 03:33:37 UTC, 1 replies.
- jobmanager异常 - posted by "18500348251@163.com" <18...@163.com> on 2020/08/17 03:49:12 UTC, 1 replies.
- Print SQL connector无法正常使用 - posted by xiao cai <fl...@163.com> on 2020/08/17 03:52:22 UTC, 4 replies.
- ScalarFunction 访问 state - posted by forideal <fs...@163.com> on 2020/08/17 04:13:38 UTC, 2 replies.
- （无主题） - posted by superainbower <su...@163.com> on 2020/08/17 04:32:13 UTC, 1 replies.
- 回复：（无主题） - posted by zhiyezou <15...@qq.com> on 2020/08/17 05:22:49 UTC, 0 replies.
- 回复：（无主题） - posted by zhiyezou <15...@qq.com> on 2020/08/17 07:24:16 UTC, 0 replies.
- flink sql在实时数仓中，关联hbase维表频繁变化的问题 - posted by Jim Chen <ch...@gmail.com> on 2020/08/17 08:28:17 UTC, 5 replies.
- flink cdc能支持分库分表读取吗 - posted by "18579099920@163.com" <18...@163.com> on 2020/08/17 08:34:53 UTC, 1 replies.
- PyFlink 写入ES - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/08/17 09:11:11 UTC, 1 replies.
- 答复: flink sql在实时数仓中，关联hbase维表频繁变化的问题 - posted by zhao liang <zh...@gmail.com> on 2020/08/17 09:29:29 UTC, 0 replies.
- sql client 并行度问题 - posted by "18579099920@163.com" <18...@163.com> on 2020/08/17 09:51:06 UTC, 1 replies.
- flink 1.10.1 跑批任务 OutOfMemoryError: Metaspace - posted by 胡松 <hs...@qq.com> on 2020/08/17 10:11:12 UTC, 3 replies.
- flink sql 数据异常导致任务失败 - posted by 赵一旦 <hi...@gmail.com> on 2020/08/17 11:15:23 UTC, 7 replies.
- PyFlink 中间表 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/08/17 11:55:13 UTC, 1 replies.
- flink1.11 mysql 分页查询 - posted by china_tao <ta...@163.com> on 2020/08/17 12:44:58 UTC, 5 replies.
- 1.11 kafka producer 只往一个partition里写 - posted by x2009438 <x2...@126.com> on 2020/08/17 14:03:09 UTC, 2 replies.
- 回复：1.11 kafka producer 只往一个partition里写 - posted by cs <58...@qq.com> on 2020/08/17 15:25:59 UTC, 1 replies.
- 回复： 1.11 kafka producer 只往一个partition里写 - posted by cs <58...@qq.com> on 2020/08/18 05:41:39 UTC, 3 replies.
- 能否考虑针对检查点和保存点设置不同的超时时间 - posted by 赵一旦 <hi...@gmail.com> on 2020/08/18 06:38:42 UTC, 2 replies.
- task传输数据时反序列化失败 - posted by shizk233 <wa...@gmail.com> on 2020/08/18 08:08:37 UTC, 2 replies.
- hive Streaming Reading 无法分组统计 - posted by "18579099920@163.com" <18...@163.com> on 2020/08/18 09:08:00 UTC, 1 replies.
- FlinkSQL sink 到 kafka partition 规则是怎样的？ - posted by "wanglei2@geekplus.com" <wa...@geekplus.com> on 2020/08/18 09:17:14 UTC, 2 replies.
- flink DataStream scala api can not overloaded method aggregate - posted by Zhou Zach <wa...@163.com> on 2020/08/18 09:20:31 UTC, 1 replies.
- flink 1.11 order by rowtime报错 - posted by 郑斌斌 <zh...@heint.cn> on 2020/08/18 09:45:09 UTC, 5 replies.
- 回复： flink 1.10.1 跑批任务 OutOfMemoryError: Metaspace - posted by 胡松 <hs...@qq.com> on 2020/08/18 12:05:22 UTC, 2 replies.
- flink集成到cdh - posted by smq <37...@qq.com> on 2020/08/18 12:16:46 UTC, 2 replies.
- Flink SQL血缘关系 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/08/18 12:29:53 UTC, 1 replies.
- 【bug】flink 1.11使用连接器时schema丢失DataType指定的物理信息 - posted by 赵建云 <zh...@outlook.com> on 2020/08/18 14:09:13 UTC, 3 replies.
- 1.11版本，执行任务报错：Cannot have more than one execute() or executeAsyc() call in a single environment - posted by Asahi Lee <97...@qq.com> on 2020/08/18 15:11:16 UTC, 1 replies.
- flink本地编译源码失败 - posted by 魏烽 <we...@nequal.com> on 2020/08/18 15:17:47 UTC, 3 replies.
- flink sql 如何指定之前的checkpoint执行 - posted by superainbower <su...@163.com> on 2020/08/19 01:09:21 UTC, 2 replies.
- Flink1.11 hive catalog使用 - posted by Dream-底限 <zh...@akulaku.com> on 2020/08/19 02:53:03 UTC, 6 replies.
- flink生产环境使用 - posted by 引领 <yr...@163.com> on 2020/08/19 02:56:56 UTC, 1 replies.
- flink1.12啥时候会出呢？ - posted by 赵一旦 <hi...@gmail.com> on 2020/08/19 03:16:28 UTC, 1 replies.
- 对于intervaljoin类型的任务，配置jobmanager.execution.failover-strategy为region时，会触发频繁的task cancel - posted by jiafu <53...@qq.com> on 2020/08/19 03:50:39 UTC, 0 replies.
- Flink on Yarn 启动任务，任务重启后貌似taskmanager中会丢失lib中的jar文件 - posted by xiao cai <fl...@163.com> on 2020/08/19 04:49:47 UTC, 2 replies.
- 回复：flink 1.11 order by rowtime报错 - posted by 郑斌斌 <zh...@heint.cn> on 2020/08/19 05:20:29 UTC, 1 replies.
- flink1.11.1 SQL任务启动报错 - posted by hb <34...@163.com> on 2020/08/19 06:15:19 UTC, 0 replies.
- Flink运行偶尔会报AskTimeoutException等 - posted by 赵一旦 <hi...@gmail.com> on 2020/08/19 07:11:11 UTC, 0 replies.
- flink 1.11 web ui请教 - posted by ab...@163.com on 2020/08/19 07:33:25 UTC, 3 replies.
- flink任务提交 - posted by Dream-底限 <zh...@akulaku.com> on 2020/08/19 07:52:15 UTC, 9 replies.
- flinkSQL eventtime问题 - posted by ★猛★ <zh...@qq.com> on 2020/08/19 09:22:22 UTC, 1 replies.
- 回复： flinkSQL eventtime问题 - posted by ★猛★ <zh...@qq.com> on 2020/08/19 09:48:18 UTC, 1 replies.
- 有什么方式基于yarn集群直接运行flink任务（仅部署yarn集群，不部署flink） - posted by 赵一旦 <hi...@gmail.com> on 2020/08/19 09:53:49 UTC, 4 replies.
- Flink StreamingFileSink滚动策略 - posted by guoliang_wang1335 <gu...@163.com> on 2020/08/19 10:19:59 UTC, 2 replies.
- TumblingProcessingTimeWindows 每来一条消息就会 trigger aggregate function - posted by "wanglei2@geekplus.com" <wa...@geekplus.com> on 2020/08/19 10:27:25 UTC, 2 replies.
- Re: TumblingProcessingTimeWindows 每来一条消息就会 trigger aggregate function - posted by 赵一旦 <hi...@gmail.com> on 2020/08/19 10:41:03 UTC, 6 replies.
- flink kafka 数据丢失 - posted by steven chen <st...@163.com> on 2020/08/19 14:45:22 UTC, 1 replies.
- 答复: Flink on Yarn 启动任务，任务重启后貌似taskmanager中会丢失lib中的jar文件 - posted by 范超 <fa...@mgtv.com> on 2020/08/20 01:11:18 UTC, 3 replies.
- kafka分区数扩容对flink任务的影响 - posted by 赵一旦 <hi...@gmail.com> on 2020/08/20 02:40:50 UTC, 2 replies.
- 增量che ckpoint - posted by superainbower <su...@163.com> on 2020/08/20 02:46:31 UTC, 3 replies.
- flink1.11启动问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/08/20 02:59:28 UTC, 1 replies.
- Orc文件问题请教 - posted by ab...@163.com on 2020/08/20 04:09:45 UTC, 2 replies.
- 回复： flink 1.11 SQL idea调试无数据也无报错 - posted by Daniel51 <da...@vip.qq.com> on 2020/08/20 04:19:48 UTC, 0 replies.
- KeyedCoProcessFunction中的状态数据是否存在资源竞争的可能 - posted by shizk233 <wa...@gmail.com> on 2020/08/20 06:22:32 UTC, 5 replies.
- 回复：答复: Flink on Yarn 启动任务，任务重启后貌似taskmanager中会丢失lib中的jar文件 - posted by xiao cai <fl...@163.com> on 2020/08/20 06:27:19 UTC, 0 replies.
- 回复： KeyedCoProcessFunction中的状态数据是否存在资源竞争的可能 - posted by Cayden chen <11...@qq.com> on 2020/08/20 08:57:59 UTC, 0 replies.
- DDL中声明主键会报类型不匹配 - posted by xiao cai <fl...@163.com> on 2020/08/20 09:19:32 UTC, 2 replies.
- state序列化问题 - posted by shizk233 <wa...@gmail.com> on 2020/08/20 10:00:45 UTC, 4 replies.
- 关于hive的一个疑问 - posted by Bruce <br...@qq.com> on 2020/08/20 11:52:12 UTC, 1 replies.
- JDBC connector 写入 mysql 每秒大约只有 200KB 是正常的吗 - posted by LittleFall <15...@qq.com> on 2020/08/20 11:56:41 UTC, 4 replies.
- Flink 启动问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/08/20 12:40:39 UTC, 2 replies.
- 回复： JDBC connector 写入 mysql 每秒大约只有 200KB 是正常的吗 - posted by 引领 <yr...@163.com> on 2020/08/21 01:41:03 UTC, 0 replies.
- Flink 1.10.1 on Yarn - posted by xuhaiLong <xi...@163.com> on 2020/08/21 02:11:05 UTC, 0 replies.
- flink orc与hive2.1.1版本冲突怎么解决 - posted by ab...@163.com on 2020/08/21 02:17:34 UTC, 10 replies.
- Flink SQL Map类型字段大小写不敏感支持 - posted by zilong xiao <ac...@gmail.com> on 2020/08/21 03:03:43 UTC, 5 replies.
- flink1.10中hive module 没有plus，greaterThan等函数 - posted by faaron zheng <fa...@gmail.com> on 2020/08/21 03:06:31 UTC, 3 replies.
- hive只作为元数据管理可以读到具体的表数据吗？ - posted by Bruce <br...@qq.com> on 2020/08/21 03:07:31 UTC, 1 replies.
- taskmanager引用通用jdbc连接池的问题 - posted by Bruce <br...@qq.com> on 2020/08/21 03:09:11 UTC, 1 replies.
- 1.11版本，关于TableEnvironment.executeSql("insert into ...")，job名称设置的问题 - posted by Asahi Lee <97...@qq.com> on 2020/08/21 03:11:32 UTC, 3 replies.
- 回复：flink1.10中hive module 没有plus，greaterThan等函数 - posted by faaron zheng <fa...@gmail.com> on 2020/08/21 03:27:32 UTC, 0 replies.
- flink prometheus 无法上报accumulator类型监控吗 - posted by 赵一旦 <hi...@gmail.com> on 2020/08/21 08:20:04 UTC, 5 replies.
- flink1.11 cdc使用 - posted by Dream-底限 <zh...@akulaku.com> on 2020/08/21 08:58:26 UTC, 2 replies.
- flink-sql-gateway还会更新吗 - posted by "18579099920@163.com" <18...@163.com> on 2020/08/21 09:48:22 UTC, 6 replies.
- 流处理任务中checkpoint失败 - posted by "Robert.Zhang" <17...@qq.com> on 2020/08/21 10:31:36 UTC, 3 replies.
- 有没有可能使用tikv作为flink 分布式的backend - posted by wxpcc <wx...@outlook.com> on 2020/08/21 10:33:42 UTC, 5 replies.
- 基于flink1.10源码编译问题 - posted by 魏烽 <we...@nequal.com> on 2020/08/21 12:44:20 UTC, 2 replies.
- flink on yarn配置问题 - posted by 赵一旦 <hi...@gmail.com> on 2020/08/21 15:11:58 UTC, 9 replies.
- Elasticsearch 写入问题 - posted by ab...@163.com on 2020/08/23 10:10:50 UTC, 1 replies.
- flink 1.11.1 与HDP3.0.1中的hive集成，查询不出hive表数据 - posted by 黄蓉 <je...@gmail.com> on 2020/08/23 19:01:51 UTC, 3 replies.
- 回复： 1.11版本，关于TableEnvironment.executeSql("insert into ...")，job名称设置的问题 - posted by Asahi Lee <97...@qq.com> on 2020/08/24 02:22:05 UTC, 0 replies.
- Flink log4j2 问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/08/24 03:17:55 UTC, 1 replies.
- 请教 hive streaming 报错 - posted by McClone <ab...@163.com> on 2020/08/24 06:07:40 UTC, 2 replies.
- 关于flink 读取 jdbc报错详情，序列化报错 - posted by 引领 <yr...@163.com> on 2020/08/24 07:34:15 UTC, 1 replies.
- 报错 Could not resolve ResourceManager address akka.tcp://flink@hostname:16098/user/resourcemanager - posted by song wang <sd...@gmail.com> on 2020/08/24 07:40:44 UTC, 17 replies.
- Re[2]: flink 1.11.1 与HDP3.0.1中的hive集成，查询不出hive表数据 - posted by 黄蓉 <je...@gmail.com> on 2020/08/24 07:43:26 UTC, 0 replies.
- flink kafka 分区问题 - posted by steven chen <st...@163.com> on 2020/08/24 08:04:14 UTC, 0 replies.
- flink1.10以后，task堆外内存什么时候使用？ - posted by caozhen <ca...@163.com> on 2020/08/24 08:27:52 UTC, 1 replies.
- flink on yarn默认GC的问题 - posted by shizk233 <wa...@gmail.com> on 2020/08/24 09:26:23 UTC, 2 replies.
- 请问一下，flink 1.11 的cdc历史数据问题 - posted by "dixingxing85@163.com" <di...@163.com> on 2020/08/24 09:27:24 UTC, 4 replies.
- flink 1.10 如何监控 Managed memory 使用量 - posted by 莫失莫忘 <xi...@qq.com> on 2020/08/24 09:53:09 UTC, 2 replies.
- flink taskmanager 因为内存超了container限制被yarn kill 问题定位 - posted by 柯四海 <26...@qq.com> on 2020/08/24 09:58:30 UTC, 2 replies.
- flink1.11 sql api使用per job模式提交后，客户端退出 - posted by lijufeng2016 <92...@qq.com> on 2020/08/24 11:15:01 UTC, 2 replies.
- hive-exec依赖导致hadoop冲突问题 - posted by "amenhub@163.com" <am...@163.com> on 2020/08/24 12:40:52 UTC, 2 replies.
- 回复： flink taskmanager 因为内存超了container限制被yarn kill 问题定位 - posted by 柯四海 <26...@qq.com> on 2020/08/24 12:55:43 UTC, 0 replies.
- 回复: hive-exec依赖导致hadoop冲突问题 - posted by "amenhub@163.com" <am...@163.com> on 2020/08/24 13:04:43 UTC, 0 replies.
- 回复：流处理任务中checkpoint失败 - posted by "Robert.Zhang" <17...@qq.com> on 2020/08/24 16:58:24 UTC, 2 replies.
- flink-sql-gateway的安全与多租 - posted by 华小研 <xi...@gmail.com> on 2020/08/25 02:25:33 UTC, 0 replies.
- [ANNOUNCE] Apache Flink 1.10.2 released - posted by Zhu Zhu <re...@gmail.com> on 2020/08/25 03:36:30 UTC, 10 replies.
- 回复: Re: 请问一下，flink 1.11 的cdc历史数据问题 - posted by "dixingxing85@163.com" <di...@163.com> on 2020/08/25 04:47:38 UTC, 0 replies.
- flink on yarn 提交作业application模式的2个疑问 - posted by yang zhang <zh...@icloud.com.INVALID> on 2020/08/25 05:49:57 UTC, 4 replies.
- flink1.11 sql问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/08/25 05:58:50 UTC, 3 replies.
- 回复：flink1.11 sql问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/08/25 06:05:36 UTC, 3 replies.
- Flink-1.11.1 Application-Mode提交测试 - posted by "amenhub@163.com" <am...@163.com> on 2020/08/25 07:29:09 UTC, 1 replies.
- flink webui前端 - posted by 罗显宴 <15...@163.com> on 2020/08/25 07:42:51 UTC, 1 replies.
- 回复： flink1.11 sql问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/08/25 07:46:38 UTC, 3 replies.
- 从kafka读取数据转化为Pojo类型的数据流注册成表，新消息来了，注册表的查询结果不打印 - posted by yang zhang <zh...@icloud.com.INVALID> on 2020/08/25 07:53:20 UTC, 2 replies.
- 请教一下flink链接hive的权限控制 - posted by faaron zheng <fa...@gmail.com> on 2020/08/25 07:54:52 UTC, 2 replies.
- Flink运行时可以转移数据吗？ - posted by Sun_yijia <jo...@qq.com> on 2020/08/25 08:11:28 UTC, 3 replies.
- 回复：请教一下flink链接hive的权限控制 - posted by xiaoyan hua <xi...@gmail.com> on 2020/08/25 08:48:01 UTC, 1 replies.
- 关于flink任务的日志收集到kafka，可以在logback配置文件中，加如每个job的id或者name吗？ - posted by Jim Chen <ch...@gmail.com> on 2020/08/25 08:48:39 UTC, 10 replies.
- ProcessWindowFunction为何在clear方法中无法清理状态-v1.10.1 - posted by x <35...@qq.com> on 2020/08/25 10:24:51 UTC, 1 replies.
- flink checkpoint导致反压严重 - posted by zhanglachun <zh...@163.com> on 2020/08/25 15:25:57 UTC, 6 replies.
- flink1.11单机执行slot出错 - posted by 小学生 <20...@qq.com> on 2020/08/26 01:24:55 UTC, 1 replies.
- flink1.11 kafka sql connector - posted by Dream-底限 <zh...@akulaku.com> on 2020/08/26 02:42:27 UTC, 1 replies.
- 【闫云鹏】Flink cdc 连接mysql5.7.25报错 - posted by "Yan,Yunpeng(DXM,PB)" <ya...@duxiaoman.com> on 2020/08/26 03:24:11 UTC, 4 replies.
- 关于sink失败不消费kafka消息的处理 - posted by 范超 <fa...@mgtv.com> on 2020/08/26 03:37:43 UTC, 9 replies.
- 答复: 关于sink失败不消费kafka消息的处理 - posted by 范超 <fa...@mgtv.com> on 2020/08/26 05:55:28 UTC, 3 replies.
- 1.11.2大概什么时候发布 - posted by ab...@163.com on 2020/08/26 07:41:59 UTC, 2 replies.
- pyflink kafka connector的问题 - posted by Wanmail1997 <Wa...@88.com> on 2020/08/26 09:32:12 UTC, 2 replies.
- How to visit outer service in batch for sql - posted by 刘建刚 <li...@gmail.com> on 2020/08/26 12:02:04 UTC, 0 replies.
- Re: Flink SQLMap类型字段大小写不敏感支持 - posted by Danny Chan <yu...@gmail.com> on 2020/08/26 12:41:55 UTC, 0 replies.
- 回复：流处理任务中checkpoint失败 - posted by "Robert.Zhang" <17...@qq.com> on 2020/08/26 14:17:44 UTC, 2 replies.
- 文件的增量监控 - posted by lj879933274 <lj...@163.com> on 2020/08/27 00:03:21 UTC, 1 replies.
- Flink 维表延迟join - posted by 郑斌斌 <zh...@heint.cn> on 2020/08/27 01:22:45 UTC, 10 replies.
- 求助：实时计算累计UV时，为什么使用MapState和BloomFilter,在checkpoint时的状态大小没有差异 - posted by x <35...@qq.com> on 2020/08/27 05:48:32 UTC, 1 replies.
- 回复： ProcessWindowFunction为何在clear方法中无法清理状态-v1.10.1 - posted by x <35...@qq.com> on 2020/08/27 06:00:36 UTC, 1 replies.
- flink1.8 AsyncIO算子中使用同步操作结果会是异步的吗？ - posted by 462329521 <46...@qq.com> on 2020/08/27 06:22:35 UTC, 0 replies.
- [需求调研] Stream SQL window join 支持 - posted by Danny Chan <yu...@gmail.com> on 2020/08/27 06:48:37 UTC, 1 replies.
- Flink SQL 问题; - posted by air23 <wa...@163.com> on 2020/08/27 07:11:00 UTC, 3 replies.
- Source 定时执行sql，只执行一次就close了source - posted by zhao liang <zh...@gmail.com> on 2020/08/27 07:48:40 UTC, 1 replies.
- Flink SQL 有提供参数支持大小写不敏感吗？ - posted by Tianwang Li <li...@gmail.com> on 2020/08/27 07:52:30 UTC, 1 replies.
- Re: Flink SQL有提供参数支持大小写不敏感吗？ - posted by Danny Chan <yu...@gmail.com> on 2020/08/27 08:12:12 UTC, 0 replies.
- 回复： [需求调研] Stream SQL window join 支持 - posted by Cayden chen <11...@qq.com> on 2020/08/27 08:15:36 UTC, 0 replies.
- 回复: Source 定时执行sql，只执行一次就close了source - posted by "gongpulin@163.com" <go...@163.com> on 2020/08/27 08:21:54 UTC, 1 replies.
- [ANNOUNCE] New PMC member: Dian Fu - posted by jincheng sun <su...@gmail.com> on 2020/08/27 09:23:09 UTC, 18 replies.
- Re: flink on yarn日志问题 - posted by Jim Chen <ch...@gmail.com> on 2020/08/27 10:16:29 UTC, 1 replies.
- quickstart工程默认的log不打印到console - posted by Qishang <zh...@gmail.com> on 2020/08/27 10:27:49 UTC, 0 replies.
- flink stream sink hive - posted by "liyakun@huimin100.cn" <li...@huimin100.cn> on 2020/08/27 11:09:29 UTC, 3 replies.
- 回复: flink stream sink hive - posted by "liyakun@huimin100.cn" <li...@huimin100.cn> on 2020/08/27 12:08:54 UTC, 0 replies.
- tidb Binlog 整库同步到 hive - posted by Qishang <zh...@gmail.com> on 2020/08/27 13:57:08 UTC, 6 replies.
- 回复：RE: Flink运行时可以转移数据吗？ - posted by Sun_yijia <jo...@qq.com> on 2020/08/27 16:36:37 UTC, 0 replies.
- 回复： Flink运行时可以转移数据吗？ - posted by Sun_yijia <jo...@qq.com> on 2020/08/27 16:38:45 UTC, 0 replies.
- 回复：回复：流处理任务中checkpoint失败 - posted by "Robert.Zhang" <17...@qq.com> on 2020/08/27 17:58:56 UTC, 0 replies.
- flink1.11读取kafka问题 - posted by 小学生 <20...@qq.com> on 2020/08/28 01:22:23 UTC, 4 replies.
- 一个main方法启动2个yarn job问题 - posted by air23 <wa...@163.com> on 2020/08/28 01:41:14 UTC, 2 replies.
- Flink Kafka作业异常重启，从Checkpoint恢复后重复推送数据部分数据如何处理？ - posted by Kevin Dai <15...@qq.com> on 2020/08/28 01:43:51 UTC, 2 replies.
- 从savepoint 启动以后，无法在checkpoint页面看到last restore的相关信息 - posted by 范超 <fa...@mgtv.com> on 2020/08/28 03:37:03 UTC, 2 replies.
- flink-sql 1.11整合hbase的查询性能问题 - posted by 大罗 <ti...@163.com> on 2020/08/28 03:52:44 UTC, 7 replies.
- 答复: 从savepoint 启动以后，无法在checkpoint页面看到last restore的相关信息 - posted by 范超 <fa...@mgtv.com> on 2020/08/28 06:01:59 UTC, 1 replies.
- flink1.11时间函数 - posted by Dream-底限 <zh...@akulaku.com> on 2020/08/28 06:50:27 UTC, 4 replies.
- flink1.11连接mysql问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/08/28 07:02:29 UTC, 2 replies.
- 答复: flink prometheus 无法上报accumulator类型监控吗 - posted by 范超 <fa...@mgtv.com> on 2020/08/28 08:13:38 UTC, 0 replies.
- flink1.10 sink结果到mysql的问题 - posted by 赵子仪 <zy...@163.com> on 2020/08/28 08:33:10 UTC, 0 replies.
- flink文档 - posted by Dream-底限 <zh...@akulaku.com> on 2020/08/28 08:42:58 UTC, 1 replies.
- flink如何将时间戳转换为长整型并精确到毫秒 - posted by Dream-底限 <zh...@akulaku.com> on 2020/08/28 09:08:54 UTC, 0 replies.
- flink1.10 sql state 聚合函数窗口统计,状态越来越大，无法自动清理问题 - posted by zhuyuping <10...@qq.com> on 2020/08/28 13:13:37 UTC, 1 replies.
- flink sql 计算列不支持comment - posted by sl...@aliyun.com.INVALID on 2020/08/29 05:37:22 UTC, 1 replies.
- 【Flink监控文件变化】 - posted by 忝忝向仧 <15...@qq.com> on 2020/08/29 09:35:16 UTC, 0 replies.
- 启动任务异常, Caused by: java.lang.IndexOutOfBoundsException: Index: 1, Size: 1 - posted by RS <ti...@163.com> on 2020/08/30 06:54:15 UTC, 1 replies.
- Re：求助：实时计算累计UV时，为什么使用MapState和BloomFilter,在checkpoint时的状态大小没有差异 - posted by Yichao Yang <10...@qq.com> on 2020/08/30 08:13:12 UTC, 0 replies.
- flink1.11 流式读取hive怎么设置 process_time 和event_time? - posted by me <me...@lishiyu.cn> on 2020/08/30 13:42:05 UTC, 2 replies.
- Re: flink1.11 流式读取hive怎么设置 process_time 和event_time? - posted by Rui Li <li...@gmail.com> on 2020/08/31 02:29:27 UTC, 0 replies.
- 来自邮件帮助中心的邮件 - posted by 邮件帮助中心 <yi...@163.com> on 2020/08/31 02:53:27 UTC, 0 replies.
- Re: flink1.10.1/1.11.1使用sql 进行group 和时间窗口操作后状态越来越大 - posted by Danny Chan <yu...@gmail.com> on 2020/08/31 03:05:26 UTC, 0 replies.
- 回复: flink1.11 流式读取hive怎么设置 process_time 和event_time? - posted by sl...@aliyun.com.INVALID on 2020/08/31 03:39:45 UTC, 0 replies.
- 回复：flink1.11连接mysql问题 - posted by 13580506953 <13...@163.com> on 2020/08/31 07:06:45 UTC, 1 replies.
- 来自李国鹏的邮件 - posted by 李国鹏 <gp...@163.com> on 2020/08/31 07:55:06 UTC, 2 replies.
- 回复： flink1.11连接mysql问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/08/31 12:48:55 UTC, 0 replies.
- flink-1.11连接hive或filesystem问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2020/08/31 12:53:16 UTC, 0 replies.
- flink-1.11.1 Table API /SQL 无法写入hive orc表 - posted by Jian Wang <wa...@seagroup.com> on 2020/08/31 13:55:01 UTC, 0 replies.