user-zh@flink.apache.org, 2021-05

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

- Upsert kafka 作为 source 的几个问题 - posted by key lou <lo...@gmail.com> on 2021/05/01 13:24:13 UTC, 3 replies.
- Re: 流跑着跑着，报出了rocksdb层面的错误 Error while retrieving data from RocksDB - posted by Yun Tang <my...@live.com> on 2021/05/06 06:23:25 UTC, 0 replies.
- Re: 使用processor api生成savepoints，运行后报的错误 - posted by Yun Tang <my...@live.com> on 2021/05/06 06:27:29 UTC, 0 replies.
- flink页面监控问题 - posted by "penguin." <bx...@126.com> on 2021/05/07 01:49:34 UTC, 0 replies.
- 请问ColumnVector类为何没map类型的实现类 - posted by Jun Zhang <zh...@gmail.com> on 2021/05/07 02:34:58 UTC, 0 replies.
- Re: Fwd: flink1.12.2 CLI连接hive出现异常 - posted by Rui Li <li...@gmail.com> on 2021/05/07 02:39:32 UTC, 2 replies.
- 回复：Fwd: flink1.12.2 CLI连接hive出现异常 - posted by guoyb <86...@qq.com> on 2021/05/07 02:58:34 UTC, 0 replies.
- 自定义数据源输出JDBC Sink报错 - posted by TonyChen <to...@qq.com> on 2021/05/07 03:05:27 UTC, 0 replies.
- History Server是否可以查看TaskManager聚合后的日志 - posted by lhuiseu <li...@ipalfish.com> on 2021/05/07 05:48:52 UTC, 1 replies.
- 扩展SqlServerDialect 运行在flink on k8s报错 - posted by "18756225770@163.com" <18...@163.com> on 2021/05/07 05:58:57 UTC, 1 replies.
- 请问在native kubernetes上如何运行Flink History Server? - posted by "casel.chen" <ca...@126.com> on 2021/05/07 06:19:59 UTC, 1 replies.
- 回复: Re: 扩展SqlServerDialect 运行在flink on k8s报错 - posted by "18756225770@163.com" <18...@163.com> on 2021/05/07 07:01:20 UTC, 0 replies.
- 关于minicluster的监听器超时问题 - posted by 刘阳buaa <18...@qq.com> on 2021/05/07 07:05:38 UTC, 0 replies.
- flink job task在taskmanager上分布不均衡 - posted by wenyuan138 <we...@gmail.com> on 2021/05/07 08:42:42 UTC, 4 replies.
- 回复： Flink sql 自定义udaf函数出现 No match found for function signature count_uadf() - posted by JackJia <co...@126.com> on 2021/05/07 09:50:55 UTC, 0 replies.
- 回复：flink job task在taskmanager上分布不均衡 - posted by allanqinjy <al...@163.com> on 2021/05/07 11:31:27 UTC, 0 replies.
- Iceberg Upsert: Iceberg 通过Kafka一次性插入多条主键值相同的数据，数据查询不了 - posted by xwmr <78...@qq.com> on 2021/05/07 12:48:16 UTC, 2 replies.
- Flink写clickhouse怎么实现精准一次性 - posted by 李一飞 <ku...@163.com> on 2021/05/07 14:27:22 UTC, 1 replies.
- 退订 - posted by 杨军 <ya...@163.com> on 2021/05/08 00:58:50 UTC, 13 replies.
- Flink CDC 问题 - posted by lp <97...@qq.com> on 2021/05/08 02:26:51 UTC, 0 replies.
- Flinl CDC日期格式 - posted by ELVIS_SUE <29...@qq.com> on 2021/05/08 03:12:18 UTC, 0 replies.
- flink on native kubernetes要如何修改Logging配置？ - posted by "casel.chen" <ca...@126.com> on 2021/05/08 03:50:03 UTC, 1 replies.
- About the windowOperator and Watermark - posted by 曲洋 <qu...@126.com> on 2021/05/08 06:03:26 UTC, 1 replies.
- 关于watermark和window - posted by 曲洋 <qu...@126.com> on 2021/05/08 06:09:34 UTC, 0 replies.
- 回复： Flink写clickhouse怎么实现精准一次性 - posted by 13051111332 <13...@163.com> on 2021/05/08 06:48:32 UTC, 0 replies.
- 回复：关于watermark和window - posted by Anlen <29...@qq.com> on 2021/05/08 07:09:06 UTC, 3 replies.
- 回复: 回复：关于watermark和window - posted by 明启孙 <37...@qq.com> on 2021/05/08 11:12:59 UTC, 2 replies.
- 问题咨询 - posted by "wyinjava@126.com" <wy...@126.com> on 2021/05/10 01:27:47 UTC, 1 replies.
- Flink集成到CDH集群，Flink重启后web页面打不开 - posted by "maker_dong@foxmail.com" <ma...@foxmail.com> on 2021/05/10 02:40:40 UTC, 0 replies.
- 回复：Flink集成到CDH集群，Flink重启后web页面打不开 - posted by guoyb <86...@qq.com> on 2021/05/10 03:22:47 UTC, 1 replies.
- Flink 流批一体的实践 - posted by Jacob <17...@163.com> on 2021/05/10 07:24:37 UTC, 0 replies.
- yarn-cluster模式下flink的类加载顺序问题 - posted by Willson <wa...@mails.jlu.edu.cn> on 2021/05/10 09:10:12 UTC, 0 replies.
- prometheus metric中如何设置label - posted by suisuimu <72...@qq.com> on 2021/05/10 10:15:05 UTC, 1 replies.
- FlinkCEP Pattern匹配的问题 - posted by lp <97...@qq.com> on 2021/05/10 10:48:04 UTC, 0 replies.
- 回复：FlinkCEP Pattern匹配的问题 - posted by 张义藤 <in...@163.com> on 2021/05/10 11:35:57 UTC, 0 replies.
- ./sql-client.sh embedded 这种方式提交的flink任务怎么设置state以及checkpoint? - posted by 董建 <62...@163.com> on 2021/05/11 08:58:04 UTC, 1 replies.
- flinkSQL插入数据Illegal use of 'NULL' - posted by "maker_dong@foxmail.com" <ma...@foxmail.com> on 2021/05/11 09:46:01 UTC, 0 replies.
- flink on k8s native 测试失败 - posted by 仙剑……情动人间 <15...@qq.com> on 2021/05/12 00:38:03 UTC, 1 replies.
- flink1.12.0 tableAggregationFunction在PLAN阶段报错 - posted by "wanglonglong@wondersgroup.com" <wa...@wondersgroup.com> on 2021/05/12 04:10:41 UTC, 0 replies.
- 回复： prometheus metric中如何设置label - posted by MOBIN <18...@163.com> on 2021/05/12 07:20:25 UTC, 0 replies.
- Flink-connector-jdbc源码问题疑惑 - posted by 丁浩浩 <18...@163.com> on 2021/05/12 08:37:50 UTC, 0 replies.
- flink sql写hbase问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2021/05/12 11:23:53 UTC, 0 replies.
- flink es bulk写入是否考虑支持concurrentRequest - posted by suisuimu <72...@qq.com> on 2021/05/12 12:31:01 UTC, 1 replies.
- flink sql如何修改执行计划？ - posted by "casel.chen" <ca...@126.com> on 2021/05/13 00:19:24 UTC, 1 replies.
- 回复：flink sql写hbase问题 - posted by allanqinjy <al...@163.com> on 2021/05/13 02:09:49 UTC, 1 replies.
- 回复： flink on k8s native 测试失败 - posted by 仙剑……情动人间 <15...@qq.com> on 2021/05/13 06:57:07 UTC, 0 replies.
- Re: Flink 1.11版本LeaseRenewer线程不释放 - posted by zhisheng <zh...@gmail.com> on 2021/05/13 08:19:45 UTC, 1 replies.
- 回复： Flink 1.11版本LeaseRenewer线程不释放 - posted by 5599 <67...@qq.com> on 2021/05/13 08:21:55 UTC, 0 replies.
- flink sql怎样将change log stream转换成append log stream? - posted by "casel.chen" <ca...@126.com> on 2021/05/13 09:20:15 UTC, 2 replies.
- 类型转换问题 String 类型如何转 decimal类型 - posted by WeiXubin <18...@163.com> on 2021/05/13 09:49:33 UTC, 0 replies.
- FlinkCEP 尽可能多的匹配的问题 - posted by lp <97...@qq.com> on 2021/05/13 12:52:41 UTC, 0 replies.
- Mysql cdc 事件时间 - posted by 流弊 <13...@qq.com> on 2021/05/13 14:14:10 UTC, 0 replies.
- flink使用hive作为维表，kafka作为数据源，join时候报错 - posted by hehuiyuan <kn...@163.com> on 2021/05/13 14:27:06 UTC, 0 replies.
- 请教flink cep如何对无序数据处理 - posted by sherlock zw <zw...@LIVE.COM> on 2021/05/14 00:51:49 UTC, 2 replies.
- 回复：flink使用hive作为维表，kafka作为数据源，join时候报错 - posted by allanqinjy <al...@163.com> on 2021/05/14 01:39:32 UTC, 2 replies.
- Flink etl 的应用场景 - posted by 孙啸龙 <su...@126.com> on 2021/05/14 01:45:35 UTC, 0 replies.
- flink 读写ceph - posted by 仙剑……情动人间 <15...@qq.com> on 2021/05/14 02:20:42 UTC, 0 replies.
- UpsertStreamTableSink requires that Table has a full primary keys if it is updated. - posted by automths <au...@163.com> on 2021/05/14 03:00:13 UTC, 4 replies.
- sideoutput sql语法支持 - posted by Yu Xia <15...@qq.com> on 2021/05/14 06:16:00 UTC, 0 replies.
- FlinKCEP - posted by lp <97...@qq.com> on 2021/05/14 06:42:13 UTC, 2 replies.
- Exception: Could not perform checkpoint - posted by gen <li...@outlook.com> on 2021/05/14 10:44:49 UTC, 1 replies.
- 回复: 请教flink cep如何对无序数据处理 - posted by sherlock zw <zw...@live.com> on 2021/05/15 12:08:50 UTC, 0 replies.
- Flink SQL CodeGenException - posted by sherlock c <cy...@gmail.com> on 2021/05/15 12:10:14 UTC, 0 replies.
- ExtractionUtils#getClassReader 触发open too many files 异常 - posted by "zhiping.lin" <lz...@163.com> on 2021/05/16 09:02:07 UTC, 0 replies.
- 关于union之后的keyBy问题 - posted by 赫里斯汀的树 <58...@qq.com> on 2021/05/17 01:59:25 UTC, 1 replies.
- pyflink双流join - posted by qianhuan <81...@qq.com> on 2021/05/17 02:28:53 UTC, 2 replies.
- Flink upgraded to version 1.12.0 and started from SavePoint to report an error - posted by 王炳焱 <15...@163.com> on 2021/05/17 06:11:00 UTC, 3 replies.
- hibench使用identity程序测试flink - posted by "penguin." <bx...@126.com> on 2021/05/17 08:10:36 UTC, 0 replies.
- 集群重启如何保证带状态的任务自动从最近一个checkpoint恢复？ - posted by 董建 <62...@163.com> on 2021/05/17 10:23:58 UTC, 2 replies.
- 使用hibench测试flink - posted by "penguin." <bx...@126.com> on 2021/05/17 12:07:05 UTC, 0 replies.
- 维度表处理时间 - posted by 流弊 <13...@qq.com> on 2021/05/18 00:46:40 UTC, 3 replies.
- flink问题咨询 - posted by 清酌 <sh...@ideacome.com> on 2021/05/18 01:49:14 UTC, 1 replies.
- flink sql源表定义字段列表问题 - posted by "casel.chen" <ca...@126.com> on 2021/05/18 03:49:16 UTC, 1 replies.
- flink sql写mysql中文乱码问题 - posted by "casel.chen" <ca...@126.com> on 2021/05/18 03:55:46 UTC, 6 replies.
- 回复：集群重启如何保证带状态的任务自动从最近一个checkpoint恢复？ - posted by 5599 <67...@qq.com> on 2021/05/18 04:19:55 UTC, 0 replies.
- flink mysql cdc支持mysql的json格式吗？ - posted by 董建 <62...@163.com> on 2021/05/18 09:35:29 UTC, 1 replies.
- (无主题) - posted by maozhaolin <ma...@163.com> on 2021/05/18 10:09:24 UTC, 2 replies.
- 如何统计n小时内，flink成功从kafka消费的数据量？ - posted by zzzyw <zh...@163.com> on 2021/05/18 13:33:26 UTC, 3 replies.
- 请教，有哪些连接器能让我获得一个非 update/delete，但又有主键的流呢？ - posted by LittleFall <15...@qq.com> on 2021/05/18 14:57:55 UTC, 1 replies.
- 请问flink 什么时候支持读写ACID的hive表 - posted by youngysh <yo...@126.com> on 2021/05/19 03:37:34 UTC, 1 replies.
- flink 1.13.0 ，使用flink sql 链接数据库是否支持多模式，即表名为schema.name - posted by Asahi Lee <97...@qq.com> on 2021/05/19 06:01:37 UTC, 1 replies.
- 请教：如何获取queryable-state.proxy.ports的实际值 - posted by "cao.j" <jo...@qq.com> on 2021/05/19 08:07:22 UTC, 0 replies.
- flink job 运行一小时会出现报错 - posted by cecotw <ce...@163.com> on 2021/05/20 09:02:42 UTC, 0 replies.
- 回复：flink job 运行一小时会出现报错 - posted by 田向阳 <lu...@163.com> on 2021/05/20 09:36:30 UTC, 1 replies.
- flink sql运行在阿里云k8s用oss作为checkpoint存储介质出错 - posted by "casel.chen" <ca...@126.com> on 2021/05/21 06:51:39 UTC, 0 replies.
- Flink Jdbc Connector close方法线程同步 - posted by Luna Wong <gf...@gmail.com> on 2021/05/21 08:56:05 UTC, 0 replies.
- 退订邮件服务 - posted by 924602208 <do...@foxmail.com> on 2021/05/21 09:23:42 UTC, 0 replies.
- flink sql支持创建临时函数吗？ - posted by "casel.chen" <ca...@126.com> on 2021/05/21 15:21:26 UTC, 0 replies.
- flink sql支持Common Table Expression (CTE)吗？ - posted by "casel.chen" <ca...@126.com> on 2021/05/21 15:23:28 UTC, 1 replies.
- flink checkpoint 数据清理问题 - posted by 赵旭晨 <jj...@163.com> on 2021/05/22 02:10:53 UTC, 1 replies.
- Re: Re:Re: Re: Flink 1.11.1 on k8s 如何配置hadoop - posted by mts_geek <mt...@163.com> on 2021/05/22 03:56:23 UTC, 0 replies.
- 关于 flinksql 维表的问题 - posted by WeiXubin <18...@163.com> on 2021/05/22 08:08:58 UTC, 6 replies.
- 关于Table和DataStream相互转化的问题 - posted by lp <97...@qq.com> on 2021/05/23 05:18:08 UTC, 0 replies.
- Flink/FlinkSQL如何开启检查点，但自动重启不基于检查点。 - posted by yidan zhao <hi...@gmail.com> on 2021/05/24 02:25:19 UTC, 0 replies.
- Deduplication query - posted by jiangwan <ji...@foxmail.com> on 2021/05/24 07:04:36 UTC, 0 replies.
- flink exception cound not retrieve file from transient blob store - posted by mq sun <su...@gmail.com> on 2021/05/24 08:18:06 UTC, 0 replies.
- Re: java.lang.IllegalStateException: Trying to access closed classloader. - posted by panzhihao <52...@qq.com> on 2021/05/24 11:16:35 UTC, 1 replies.
- avro.ComplexPayloadAvro - posted by r pp <pr...@gmail.com> on 2021/05/25 01:51:23 UTC, 2 replies.
- flink sql cdc并行度问题 - posted by "casel.chen" <ca...@126.com> on 2021/05/25 03:51:27 UTC, 3 replies.
- flink状态查看工具 - posted by "casel.chen" <ca...@126.com> on 2021/05/26 01:14:28 UTC, 1 replies.
- 退订邮件 - posted by "wujinglun@shantaijk.cn" <wu...@shantaijk.cn> on 2021/05/26 06:36:55 UTC, 0 replies.
- createTemporaryView接口注册table时，fieldname支持中横线（-） - posted by Jun Zou <ni...@gmail.com> on 2021/05/26 08:32:45 UTC, 1 replies.
- 关于savepoint恢复问题咨询 - posted by 王春浩 <wa...@navercorp.com> on 2021/05/26 09:30:51 UTC, 1 replies.
- 关于北京哪里有开化工原料发票-北京产品吧 - posted by luoshaoj <li...@Gmail.com> on 2021/05/26 17:40:49 UTC, 0 replies.
- 关于兰州哪里有开机械设备发票-兰州本地宝 - posted by luoshaoj <li...@Gmail.com> on 2021/05/26 17:42:52 UTC, 0 replies.
- SQL DDL选项的值需要单引号应该如何解决？ - posted by Luna Wong <gf...@gmail.com> on 2021/05/27 08:02:33 UTC, 1 replies.
- flink 维表 - posted by liujian <13...@qq.com> on 2021/05/27 08:35:21 UTC, 2 replies.
- flink 1.12 通过rest api 提交任务时 SupervisorActor block - posted by seuzxc <ze...@gmail.com> on 2021/05/27 08:46:09 UTC, 2 replies.
- 流与流 left join - posted by 流弊 <13...@qq.com> on 2021/05/27 11:36:18 UTC, 9 replies.
- Flink sql 执行计划 - posted by 流弊 <13...@qq.com> on 2021/05/27 11:53:07 UTC, 0 replies.
- 如何根据flink sql解析出作业的血缘关系？ - posted by "casel.chen" <ca...@126.com> on 2021/05/27 15:33:03 UTC, 0 replies.
- rocksdb状态后端最多保留checkpoints问题 - posted by "casel.chen" <ca...@126.com> on 2021/05/27 15:35:44 UTC, 3 replies.
- flink 1.12.2 编译报错 - posted by Zhiwen Sun <pe...@gmail.com> on 2021/05/28 02:15:55 UTC, 5 replies.
- 回复： flink 维表 - posted by liujian <13...@qq.com> on 2021/05/28 02:49:40 UTC, 0 replies.
- flink1.13 通过sql cli执行hdfs上面的SQL文件 - posted by guozhi mang <ro...@gmail.com> on 2021/05/28 03:30:39 UTC, 2 replies.
- flink hive batch作业报FileNotFoundException - posted by bowen li <ch...@gmail.com> on 2021/05/28 03:35:07 UTC, 0 replies.
- flink 1.13.0 中cumulate window 使用 - posted by 邹云鹤 <ke...@163.com> on 2021/05/28 03:43:57 UTC, 1 replies.
- 回复： flink 1.13.0 中cumulate window 使用 - posted by 邹云鹤 <ke...@163.com> on 2021/05/28 03:52:24 UTC, 0 replies.
- 回复：flink 1.13.0 中cumulate window 使用 - posted by 范瑞 <83...@qq.com> on 2021/05/28 04:37:37 UTC, 0 replies.
- Re: 回复：Flink sql的state ttl设置 - posted by chenchencc <13...@qq.com> on 2021/05/28 08:28:12 UTC, 1 replies.
- flink on yarn 模式下，yarn集群的resource-manager切换导致flink应用程序重启，并且未从最后一次checkpoint恢复 - posted by 董建 <62...@163.com> on 2021/05/28 09:37:25 UTC, 4 replies.
- Re: flink hive批量作业报FileNotFoundException - posted by libowen <ch...@gmail.com> on 2021/05/28 10:15:46 UTC, 0 replies.
- flink 1.13 k8s native 启动找不到 KubernetesSessionClusterEntrypoint - posted by fz <fr...@163.com> on 2021/05/28 14:09:18 UTC, 1 replies.
- 不同的程序在同一时间段报同一个异常 - posted by mq sun <su...@gmail.com> on 2021/05/30 11:23:07 UTC, 1 replies.
- 求教：动态字段的处理 - posted by 信华哺 <la...@163.com> on 2021/05/31 03:25:52 UTC, 2 replies.
- flink job exception - posted by krislee <kr...@163.com> on 2021/05/31 05:55:12 UTC, 0 replies.
- 回复：flink job exception - posted by day <37...@qq.com> on 2021/05/31 06:06:42 UTC, 0 replies.
- Flink Sql 的/checkpoint/shared/文件夹大小不断增长，源数据没有数据激增，应该如何控制？ - posted by yujianbo <15...@163.com> on 2021/05/31 08:02:13 UTC, 0 replies.
- 怎么关闭operatorChaining - posted by McClone <ab...@163.com> on 2021/05/31 09:13:15 UTC, 0 replies.
- Re: flink sink kafka from checkpoint run failed - posted by tianxy <lu...@163.com> on 2021/05/31 11:16:59 UTC, 0 replies.
- Flink state processor API with Avro data type - posted by Min Tan <ta...@icloud.com.INVALID> on 2021/05/31 16:27:10 UTC, 0 replies.