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

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

- Re:Flink检查点失败，原因写着是job failed，但我的job明明好好的。 - posted by 熊云昆 <xi...@163.com> on 2020/12/01 00:44:13 UTC, 2 replies.
- Re: flink sql es写入时，用户名密码认证不支持 - posted by Kyle Zhang <sh...@gmail.com> on 2020/12/01 01:35:19 UTC, 3 replies.
- Re: flink-1.11.2 job启动不起来， - posted by zhisheng <zh...@gmail.com> on 2020/12/01 01:40:11 UTC, 0 replies.
- 退订 - posted by elvis <el...@foxmail.com> on 2020/12/01 01:42:15 UTC, 5 replies.
- Re: 使用 StreamingFileSink后 checkpoint状态中的数据如何hive读取 - posted by admin <17...@163.com> on 2020/12/01 02:59:36 UTC, 0 replies.
- 使用flink-sql解析debezium采集的mysql timestamp字段报错 - posted by 王羽凡 <wa...@gmail.com> on 2020/12/01 03:09:21 UTC, 1 replies.
- Re: flink sql cdc sum 结果出现NULL - posted by Jianzhi Zhang <en...@gmail.com> on 2020/12/01 05:24:23 UTC, 1 replies.
- 分组查询时，select的字段是否一定要都在group by中吗？ - posted by bulterman <15...@163.com> on 2020/12/01 05:40:23 UTC, 3 replies.
- Re: 关于flink cdc sql转出Stream流问题 - posted by jsqf <ya...@gmail.com> on 2020/12/01 05:59:41 UTC, 1 replies.
- 使用sql-client中遇到的一点问题 - posted by 李轲 <m1...@163.com> on 2020/12/01 08:29:05 UTC, 0 replies.
- 错误日志分析 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/01 08:54:10 UTC, 2 replies.
- Flinksql通过phoenix查询维表，报Caused by: org.apache.calcite.avatica.NoSuchStatementException - posted by hoose <xi...@qq.com> on 2020/12/01 09:40:48 UTC, 1 replies.
- 大家有用Flink SQL中的collect函数执行的结果用DataStream后，用什么数据类型匹配该字段的结果，数据类型的类名和需要的依赖是什么？ - posted by chegg_work <ch...@163.com> on 2020/12/01 11:03:15 UTC, 2 replies.
- Re: zookeeper更换leader对flink的影响 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/01 11:12:59 UTC, 4 replies.
- 修改topic名称后从Savepoint重启会怎么消费Kafka - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/12/01 12:59:48 UTC, 2 replies.
- 【Flink SQL】无法启动 env.yaml - posted by 李轲 <m1...@163.com> on 2020/12/01 13:43:08 UTC, 2 replies.
- Flink TableAPI Issue: cannot assign instance of org.apache.flink.shaded.jackson2.com.fasterxml.jackson.databind.util.LRUMap to field - posted by Zed <yu...@163.com> on 2020/12/02 03:44:39 UTC, 3 replies.
- 回复：Flinksql通过phoenix查询维表，报Caused by: org.apache.calcite.avatica.NoSuchStatementException - posted by 黑色 <xi...@qq.com> on 2020/12/02 03:55:29 UTC, 1 replies.
- 回复：修改topic名称后从Savepoint重启会怎么消费Kafka - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/12/02 06:03:01 UTC, 0 replies.
- flink sql 1.11.1 貌似出现bug - posted by zzy <zy...@163.com> on 2020/12/02 06:08:55 UTC, 2 replies.
- flink sql 1.11.1 - posted by zzy <zy...@163.com> on 2020/12/02 06:32:08 UTC, 0 replies.
- Flink CEP 动态加载 pattern - posted by huang botao <bo...@gmail.com> on 2020/12/02 09:48:46 UTC, 2 replies.
- I defined a Kafka dynamic table in SQL-Client, but the kafka theme had some elements in the wrong format, so an exception was thrown in SQL-Client. Can we define the Kafka dynamic table with some additional configuration items to ignore these error records? - posted by "mr.mengyao@ouglook.com" <mr...@outlook.com> on 2020/12/02 09:55:41 UTC, 1 replies.
- 请问为什么关闭calcite的隐式转换 - posted by stgztsw <st...@126.com> on 2020/12/02 10:07:24 UTC, 0 replies.
- 为什么要关闭calcite的隐式转换功能 - posted by tangshiwei <ta...@zhongan.com.INVALID> on 2020/12/02 10:13:03 UTC, 6 replies.
- Re: the remote task manager was lost - posted by 赵一旦 <hi...@gmail.com> on 2020/12/02 10:17:07 UTC, 1 replies.
- Flink SQL共享source 问题 - posted by zz <z_...@foxmail.com> on 2020/12/02 11:22:15 UTC, 2 replies.
- flink-cdc 无法读出binlog，程序也不报错 - posted by chenjb <ch...@163.com> on 2020/12/02 14:15:20 UTC, 5 replies.
- flinksql1.11长时间没有数据写入mysql，会报ava.sql.SQLException: No operations allowed after statement closed. - posted by yanzi <an...@126.com> on 2020/12/03 02:36:28 UTC, 5 replies.
- Flink SQL使用Tumble窗口函数报NoSuchMethodError functions/AggregateFunction 异常 - posted by 18293503878 <18...@163.com> on 2020/12/03 03:02:08 UTC, 2 replies.
- flink sql实时计算分位数如何实现 - posted by 爱成绕指柔 <11...@qq.com> on 2020/12/03 04:06:04 UTC, 1 replies.
- 用代码执行flink sql 报错 Multiple factories for identifier 'jdbc' that implement - posted by xuzh <hu...@qq.com> on 2020/12/03 07:44:18 UTC, 3 replies.
- flink 1.11.2写hive 2.1.1 orc 遇到的问题 - posted by yang xu <31...@qq.com> on 2020/12/03 08:14:49 UTC, 6 replies.
- flink使用多个keytab - posted by zhengmao776 <zh...@qq.com> on 2020/12/03 09:16:38 UTC, 2 replies.
- taskmanager.out配置滚动 - posted by zilong xiao <ac...@gmail.com> on 2020/12/03 11:50:27 UTC, 7 replies.
- Flink1.9设置TTL不生效 - posted by Yang Peng <ya...@gmail.com> on 2020/12/03 12:26:39 UTC, 2 replies.
- Re: flink cdc 如何保证group agg结果正确性 - posted by Jark Wu <im...@gmail.com> on 2020/12/03 12:37:17 UTC, 0 replies.
- Re: 摄像头视频流采集 - posted by Jark Wu <im...@gmail.com> on 2020/12/03 12:37:46 UTC, 0 replies.
- 帮忙推荐下flink是用啥可视化的客户端？ - posted by "yinghua_zh@163.com" <yi...@163.com> on 2020/12/03 12:45:37 UTC, 4 replies.
- Re: flink sql client 报错java.net.NoRouteToHostException: 没有到主机的路由 - posted by Jark Wu <im...@gmail.com> on 2020/12/03 12:47:31 UTC, 1 replies.
- 生产hive sql 迁移flink 11 引擎，碰到的问题 - posted by 莫失莫忘 <xi...@qq.com> on 2020/12/04 03:45:04 UTC, 2 replies.
- sink.rolling-policy.file-size不生效 - posted by admin <17...@163.com> on 2020/12/04 07:43:27 UTC, 0 replies.
- SQL解析复杂JSON问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/12/04 08:39:20 UTC, 3 replies.
- 一个关于实时合并数据的问题 - posted by bradyMk <zh...@126.com> on 2020/12/04 08:42:01 UTC, 0 replies.
- 回复：一个关于实时合并数据的问题 - posted by 吴磊 <wu...@foxmail.com> on 2020/12/04 08:53:10 UTC, 5 replies.
- 动态表 Change Log 格式 - posted by jie mei <me...@gmail.com> on 2020/12/04 09:00:28 UTC, 1 replies.
- Flink-yarn模块加载外部文件的问题 - posted by zhou chao <zh...@hotmail.com> on 2020/12/04 09:45:09 UTC, 1 replies.
- 回复： re:Re: 回复：一个关于实时合并数据的问题 - posted by xuhaiLong <xi...@163.com> on 2020/12/04 11:21:30 UTC, 5 replies.
- 使用DataStream → IterativeStream → DataStream 方式做流关联 - posted by 163 <ya...@163.com> on 2020/12/04 11:53:12 UTC, 1 replies.
- Flink1.11.2写hive提示UnknownHostException - posted by smallwong <sm...@163.com> on 2020/12/05 02:30:20 UTC, 1 replies.
- flinksql维表join - posted by leiyanrui <11...@qq.com> on 2020/12/05 07:11:26 UTC, 1 replies.
- flink使用RocksDB增量checkpoints，程序运行一段时间报出：超出物理内存 - posted by bradyMk <zh...@126.com> on 2020/12/05 09:29:11 UTC, 0 replies.
- 请教一些问题 - posted by 沈保源 <75...@qq.com> on 2020/12/05 14:19:14 UTC, 0 replies.
- 使用RedisSink无法将读取的Kafka数据写入Redis中 - posted by 追梦的废柴 <zh...@163.com> on 2020/12/06 12:35:15 UTC, 3 replies.
- 答复: flink使用RocksDB增量checkpoints，程序运行一段时间报出：超出物理内存 - posted by 范超 <fa...@mgtv.com> on 2020/12/07 01:04:28 UTC, 6 replies.
- 使用stop命令停止yarn队列任务携带Kerberos认证信息 - posted by "amenhub@163.com" <am...@163.com> on 2020/12/07 03:34:26 UTC, 1 replies.
- 回复：回复： re:Re: 回复：一个关于实时合并数据的问题 - posted by xuhaiLong <xi...@163.com> on 2020/12/07 03:51:07 UTC, 0 replies.
- FlinkSQL如何定义JsonObject数据的字段类型 - posted by xiao cai <fl...@163.com> on 2020/12/07 04:52:29 UTC, 18 replies.
- 关于 stream-stream Interval Join 的问题 - posted by macia kk <pr...@gmail.com> on 2020/12/07 06:10:02 UTC, 16 replies.
- flink sql 超时输出要怎么定义 1.10.1的sql可以支持吗 - posted by 沈保源 <75...@qq.com> on 2020/12/07 06:30:23 UTC, 0 replies.
- 回复：生产hive sql 迁移flink 11 引擎，碰到的问题 - posted by 莫失莫忘 <xi...@qq.com> on 2020/12/07 07:38:31 UTC, 2 replies.
- flink sql实时计算UpsertStreamTableSink requires that Table has a full primary keys if it is updated - posted by 爱成绕指柔 <11...@qq.com> on 2020/12/07 08:41:02 UTC, 6 replies.
- flink 使用关系型数据库的默认事务是否可以做到端对端的精确一次，还是需要实现2p2提交 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/12/07 08:46:54 UTC, 3 replies.
- flink sql实时计算UpsertStreamTableSink - posted by 爱成绕指柔 <11...@qq.com> on 2020/12/07 09:04:16 UTC, 1 replies.
- flink sql 任务滑动窗口失效 - posted by xushanshan <13...@qq.com> on 2020/12/07 09:31:42 UTC, 2 replies.
- Flink 1.11版本LeaseRenewer线程不释放 - posted by zilong xiao <ac...@gmail.com> on 2020/12/07 10:11:15 UTC, 5 replies.
- 回复: Re: flink 使用关系型数据库的默认事务是否可以做到端对端的精确一次，还是需要实现2p2提交 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/12/07 10:40:11 UTC, 0 replies.
- 回复：flink使用RocksDB增量checkpoints，程序运行一段时间报出：超出物理内存 - posted by 熊云昆 <xi...@163.com> on 2020/12/07 11:51:55 UTC, 5 replies.
- 关于dataStream 转成kafka流表新建的表是否可以保存到已存在的catalog里面 - posted by 夜思流年梦 <li...@163.com> on 2020/12/07 13:22:36 UTC, 0 replies.
- Flink 1.11.2运行一段时间后，会报ResourceManager leader changed to new address null的异常 - posted by 史正超 <sh...@outlook.com> on 2020/12/07 14:13:17 UTC, 0 replies.
- 回复: 回复: flink 使用关系型数据库的默认事务是否可以做到端对端的精确一次，还是需要实现2p2提交 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/12/08 01:14:23 UTC, 0 replies.
- ScanTableSource 为什么不支持SupportsFilterPushDown的问题 - posted by jy l <lj...@gmail.com> on 2020/12/08 03:42:08 UTC, 1 replies.
- Re: 回复: flink 使用关系型数据库的默认事务是否可以做到端对端的精确一次，还是需要实现2p2提交 - posted by Jark Wu <im...@gmail.com> on 2020/12/08 05:43:54 UTC, 0 replies.
- [flink-1.10.2] 异步IO结果DataStream 该如何注册为table？？ - posted by Tianwang Li <li...@gmail.com> on 2020/12/08 06:51:21 UTC, 1 replies.
- FlinkSQL中创建表，视图等一些元数据信息都是存放在什么地方（没看到像Hive那样使用mysql存储元数据信息） - posted by 邮件帮助中心 <yi...@163.com> on 2020/12/08 07:23:08 UTC, 2 replies.
- 关于检查点对任务性能的影响 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/08 07:32:58 UTC, 0 replies.
- 怎样定时更新广播变量的值 - posted by Lei Wang <le...@gmail.com> on 2020/12/08 09:36:30 UTC, 0 replies.
- 求助如何用flink1.11.2 on yarn集成CDH的hbase2.0版本 - posted by site <si...@163.com> on 2020/12/08 09:39:51 UTC, 1 replies.
- flink sql ddl本地执行报错java.lang.IncompatibleClassChangeError: Implementing class - posted by bigdata <11...@qq.com> on 2020/12/08 09:48:07 UTC, 1 replies.
- flink11 SQL 如何支持双引号字符串 - posted by 莫失莫忘 <xi...@qq.com> on 2020/12/08 10:42:08 UTC, 0 replies.
- 关于flink sql往postgres写数据遇到的timestamp问题 - posted by 李轲 <m1...@163.com> on 2020/12/08 11:24:43 UTC, 3 replies.
- 在map算子中对redis进行sadd写入之后再sget读取 - posted by 追梦的废柴 <zh...@163.com> on 2020/12/08 12:44:15 UTC, 1 replies.
- 回复：怎样定时更新广播变量的值 - posted by 熊云昆 <xi...@163.com> on 2020/12/08 23:17:05 UTC, 0 replies.
- Flink 1.11.2 on yarn报错 - posted by Jacob <17...@163.com> on 2020/12/09 02:12:47 UTC, 1 replies.
- Re: flink11 SQL 如何支持双引号字符串 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/09 02:17:10 UTC, 2 replies.
- Re: Flink1.10执行sql超出内存限制被yarn杀掉 - posted by kuailuohe <he...@163.com> on 2020/12/09 02:55:52 UTC, 0 replies.
- flink sql 1.11 kafka cdc与holo sink - posted by 于洋 <10...@qq.com> on 2020/12/09 03:32:17 UTC, 1 replies.
- 关于flink cdc的N流join状态后端的选择问题： ‎FsStateBackend和‎RocksDBStateBackend - posted by jindy_liu <28...@qq.com> on 2020/12/09 04:19:39 UTC, 8 replies.
- Flink SQL读取复杂JSON格式 - posted by 破极 <za...@163.com> on 2020/12/09 05:18:56 UTC, 5 replies.
- flink现在的planner用blink的话是不是可以支持cep sql的a->b - posted by 沈保源 <75...@qq.com> on 2020/12/09 05:35:38 UTC, 0 replies.
- flink sql 实时计算百分比CodeGenException: Unsupported cast from 'ROW' to 'ROW'. - posted by bigdata <11...@qq.com> on 2020/12/09 05:50:08 UTC, 2 replies.
- Flink HA目录下数据不完整，导致JobManager启动失败。 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/09 07:03:49 UTC, 2 replies.
- flink 1.11.2 on yarn 可用slot始终为0，job无法提交 - posted by Jacob <17...@163.com> on 2020/12/09 07:41:58 UTC, 2 replies.
- A group window expects a time attribute for grouping in a stream environment谢谢 - posted by Appleyuchi <ap...@163.com> on 2020/12/09 07:43:44 UTC, 8 replies.
- 使用flink sql cli读取postgres-cdc时，Could not find any factory for identifier 'postgres-cdc' that implements 'org.apache.flink.table.factories.DynamicTableSinkFactory' in the classpath. - posted by 王敏超 <mi...@163.com> on 2020/12/09 08:49:00 UTC, 2 replies.
- flink1.12 docker 镜像啥时候有 - posted by jiangjiguang719 <ji...@163.com> on 2020/12/09 09:09:43 UTC, 3 replies.
- flink jdbc connector 在checkpoint的时候如何确保buffer中的数据全都sink到数据库 - posted by jie mei <me...@gmail.com> on 2020/12/09 10:13:14 UTC, 5 replies.
- flink 1.12如何使用RateLimiter - posted by 18757141558 <18...@163.com> on 2020/12/09 10:48:23 UTC, 1 replies.
- create table语句从kafka中读取数据时，创建的表的数据保存多久？ - posted by 邮件帮助中心 <yi...@163.com> on 2020/12/09 12:24:17 UTC, 1 replies.
- Re:flink 1.9.2 容器ha部署是jobid 一直是00000000000000000000000000000000 - posted by Jeff <zi...@126.com> on 2020/12/10 01:31:33 UTC, 1 replies.
- Flink 1.11.2 on yarn 提交job失败 - posted by Jacob <17...@163.com> on 2020/12/10 01:45:21 UTC, 1 replies.
- 回复：flink 1.9.2 容器ha部署是jobid 一直是00000000000000000000000000000000 - posted by Jun Zhang <82...@qq.com> on 2020/12/10 02:00:20 UTC, 0 replies.
- flink+ druid - posted by 水静于止 <37...@qq.com> on 2020/12/10 02:57:08 UTC, 0 replies.
- interval join 时checkpoint失败 - posted by song wang <sd...@gmail.com> on 2020/12/10 02:58:18 UTC, 3 replies.
- 测试下如何发问题 - posted by 水静于止 <37...@qq.com> on 2020/12/10 03:09:15 UTC, 0 replies.
- or using the Connector/J connection property 'autoReconnect=true' to avoid this problem. - posted by 水静于止 <37...@qq.com> on 2020/12/10 03:17:45 UTC, 0 replies.
- retract stream UDAF使用问题 - posted by bulterman <15...@163.com> on 2020/12/10 03:18:40 UTC, 5 replies.
- 关于Task之间数据rebalance是否可能根据反压情况调整数据流 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/10 05:35:23 UTC, 0 replies.
- Flink 1.11.2 on yarn 提交job失败(附完整日志) - posted by Jacob <17...@163.com> on 2020/12/10 06:30:27 UTC, 1 replies.
- Unknown call expression: avg(amount)－官方文档示例补全后报错(含:完整代码＋异常栈＋文档出处)，谢谢 - posted by Appleyuchi <ap...@163.com> on 2020/12/10 09:09:19 UTC, 0 replies.
- flink 1.11.2及1.12.0写读hive表无法读取数据问题 - posted by ﹏〆﹎゛独家记忆 <60...@qq.com> on 2020/12/10 09:21:56 UTC, 0 replies.
- 答复: flink 1.12如何使用RateLimiter - posted by zhao liang <zh...@gmail.com> on 2020/12/10 09:23:46 UTC, 1 replies.
- flink-1.11.2 rocksdb when trigger savepoint job fail and restart - posted by smailxie <sm...@163.com> on 2020/12/10 09:42:54 UTC, 1 replies.
- 订阅flink中文邮件 - posted by China_fei <cf...@gmail.com> on 2020/12/10 13:18:27 UTC, 1 replies.
- flink-shaded-hadoop-2-uber版本如何选择 - posted by 赢峰 <si...@163.com> on 2020/12/11 00:45:07 UTC, 6 replies.
- computed column转为timestamp类型后进行窗口聚合报错 - posted by jun su <su...@gmail.com> on 2020/12/11 02:46:53 UTC, 4 replies.
- flink sql 消费kafka，断开连接 - posted by smailxie <sm...@163.com> on 2020/12/11 02:52:56 UTC, 0 replies.
- flink无法写入数据到ES中 - posted by 小墨鱼 <ba...@163.com> on 2020/12/11 06:46:48 UTC, 1 replies.
- Flink SQL 1.11支持将数据写入到Hive吗？ - posted by "yinghua_zh@163.com" <yi...@163.com> on 2020/12/11 07:44:41 UTC, 3 replies.
- Re: 使用flinksql提供的内置函数LAST_VALUE 发现存的state越来越大 - posted by guoliang_wang1335 <gu...@163.com> on 2020/12/11 08:06:50 UTC, 2 replies.
- 关于flink-sql 元数据问题 - posted by 夜思流年梦 <li...@163.com> on 2020/12/11 09:26:23 UTC, 4 replies.
- 回复：Flink SQL 1.11支持将数据写入到Hive吗？ - posted by ﹏〆﹎゛独家记忆 <60...@qq.com> on 2020/12/11 09:31:12 UTC, 0 replies.
- 创建的临时表，在新的catalog中找不到对应的临时表 - posted by jy l <lj...@gmail.com> on 2020/12/11 09:49:55 UTC, 0 replies.
- Unknown call expression: avg(amount) - posted by Appleyuchi <ap...@163.com> on 2020/12/11 11:41:00 UTC, 0 replies.
- Flink 1.10.0 on yarn 提交job失败 - posted by Jacob <17...@163.com> on 2020/12/12 02:56:47 UTC, 0 replies.
- flink-shaded-hadoop-2-uber*-* 版本确定问题 - posted by Jacob <17...@163.com> on 2020/12/12 08:33:20 UTC, 3 replies.
- tEnv.executeSql(query).print() 这样不能成功消费kafka的数据 - posted by jy l <lj...@gmail.com> on 2020/12/12 09:54:15 UTC, 0 replies.
- Over window的watermark没有触发计算(附完整代码)，谢谢 - posted by Appleyuchi <ap...@163.com> on 2020/12/12 09:54:45 UTC, 0 replies.
- Pandas UDF处理过的数据sink问题 - posted by Lucas <gu...@foxmail.com> on 2020/12/13 05:13:47 UTC, 4 replies.
- Tumble Window某个时间区间没数据的问题 - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/13 05:43:18 UTC, 0 replies.
- Flink SQL 怎么为每一个任务分配不同的内存配置 - posted by "yinghua_zh@163.com" <yi...@163.com> on 2020/12/14 00:41:33 UTC, 2 replies.
- Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered. - posted by "kandy.wang" <ka...@163.com> on 2020/12/14 02:28:10 UTC, 0 replies.
- 回复: Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered. - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/14 02:41:12 UTC, 2 replies.
- 回复: Re: Pandas UDF处理过的数据sink问题 - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/14 02:59:38 UTC, 0 replies.
- 回复: Re: Window aggregate can only be defined over a time attribute column, but TIMESTAMP(3) encountered. - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/14 05:02:54 UTC, 1 replies.
- kafka的多分区watermark - posted by 张锴 <zk...@gmail.com> on 2020/12/14 05:51:06 UTC, 1 replies.
- 回复：kafka的多分区watermark - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/12/14 06:07:51 UTC, 0 replies.
- Re: flink-cdc-connector 使用场景和限制是什么？ - posted by Chesnay Schepler <ch...@apache.org> on 2020/12/14 09:33:31 UTC, 0 replies.
- Flink-SQL数据倾斜处理 - posted by yanggang_it_job <ya...@163.com> on 2020/12/14 09:36:52 UTC, 0 replies.
- Flink1.11.1版本Application Mode job on K8S集群，too old resource version问题 - posted by lichunguang <lc...@163.com> on 2020/12/14 09:47:58 UTC, 4 replies.
- Application Mode job on K8S集群，无法缩容问题 - posted by lichunguang <lc...@163.com> on 2020/12/14 10:23:28 UTC, 6 replies.
- 回复：Pandas UDF处理过的数据sink问题 - posted by 郭刘斌 <gu...@foxmail.com> on 2020/12/14 11:52:21 UTC, 0 replies.
- pyflink udf依赖引用问题 - posted by magichuang <ma...@88.com> on 2020/12/14 12:04:50 UTC, 1 replies.
- Can't load kafka-0.10 DynamicTableSourceFactory - posted by "meijie.work" <me...@gmail.com> on 2020/12/14 12:41:06 UTC, 1 replies.
- 如何让FlinkSQL访问到阿里云MaxCompute上的表？ - posted by 陈帅 <ca...@126.com> on 2020/12/14 15:33:34 UTC, 0 replies.
- 回复: 如何让FlinkSQL访问到阿里云MaxCompute上的表？ - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/14 16:34:03 UTC, 1 replies.
- temporal table join SQL报错 - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/14 17:24:49 UTC, 0 replies.
- java.lang.ClassNotFoundException: com.mysql.jdbc.Driver - posted by 水静于止 <37...@qq.com> on 2020/12/15 01:09:56 UTC, 3 replies.
- pyflink是否可调试 - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/15 01:25:11 UTC, 4 replies.
- 两条流去重后再关联出现不符合预期数据 - posted by "hdxg1101300123@163.com" <hd...@163.com> on 2020/12/15 02:35:32 UTC, 0 replies.
- pyflink udf 依赖问题 - posted by magichuang <ma...@88.com> on 2020/12/15 04:30:26 UTC, 1 replies.
- 怎么配置log4j2 properties 文件中的Kafka Appender - posted by Fanshu <bj...@gmail.com> on 2020/12/15 06:00:41 UTC, 0 replies.
- pyflink 引用第三库的文件出现安装权限的问题 - posted by magichuang <ma...@88.com> on 2020/12/15 06:15:04 UTC, 4 replies.
- Flink 1.12.0 写ORC文件，自定义文件名 - posted by Jacob <17...@163.com> on 2020/12/15 06:35:48 UTC, 0 replies.
- zeppelin+flink1.12问题 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/15 08:36:47 UTC, 1 replies.
- flink1.9.1单任务配置rocksDB不生效 - posted by bradyMk <zh...@126.com> on 2020/12/15 09:05:25 UTC, 2 replies.
- pyflink 定义udf 运行报错 - posted by Leopard <fe...@163.com> on 2020/12/15 10:27:59 UTC, 1 replies.
- flink 1.12提交用户任务方法问题 - posted by 陈帅 <ca...@126.com> on 2020/12/15 12:19:27 UTC, 1 replies.
- Flink sql 列裁剪原理请教 - posted by SmileSmile <a5...@163.com> on 2020/12/15 13:57:32 UTC, 1 replies.
- FlinkSQL多个select group by统计union后输出，或多个select union后在group by统计的区别，以及问题。 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/15 14:48:06 UTC, 5 replies.
- 回复：Flink sql 列裁剪原理请教 - posted by SmileSmile <a5...@163.com> on 2020/12/15 14:50:37 UTC, 0 replies.
- 转发: 两条流去重后再关联出现不符合预期数据 - posted by hdxg1101300123 <hd...@163.com> on 2020/12/15 15:44:51 UTC, 1 replies.
- temparol table join后无法sink - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/15 23:36:44 UTC, 0 replies.
- 邮件退订 - posted by 谢治平 <xi...@163.com> on 2020/12/16 01:08:26 UTC, 2 replies.
- 回复: 邮件退订 - posted by Evan <ch...@foxmail.com> on 2020/12/16 01:14:22 UTC, 0 replies.
- 回复: temparol table join后无法sink - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/16 01:57:26 UTC, 0 replies.
- 加锁两次 - posted by xiaobao li <li...@gmail.com> on 2020/12/16 02:13:04 UTC, 0 replies.
- flink sql数据处理时延的测试方法？ - posted by jindy_liu <28...@qq.com> on 2020/12/16 02:33:34 UTC, 0 replies.
- Re: Flink 1.10.0 on yarn 提交job失败 - posted by Xintong Song <to...@gmail.com> on 2020/12/16 02:39:37 UTC, 0 replies.
- flink1.11 datastream elasticsearch sink 写入es需要账号密码验证，目前支持这种操作吗？ - posted by 李世钰 <me...@lishiyu.cn> on 2020/12/16 03:34:07 UTC, 0 replies.
- flink sql 1.12 写数据到elasticsearch,部署问题 - posted by "cljbest@163.com" <cl...@163.com> on 2020/12/16 03:34:09 UTC, 1 replies.
- Re: flink1.11 datastream elasticsearch sink 写入es需要账号密码验证，目前支持这种操作吗？ - posted by Yangze Guo <ka...@gmail.com> on 2020/12/16 03:58:15 UTC, 0 replies.
- flink1.9.1 如何配置RocksDB的block-cache-usage参数 - posted by bradyMk <zh...@126.com> on 2020/12/16 04:03:30 UTC, 4 replies.
- UDF函数类型匹配问题 - posted by chen310 <22...@163.com> on 2020/12/16 06:56:52 UTC, 0 replies.
- flink 1.11 版本sql client 不支持checkpoint - posted by lingchanhu <li...@163.com> on 2020/12/16 07:47:23 UTC, 0 replies.
- Flink 新版本的WEB UI taskmanager没有logs - posted by Jacob <17...@163.com> on 2020/12/16 07:54:31 UTC, 4 replies.
- env.getCheckpointConfig().enableUnalignedCheckpoints(); - posted by 何宗谨 <he...@qq.com> on 2020/12/16 08:32:42 UTC, 0 replies.
- Scala REPL YARN 运行模式报 NoSuchMethodError - posted by 卢国庆 <15...@126.com> on 2020/12/16 09:50:03 UTC, 3 replies.
- 回复：flink-shaded-hadoop-2-uber版本如何选择 - posted by superainbower <su...@163.com> on 2020/12/16 10:19:39 UTC, 1 replies.
- 直接内存溢出 - posted by 巫旭阳 <da...@163.com> on 2020/12/16 11:06:48 UTC, 3 replies.
- Flink SQL中with子句中的配置最终是传给了外部数据源对应的配置中，如果有些配置不能出现在SQL的wtih子句中而要设置一些额外的配置参数（SQL级别不是全局级别的配置参数）给外部数据源的配置中，可以怎么传递？ - posted by 邮件帮助中心 <yi...@163.com> on 2020/12/16 12:51:16 UTC, 0 replies.
- 求教：pyflink的sink是否支持redis connector? - posted by 消息室 <he...@qq.com> on 2020/12/16 13:12:43 UTC, 6 replies.
- 回复：flink1.12 docker 镜像啥时候有 - posted by superainbower <su...@163.com> on 2020/12/16 23:19:12 UTC, 1 replies.
- Pyflink1.12尝试连接oracle数据，报错findAndCreateTableSource failed - posted by 肖越 <18...@163.com> on 2020/12/17 01:47:52 UTC, 7 replies.
- Pyflink1.12尝试连接oracle数据，报错findAndCreateTableSource failed - posted by hhywcl <hh...@163.com> on 2020/12/17 01:54:18 UTC, 0 replies.
- flink 1.12 RocksDBStateBackend 报错 - posted by HunterXHunter <13...@qq.com> on 2020/12/17 02:30:57 UTC, 4 replies.
- flink1.12.0中使用LISTAGG报错 - posted by huang huang <le...@gmail.com> on 2020/12/17 04:47:53 UTC, 1 replies.
- window agg early-fire 不生效 - posted by "kandy.wang" <ka...@163.com> on 2020/12/17 06:06:02 UTC, 0 replies.
- 如何通过现实时间控制事件时间的窗口 - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/17 06:15:37 UTC, 3 replies.
- pyflink 有没有方便的print方式？例如java api中的 .print() ? - posted by 肖越 <18...@163.com> on 2020/12/17 06:47:37 UTC, 2 replies.
- Re: 使用sql时候，设置了idle过期时间，但是状态还是一直变大 - posted by Storm☀️ <st...@163.com> on 2020/12/17 08:01:23 UTC, 0 replies.
- 曹三启 added you to the flink group - posted by 曹三启 <hu...@outlook.com> on 2020/12/17 08:57:55 UTC, 0 replies.
- flink-sql如何-细粒度管理state - posted by 三色堇 <25...@qq.com> on 2020/12/17 09:25:04 UTC, 0 replies.
- Flink1.12.0/flink1.11.0版本出现FLINK-19677的问题 - posted by 李延延 <li...@163.com> on 2020/12/17 10:26:05 UTC, 0 replies.
- 回复： flink1.12 docker 镜像啥时候有 - posted by superainbower <su...@163.com> on 2020/12/17 10:36:46 UTC, 1 replies.
- flink clickhouse connector - posted by magichuang <ma...@88.com> on 2020/12/17 10:41:31 UTC, 4 replies.
- flink-1.11.1 checkpoint超时，任务会不断重启 - posted by nicygan <re...@163.com> on 2020/12/17 12:15:58 UTC, 0 replies.
- Flink sql 自定义udaf函数出现 No match found for function signature count_uadf() - posted by 丁浩浩 <18...@163.com> on 2020/12/17 13:00:30 UTC, 1 replies.
- task manager内存使用问题 - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/18 01:22:20 UTC, 1 replies.
- 回复: task manager内存使用问题 - posted by "yinghua_zh@163.com" <yi...@163.com> on 2020/12/18 01:49:22 UTC, 0 replies.
- 取消订阅中文资讯邮件列表失败 - posted by 肖越 <18...@163.com> on 2020/12/18 02:47:13 UTC, 0 replies.
- Re: Re:Re: flink sql作业state size一直增加 - posted by Storm☀️ <st...@163.com> on 2020/12/18 03:16:58 UTC, 1 replies.
- Flink eventTIme问题 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/12/18 03:32:38 UTC, 1 replies.
- Re: flink1.10.1/1.11.1 使用sql 进行group 和时间窗口操作后状态越来越大 - posted by Storm☀️ <st...@163.com> on 2020/12/18 03:50:18 UTC, 6 replies.
- Flink 1.11.2 读写Hive以及对hive的版本支持 - posted by Jacob <17...@163.com> on 2020/12/18 06:00:56 UTC, 1 replies.
- jdbc sink无法插入数据 - posted by "guoliubin85@foxmail.com" <gu...@foxmail.com> on 2020/12/18 06:01:04 UTC, 4 replies.
- Re: Blink Planner构造Remote Env - posted by 莫失莫忘 <56...@qq.com> on 2020/12/18 06:22:37 UTC, 0 replies.
- StreamTableEnvironmentImpl 为什么不支持批 - posted by 莫失莫忘 <xi...@qq.com> on 2020/12/18 06:45:56 UTC, 0 replies.
- flink 1.11 interval join场景下rocksdb内存超用问题 - posted by 867127831 <86...@qq.com> on 2020/12/18 07:15:06 UTC, 1 replies.
- 请教一下flink1.12可以指定时间清除state吗？ - posted by 三色堇 <25...@qq.com> on 2020/12/18 07:19:29 UTC, 3 replies.
- org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Failed to send data to Kafka: Topic not present in metadata after 60000 ms. - posted by Level1accelerator <97...@qq.com> on 2020/12/18 07:53:06 UTC, 0 replies.
- flink1.9.1 支持一个 source 指定消费多个 topics么？ - posted by bradyMk <zh...@126.com> on 2020/12/18 07:53:34 UTC, 2 replies.
- flink1.11.2检查点失败 - posted by zhy <zh...@akulaku.com> on 2020/12/18 07:57:40 UTC, 3 replies.
- Flink-SQL-Client 啥时候支持GateWay Mode - posted by 夜思流年梦 <li...@163.com> on 2020/12/18 08:07:41 UTC, 0 replies.
- Flink 1.12 job on yarn 集成hive时如何配置 hiveConf - posted by Jacob <17...@163.com> on 2020/12/18 08:12:55 UTC, 1 replies.
- Native Kubernetes 需要访问HDFS - posted by liujian <13...@qq.com> on 2020/12/18 09:26:10 UTC, 3 replies.
- [ANNOUNCE] Apache Flink 1.11.3 released - posted by Xintong Song <xt...@apache.org> on 2020/12/18 11:20:32 UTC, 2 replies.
- Flink 连接Hive hiveConf路径配置 - posted by Jacob <17...@163.com> on 2020/12/19 01:26:08 UTC, 2 replies.
- 请教个Flink sql问题 - posted by 占英华 <yi...@163.com> on 2020/12/19 01:30:23 UTC, 5 replies.
- Table api 中指定rowtime的问题 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/12/19 04:14:53 UTC, 1 replies.
- 对于kafka partition 设置时间戳及watermark - posted by 张锴 <zk...@gmail.com> on 2020/12/19 09:45:25 UTC, 3 replies.
- 回复： flink-shaded-hadoop-2-uber版本如何选择 - posted by liujian <13...@qq.com> on 2020/12/19 12:29:15 UTC, 4 replies.
- yarn application模式提交任务失败 - posted by 陈帅 <ca...@126.com> on 2020/12/20 02:44:30 UTC, 3 replies.
- flink sql如何处理脏数据？ - posted by 陈帅 <ca...@126.com> on 2020/12/20 02:48:04 UTC, 2 replies.
- 回复：flink sql如何处理脏数据？ - posted by ℡小新的蜡笔不见嘞、 <15...@qq.com> on 2020/12/20 03:03:37 UTC, 0 replies.
- 回复：请教一下flink1.12可以指定时间清除state吗？ - posted by 三色堇 <25...@qq.com> on 2020/12/21 00:44:49 UTC, 0 replies.
- Flink-1.12支持kafka join jdbc维表吗 - posted by "amenhub@163.com" <am...@163.com> on 2020/12/21 05:33:05 UTC, 2 replies.
- pyflink1.12 连接Mysql报错： Missing required options - posted by 肖越 <18...@163.com> on 2020/12/21 05:44:53 UTC, 1 replies.
- flink1.10.0中的filter下推还能在flink1.12.0中使用吗？ - posted by jy l <lj...@gmail.com> on 2020/12/21 06:10:35 UTC, 0 replies.
- Re: flink DataStream scala api can not overloaded method aggregate - posted by hiaQ <11...@qq.com> on 2020/12/21 06:52:05 UTC, 0 replies.
- 回复: Re: Flink-1.12支持kafka join jdbc维表吗 - posted by "amenhub@163.com" <am...@163.com> on 2020/12/21 06:52:18 UTC, 1 replies.
- Re: 执行mvn构建错误编译flink1.9遇到了相同的问题请问解决了吗？我编译最新代码没这个问题 - posted by shaoshuai <76...@qq.com> on 2020/12/21 08:41:38 UTC, 1 replies.
- Flink on yarn 如何指定固定几台yarn节点当做flink任务的运行节点 - posted by yujianbo <15...@163.com> on 2020/12/21 08:43:35 UTC, 2 replies.
- Job结束blob目录及文件没有删除 - posted by Luna Wong <gf...@gmail.com> on 2020/12/21 08:50:52 UTC, 0 replies.
- flink1.11.2写hive分区表，hive识别不到分区 - posted by kingdomad <ki...@163.com> on 2020/12/21 08:55:01 UTC, 6 replies.
- 请教一个flink消费多kafka topic如何进行数据分配的问题 - posted by bradyMk <zh...@126.com> on 2020/12/21 09:40:03 UTC, 0 replies.
- 答复: Flink on yarn 如何指定固定几台yarn节点当做flink任务的运行节点 - posted by af...@163.com on 2020/12/21 09:48:46 UTC, 0 replies.
- 回复：请教一个flink消费多kafka topic如何进行数据分配的问题 - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2020/12/21 11:27:49 UTC, 0 replies.
- SQL执行模式 - posted by jiangjiguang719 <ji...@163.com> on 2020/12/21 11:44:33 UTC, 1 replies.
- Re: Flink on yarn 如何指定固定几台yarn节点当做flink任务的运行节点 - posted by r pp <pr...@gmail.com> on 2020/12/21 13:25:42 UTC, 3 replies.
- 请教关于KeyedState的恢复机制 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/21 16:03:34 UTC, 2 replies.
- pyflink1.12 进行多表关联后的结果类型是TableResult，如何转为Table类型 - posted by 肖越 <18...@163.com> on 2020/12/22 05:25:35 UTC, 1 replies.
- java.lang.IllegalStateException: Trying to access closed classloader. - posted by jy l <lj...@gmail.com> on 2020/12/22 05:25:38 UTC, 0 replies.
- flink1.10 广播流更新卡住 - posted by 洪雪芬 <ho...@126.com> on 2020/12/22 05:38:23 UTC, 4 replies.
- flink 1.11.2 创建hive表的问题 - posted by 曹武 <14...@163.com> on 2020/12/22 05:47:32 UTC, 2 replies.
- yarn.provided.lib.dirs在flink1.11 yarn提交不生效 - posted by datayangl <da...@gmail.com> on 2020/12/22 08:56:29 UTC, 3 replies.
- pyflink 1.12 是不支持通过sql 直接向数据库获取数据的操作么？没看到相关接口 - posted by 肖越 <18...@163.com> on 2020/12/22 09:40:30 UTC, 2 replies.
- Flink1.10.1代码自定义rocksdb backend webui中还是yaml显示默认的配置 - posted by Storm☀️ <st...@163.com> on 2020/12/22 09:48:58 UTC, 0 replies.
- Flink 操作hive 一些疑问 - posted by Jacob <17...@163.com> on 2020/12/22 09:51:45 UTC, 4 replies.
- TableEnvironment中怎么添加参数，使参数能在TaskManagerServices中能获取到？ - posted by jy l <lj...@gmail.com> on 2020/12/22 09:54:05 UTC, 0 replies.
- Re: 执行mvn构建错误 - posted by Storm☀️ <st...@163.com> on 2020/12/22 10:00:48 UTC, 0 replies.
- 回复： flink 1.11 interval join场景下rocksdb内存超用问题 - posted by 867127831 <86...@qq.com> on 2020/12/22 11:00:12 UTC, 0 replies.
- 回复：Re:Re: flink1.11.2写hive分区表，hive识别不到分区 - posted by 范瑞 <83...@qq.com> on 2020/12/23 01:22:48 UTC, 1 replies.
- flink1.11 streaming和table&sql混合使用提交到yarn会启动两个applicaion - posted by kingdomad <ki...@163.com> on 2020/12/23 03:46:56 UTC, 1 replies.
- 回复: Re: taskmanager.out配置滚动 - posted by hdxg1101300123 <hd...@163.com> on 2020/12/23 05:50:48 UTC, 0 replies.
- 算子并行度设置 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/23 06:25:06 UTC, 0 replies.
- Flink catalog+hive问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/12/23 07:53:48 UTC, 8 replies.
- flink sql cdc流（1.11.2），双流join长时间运行后，试着取消job后，再从从checkpoint处恢复运行，报outofmemorry, tm的参数配置也没有变过，rocksdb后端。这个可能原因是啥？运行的时候没报，为啥恢复的时间报了？ - posted by jindy_liu <28...@qq.com> on 2020/12/23 08:54:42 UTC, 0 replies.
- dml执行报错Error during disposal of stream operator. java.lang.NullPointerException - posted by bigdata <11...@qq.com> on 2020/12/23 09:03:22 UTC, 1 replies.
- pyflink query 语句执行获取数据速度很慢，where子句不过滤数据么？ - posted by 肖越 <18...@163.com> on 2020/12/23 09:31:17 UTC, 2 replies.
- flink1.10.1在idea执行dml时候报错Error during disposal of stream operator. java.lang.NullPointerException - posted by bigdata <11...@qq.com> on 2020/12/23 11:46:14 UTC, 0 replies.
- flink on yarn启动失败 - posted by magichuang <ma...@88.com> on 2020/12/23 12:28:44 UTC, 2 replies.
- proctime in yaml ,sql-cli start throws exception - posted by "su_jun@cjspd.com" <su...@cjspd.com> on 2020/12/24 03:44:54 UTC, 0 replies.
- flink.client.program.ProgramInvocationException: The main method caused an error: Unable to instantiate java compiler - posted by bigdata <11...@qq.com> on 2020/12/24 05:00:12 UTC, 1 replies.
- pyflink1.12 使用connector read.query参数报错 - posted by 肖越 <18...@163.com> on 2020/12/24 06:02:57 UTC, 4 replies.
- Flink-1.11.1流写filesystem分区提交问题 - posted by "amenhub@163.com" <am...@163.com> on 2020/12/24 09:04:29 UTC, 5 replies.
- DynamicTableSource中Filter push down - posted by automths <au...@163.com> on 2020/12/24 09:39:42 UTC, 0 replies.
- DynamicTableSource中Filter push down - posted by jy l <lj...@gmail.com> on 2020/12/24 09:49:09 UTC, 0 replies.
- flink-1.11.1 setMinPauseBetweenCheckpoints不生效 - posted by nicygan <re...@163.com> on 2020/12/24 11:24:42 UTC, 3 replies.
- flink应用起来后flink.streaming.runtime.tasks.StreamTaskException: Cannot instantiate user function. - posted by bigdata <11...@qq.com> on 2020/12/24 13:48:48 UTC, 1 replies.
- Flink读取kafka没有报错也没有数据输出，Kafka消费端有数据，谢谢 - posted by Appleyuchi <ap...@163.com> on 2020/12/25 04:11:38 UTC, 2 replies.
- Flink TaskManager失败的日志关键词 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/25 05:43:51 UTC, 2 replies.
- flink1.10.1分析程序启动后org.apache.flink.client.program.ProgramInvocationException: The main method caused an error: java.util.concurrent.TimeoutException - posted by bigdata <11...@qq.com> on 2020/12/25 07:36:29 UTC, 0 replies.
- checkpoint持久化问题 - posted by chen310 <22...@163.com> on 2020/12/25 08:01:46 UTC, 2 replies.
- Can flink kafka producer dynamically discover new parititons after expansion？ - posted by ぐ绿み翼う <35...@qq.com> on 2020/12/25 10:04:17 UTC, 1 replies.
- 关于iterative Job的检查点问题 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/25 10:34:43 UTC, 0 replies.
- 求问为什么KafkaDynamicSource 在批模式下不能运行 - posted by wxpcc <wx...@outlook.com> on 2020/12/25 11:10:03 UTC, 1 replies.
- 请教flink的处理性能，关于cpu的 - posted by x2009438 <x2...@126.com> on 2020/12/25 14:36:47 UTC, 0 replies.
- flink12同时使用flink-connector-kafka和flink-sql-connector-kafka会引发类冲突问题 - posted by site <si...@163.com> on 2020/12/26 02:37:52 UTC, 1 replies.
- flink1.12.0 HA on k8s native运行一段时间后jobmanager-leader产生大量ConfigMap问题 - posted by tao7 <99...@qq.com> on 2020/12/26 05:42:55 UTC, 1 replies.
- flink-1.12 注册udf问题 - posted by kcz <57...@qq.com> on 2020/12/26 07:23:54 UTC, 0 replies.
- 回复：flink-1.12 注册udf问题 - posted by kcz <57...@qq.com> on 2020/12/26 07:31:30 UTC, 0 replies.
- Flink SQL并发度设置问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2020/12/26 09:39:29 UTC, 6 replies.
- rowtime的时区问题 - posted by ゞ野蠻遊戲χ <zh...@vip.qq.com> on 2020/12/26 15:16:33 UTC, 1 replies.
- flink 1.12 插入 hive 表找不到 .staging_xxxx 文件 - posted by macdoor <ma...@gmail.com> on 2020/12/27 04:05:47 UTC, 0 replies.
- flink 1.12.0 kubernetes-session部署问题 - posted by 陈帅 <ca...@126.com> on 2020/12/27 14:50:32 UTC, 4 replies.
- test - posted by 蒋德祥 <jd...@gmail.com> on 2020/12/27 15:19:48 UTC, 1 replies.
- flink-connector-clickhouse写入ClickHouse 问题 - posted by DanielGu <61...@qq.com> on 2020/12/27 16:15:37 UTC, 1 replies.
- Re: Command: Flink savepoint -d reported an error。 - posted by 赢峰 <si...@163.com> on 2020/12/28 01:28:11 UTC, 0 replies.
- flink1.12错误OSError: Expected IPC message of type schema but got record batch - posted by 小学生 <20...@qq.com> on 2020/12/28 02:36:57 UTC, 6 replies.
- 根据业务需求选择合适的flink state - posted by 张锴 <zk...@gmail.com> on 2020/12/28 05:35:27 UTC, 6 replies.
- Flink RocksDBStateBackend 可以设置阿里云 OSS 存储吗？ - posted by Lei Wang <le...@gmail.com> on 2020/12/28 08:21:21 UTC, 1 replies.
- Some questions about limit push down - posted by Jun Zhang <zh...@gmail.com> on 2020/12/28 09:31:02 UTC, 1 replies.
- flink 1.12 Cancel Job内存未释放(问) - posted by 徐州州 <25...@qq.com> on 2020/12/29 00:57:42 UTC, 1 replies.
- Flink 1.11.2客户端 select * from table - posted by Jacob <17...@163.com> on 2020/12/29 01:11:09 UTC, 1 replies.
- kafka producer 可以动态更新到新扩容的分区吗? - posted by ぐ绿み翼う <35...@qq.com> on 2020/12/29 03:47:31 UTC, 0 replies.
- flink1.10.2 读取mysql并打印数据,本地可以执行,yarn上报错,什么原因呢 - posted by xufengfeng <50...@qq.com> on 2020/12/29 05:51:11 UTC, 1 replies.
- 求和统计后的数据格式-科学计数法 - posted by superainbower <su...@163.com> on 2020/12/29 07:05:36 UTC, 0 replies.
- FlinkSQL 1.10 事件时间声明不能包含系统保留字 - posted by Robin Zhang <vi...@outlook.com> on 2020/12/29 10:55:59 UTC, 2 replies.
- hive读取复杂数据类型写入mysql报错 - posted by zhang hao <zh...@gmail.com> on 2020/12/29 11:15:20 UTC, 0 replies.
- how to achive exactly once with flink sql when consume from kafka and then write to mysql - posted by huliancheng <11...@qq.com> on 2020/12/29 11:52:37 UTC, 0 replies.
- Yarn资源本地化的地方报权限错误 - posted by Qishang <zh...@gmail.com> on 2020/12/29 11:55:16 UTC, 0 replies.
- Re: flink sql ddl CREATE TABLE kafka011 sink 如何开启事务exactly-once？ - posted by huliancheng <11...@qq.com> on 2020/12/29 12:06:38 UTC, 0 replies.
- flink-sql流平台工具 - posted by zhp <49...@qq.com> on 2020/12/29 13:09:55 UTC, 1 replies.
- 如何指定csv分隔符为“||” - posted by 消息室 <he...@qq.com> on 2020/12/29 13:09:59 UTC, 0 replies.
- flink1.12支持hbase1.2吗 - posted by zhp <49...@qq.com> on 2020/12/29 13:12:28 UTC, 1 replies.
- 请教如何在flink job 里自定义kafka source function 及时提交offset - posted by jasonwu <77...@qq.com> on 2020/12/29 14:07:42 UTC, 1 replies.
- 回复： flink 1.12 Cancel Job内存未释放(问) - posted by 徐州州 <25...@qq.com> on 2020/12/30 00:34:47 UTC, 1 replies.
- Flink 1.11.2 替代MapReduce执行 Hive 语句 Full Join 非常慢 - posted by Jacob <17...@163.com> on 2020/12/30 02:12:12 UTC, 0 replies.
- pyflink 如何指定csv分隔符为“||” - posted by 消息室 <he...@qq.com> on 2020/12/30 03:42:19 UTC, 1 replies.
- flink1.11 flinksql 滑动窗口问题反馈 - posted by fan_future <zj...@163.com> on 2020/12/30 04:02:09 UTC, 0 replies.
- pyflink1.11 从Mysql读取Decimal类型数据，数据精度损失问题 - posted by 肖越 <18...@163.com> on 2020/12/30 05:41:16 UTC, 1 replies.
- Re: FlinkSQL是否支持设置窗口trigger实现continuious trigger呢 - posted by fan_future <zj...@163.com> on 2020/12/30 07:30:50 UTC, 1 replies.
- flink1.12 SQL Client 报错 - posted by jiangjiguang719 <ji...@163.com> on 2020/12/30 08:26:59 UTC, 2 replies.
- flink 1.12.0 + hive 3.1.2 报错 java.lang.NoSuchMethodError: com.google.common.base.Preconditions.checkArgument - posted by "Zeng, Jianqiang Zack" <Ji...@bsci.com> on 2020/12/30 08:42:01 UTC, 2 replies.
- 自定义Connector 报错 - posted by superainbower <su...@163.com> on 2020/12/30 10:24:48 UTC, 1 replies.
- canal-json format优化问题 - posted by air23 <wa...@163.com> on 2020/12/30 10:38:59 UTC, 0 replies.
- 回撤流-窗口计算 - posted by 孙啸龙 <su...@126.com> on 2020/12/30 10:41:50 UTC, 2 replies.
- 回复：自定义Connector 报错 - posted by superainbower <su...@163.com> on 2020/12/30 10:59:17 UTC, 2 replies.
- Flink cep可以自动化定义或者从数据中学习生成吗？还是得自己一条一条地添加pattern？ - posted by Xiali Wang <xi...@gmail.com> on 2020/12/30 11:00:54 UTC, 0 replies.
- flink读写阿里云oss问题 - posted by 陈帅 <ca...@126.com> on 2020/12/30 12:52:03 UTC, 0 replies.
- flink如何使用oss作为checkpoint/savepoint/statebackend? - posted by 陈帅 <ca...@126.com> on 2020/12/30 12:53:40 UTC, 1 replies.
- flink on yarn提交任务失败。 - posted by 徐州州 <25...@qq.com> on 2020/12/30 13:39:46 UTC, 0 replies.
- flink-cdc 简单聚合后再次通过jdbc-connector sink到mysql，SnapshotReader出现报错 - posted by chenjb <ch...@163.com> on 2020/12/31 01:26:29 UTC, 0 replies.
- Re: Flink cdc connector：数据量较大时，snapshot阶段报错 - posted by chenjb <ch...@163.com> on 2020/12/31 01:27:48 UTC, 0 replies.
- 关于先基于process_time预聚合，再基于event_time聚合的问题。 - posted by 赵一旦 <hi...@gmail.com> on 2020/12/31 05:01:12 UTC, 1 replies.
- Flink sql执行insert into 的一些问题 - posted by Jacob <17...@163.com> on 2020/12/31 06:12:28 UTC, 0 replies.
- SQL Client并行度设置问题 - posted by jiangjiguang719 <ji...@163.com> on 2020/12/31 06:56:03 UTC, 3 replies.
- Flink 1.12 Sql设置job name - posted by HideOnBushKi <14...@qq.com> on 2020/12/31 07:39:03 UTC, 1 replies.
- FlinkSQL 下推的值类型与字段类型不对应 - posted by automths <au...@163.com> on 2020/12/31 09:13:20 UTC, 1 replies.
- 回复: flink如何使用oss作为checkpoint/savepoint/statebackend? - posted by changleying <cl...@163.com> on 2020/12/31 09:22:26 UTC, 0 replies.
- flink sql 数组下标问题 - posted by silence <sl...@aliyun.com.INVALID> on 2020/12/31 10:02:07 UTC, 0 replies.