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

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

- 为什么每次打印的是上一条消息产生的watermark,不是最新的一条消息产生的watermark呢?并行度设置为1了 - posted by "hezongjin12@qq.com" <he...@qq.com> on 2021/02/01 01:28:15 UTC, 2 replies.
- 回复：为什么每次打印的是上一条消息产生的watermark,不是最新的一条消息产生的watermark呢?并行度设置为1了 - posted by 何宗谨 <he...@qq.com> on 2021/02/01 01:41:25 UTC, 0 replies.
- 水印的作用请教 - posted by amenhub <am...@163.com> on 2021/02/01 02:26:26 UTC, 7 replies.
- Re: 咨询求助 - posted by Leonard Xu <xb...@gmail.com> on 2021/02/01 02:30:32 UTC, 0 replies.
- flink sql 中的时区问题 - posted by 沉醉寒風 <10...@qq.com> on 2021/02/01 02:40:36 UTC, 0 replies.
- flink sql时区问题 - posted by 沉醉寒風 <10...@qq.com> on 2021/02/01 02:42:38 UTC, 2 replies.
- Re: 是否可以 hive 流 join hive 流？ - posted by Leonard Xu <xb...@gmail.com> on 2021/02/01 02:44:57 UTC, 4 replies.
- 回复： flink sql时区问题 - posted by 沉醉寒風 <10...@qq.com> on 2021/02/01 02:50:19 UTC, 0 replies.
- Re: 请问pyflink如何跟kerberos认证的kafka对接呢 - posted by Wei Zhong <we...@gmail.com> on 2021/02/01 03:11:58 UTC, 0 replies.
- 关于配置关联初始化方案的实现问题 - posted by javenjiangfsof <ja...@163.com> on 2021/02/01 03:40:04 UTC, 4 replies.
- Re: [ANNOUNCE] Apache Flink 1.10.3 released - posted by Zhu Zhu <re...@gmail.com> on 2021/02/01 04:04:01 UTC, 0 replies.
- Re: flink编译报错 - posted by wxpcc <wx...@outlook.com> on 2021/02/01 06:27:46 UTC, 0 replies.
- flink 1.12 中如何读取 mysql datetime 字段 - posted by macdoor <ma...@gmail.com> on 2021/02/01 06:37:31 UTC, 1 replies.
- 关于kafka中csv格式数据字段分隔符请教 - posted by "yinghua_zh@163.com" <yi...@163.com> on 2021/02/01 08:05:17 UTC, 1 replies.
- flink做checkpoint失败 Checkpoint Coordinator is suspending. - posted by chen310 <22...@163.com> on 2021/02/01 08:11:41 UTC, 3 replies.
- TwoPhaseCommitSinkFunction 中 initializeState 代码的困惑 - posted by Zeahoo <ze...@gmail.com> on 2021/02/01 08:25:24 UTC, 0 replies.
- 水位线问题 - posted by 沉醉寒風 <10...@qq.com> on 2021/02/01 09:20:26 UTC, 0 replies.
- Flink 1.12 SQL 语法，是否完全兼容 Flink 1.10 的 SQL 语法 - posted by LakeShen <sh...@gmail.com> on 2021/02/01 09:21:51 UTC, 0 replies.
- 回复: 水位线问题 - posted by amenhub <am...@163.com> on 2021/02/01 09:52:05 UTC, 0 replies.
- 回复：回复: 水位线问题 - posted by 沉醉寒風 <10...@qq.com> on 2021/02/01 09:56:41 UTC, 0 replies.
- 回复: 回复: 水位线问题 - posted by amenhub <am...@163.com> on 2021/02/01 10:03:19 UTC, 0 replies.
- 回复：回复: 回复: 水位线问题 - posted by 沉醉寒風 <10...@qq.com> on 2021/02/01 10:06:28 UTC, 0 replies.
- Re: Catalog(Kafka Connectors 的ddl)持久化到hive metastore，groupid一样的问题 - posted by 孙啸龙 <su...@126.com> on 2021/02/01 11:55:34 UTC, 0 replies.
- getCurrentWatermark - posted by 梦怀 <49...@qq.com> on 2021/02/01 12:46:50 UTC, 1 replies.
- Flink 1.11 session cluster相关问题 - posted by zilong xiao <ac...@gmail.com> on 2021/02/02 02:35:03 UTC, 1 replies.
- Re: PyFlink Expected IPC message of type schema but got record batch - posted by Xingbo Huang <hx...@gmail.com> on 2021/02/02 03:01:19 UTC, 0 replies.
- Re: flinksql引入flink-parquet_2.11任务提交失败 - posted by yujianbo <15...@163.com> on 2021/02/02 03:06:38 UTC, 1 replies.
- Re: python udf求助: Process died with exit code 0 - posted by Xingbo Huang <hx...@gmail.com> on 2021/02/02 04:09:33 UTC, 0 replies.
- flink-parcel使用求助 - posted by 郭斌 <18...@163.com> on 2021/02/02 05:57:06 UTC, 3 replies.
- flink sql - posted by 沉醉寒風 <10...@qq.com> on 2021/02/02 06:05:12 UTC, 0 replies.
- Flink 提交作业时的缓存可以删除吗 - posted by Robin Zhang <vi...@outlook.com> on 2021/02/02 06:36:56 UTC, 2 replies.
- TaggedOperatorSubtaskState is missing when creating a new savepoint using state processor api - posted by 冰已融化 <17...@qq.com> on 2021/02/02 06:53:46 UTC, 0 replies.
- flink-yarn ha - posted by 郭斌 <18...@163.com> on 2021/02/02 07:35:59 UTC, 0 replies.
- Flink job与自己系统平台的一体化集成 - posted by Jacob <17...@163.com> on 2021/02/02 08:22:43 UTC, 1 replies.
- Flink SQL关于'connector' = 'filesystem‘的问题求助！ - posted by "yinghua_zh@163.com" <yi...@163.com> on 2021/02/02 08:48:12 UTC, 0 replies.
- 写hdfs异常 org.apache.hadoop.fs.FileAlreadyExistsException - posted by jiangjiguang719 <ji...@163.com> on 2021/02/02 08:57:36 UTC, 0 replies.
- flink on yarn ， JobManager和ApplicationMaster的关系 - posted by lp <97...@qq.com> on 2021/02/02 10:00:47 UTC, 3 replies.
- flink写hdfs 如何进行kerberos认证呢 - posted by 瞿叶奇 <38...@qq.com> on 2021/02/02 10:43:53 UTC, 0 replies.
- flink1.10，flink-sql,pyflink创建hdfs的sink表后，不能append，一直报目录已存在的错误 - posted by 瞿叶奇 <38...@qq.com> on 2021/02/02 12:29:53 UTC, 0 replies.
- stop -p停并生产保存点，报错kyro错误。 - posted by 赵一旦 <hi...@gmail.com> on 2021/02/02 12:46:24 UTC, 0 replies.
- pyflink1.11 udf计算结果打印问题 The configured Task Off-Heap Memory 0 bytes is less than the least required Python worker Memory 79 mb - posted by 肖越 <18...@163.com> on 2021/02/03 02:16:38 UTC, 1 replies.
- pyflink1.11 udf计算结果打印问题 Task Off-Heap Memory 0 bytes is less than the least required Python worker Memory 79 mb - posted by 肖越 <18...@163.com> on 2021/02/03 02:23:32 UTC, 2 replies.
- Re: pyflink连接kerberos的kafka问题 - posted by Wei Zhong <we...@gmail.com> on 2021/02/03 02:40:05 UTC, 0 replies.
- 请问在richFunction中如何获取该function输入的元素类型呢？ - posted by 赵一旦 <hi...@gmail.com> on 2021/02/03 03:18:21 UTC, 0 replies.
- 测试pandas udf报错：AttributeError: 'decimal.Decimal' object has no attribute 'isnull' - posted by 肖越 <18...@163.com> on 2021/02/03 03:50:01 UTC, 1 replies.
- Re: 检查点成功，但从检查点恢复失败。使用了guava的bloomFilter，有人帮忙分析下吗？ - posted by 赵一旦 <hi...@gmail.com> on 2021/02/03 04:01:10 UTC, 0 replies.
- flink clickhouse connector - posted by 阿华田 <a1...@163.com> on 2021/02/03 04:10:32 UTC, 1 replies.
- PyFlink How to set timeout for UDF - posted by 苗红宾 <ho...@126.com> on 2021/02/03 05:04:18 UTC, 1 replies.
- 关于无法被看作POJO的类型，怎么转变可以让其不当作GenericType呢？ - posted by 赵一旦 <hi...@gmail.com> on 2021/02/03 05:24:00 UTC, 1 replies.
- 回复：关于无法被看作POJO的类型，怎么转变可以让其不当作GenericType呢？ - posted by ℡小新的蜡笔不见嘞、 <15...@qq.com> on 2021/02/03 05:51:51 UTC, 0 replies.
- 回复：关于无法被看作POJO的类型，怎么转变可以让其不当作GenericType呢？ - posted by ℡小新的蜡笔不见嘞、 <15...@qq.com> on 2021/02/03 06:20:18 UTC, 0 replies.
- HELP!!!! PyFlink UDF加载Keras模型，并注册函数出现的问题 - posted by 陈康 <84...@qq.com> on 2021/02/03 09:22:47 UTC, 5 replies.
- 请问，flink支持StreamFileSink在将pending文件转为finished的时候做一些操作吗 - posted by 上官 <17...@163.com> on 2021/02/03 09:36:43 UTC, 1 replies.
- 如果输入有回撤流的话，group by时间窗口会遇到GroupWindowAggregate doesn't support consuming update and delete changes - posted by HongHuangNeu <hu...@126.com> on 2021/02/03 12:34:15 UTC, 2 replies.
- Flink window evictor(TimeEvictor.of(Time.seconds(0))) 会出现 NullPoint问题 - posted by HunterXHunter <13...@qq.com> on 2021/02/04 02:57:33 UTC, 1 replies.
- 如何在程序里面判断作业是否是重启了 - posted by op <52...@qq.com> on 2021/02/04 03:04:28 UTC, 3 replies.
- pyflink1.12 定义源表后, 执行表关联的query效率较慢？ - posted by 肖越 <18...@163.com> on 2021/02/04 03:15:28 UTC, 0 replies.
- 回复：如何在程序里面判断作业是否是重启了 - posted by op <52...@qq.com> on 2021/02/04 03:26:56 UTC, 2 replies.
- StreamAPi Window 在使用 .evictor(TimeEvictor.of(Time.seconds(0))).sum().print 报NullPoint - posted by HunterXHunter <13...@qq.com> on 2021/02/04 04:08:07 UTC, 1 replies.
- flinkSQL的ValueStateDescriptor没有设置StateTtlConfig - posted by stgztsw <st...@126.com> on 2021/02/04 07:33:30 UTC, 0 replies.
- 回复：flinkSQL的ValueStateDescriptor没有设置StateTtlConfig - posted by 沉醉寒風 <10...@qq.com> on 2021/02/04 07:36:23 UTC, 0 replies.
- 开源Pyflink连接kerberos认证的hdfs结果数据报错 - posted by 瞿叶奇 <38...@qq.com> on 2021/02/04 07:51:51 UTC, 0 replies.
- Re: flink sql - posted by HunterXHunter <13...@qq.com> on 2021/02/04 08:33:55 UTC, 0 replies.
- fink on yarn per job container 被杀 - posted by key lou <lo...@gmail.com> on 2021/02/04 09:46:02 UTC, 2 replies.
- pyflink的py4j里是不是可以调用我自己写的java程序？ - posted by 瞿叶奇 <38...@qq.com> on 2021/02/04 09:53:21 UTC, 4 replies.
- Flink SQL Hive 使用 partition.include 结果跟文档不一致 - posted by macia kk <pr...@gmail.com> on 2021/02/05 01:47:49 UTC, 1 replies.
- 回复： pyflink的py4j里是不是可以调用我自己写的java程序？ - posted by 瞿叶奇 <38...@qq.com> on 2021/02/05 02:48:08 UTC, 3 replies.
- 回复：如何在程序里面判断作业是否是重启了 - posted by 熊云昆 <xi...@163.com> on 2021/02/05 03:30:23 UTC, 0 replies.
- 回复：fink on yarn per job container 被杀 - posted by zhiyezou <15...@qq.com> on 2021/02/05 05:24:26 UTC, 0 replies.
- flink cdc 同步数据问题 - posted by 奔跑的小飞袁 <s_...@126.com> on 2021/02/05 09:39:29 UTC, 0 replies.
- flink cdc同步数据 - posted by 奔跑的小飞袁 <s_...@126.com> on 2021/02/05 09:44:44 UTC, 0 replies.
- flink on yarn 多TaskManager 拒绝连接问题 - posted by Junpb <bj...@126.com> on 2021/02/05 12:09:45 UTC, 3 replies.
- 回复： fink on yarn per job container 被杀 - posted by zhiyezou <15...@qq.com> on 2021/02/07 01:40:54 UTC, 1 replies.
- flink升级hadoop3 - posted by "kandy.wang" <ka...@163.com> on 2021/02/07 02:27:23 UTC, 2 replies.
- pyflink1.12 to_pandas报错：java.lang.RuntimeException: Failed to fetch next result - posted by 肖越 <18...@163.com> on 2021/02/07 02:30:23 UTC, 1 replies.
- PyFlink Could not read the user code wrapper:org.apache.flink.connector.jdbc.table.JdbcRowDataInputFormat - posted by 陈康 <84...@qq.com> on 2021/02/07 02:50:51 UTC, 2 replies.
- Re: pyflink1.12 to_pandas报错：java.lang.RuntimeException: Failed to fetch next result - posted by Xingbo Huang <hx...@gmail.com> on 2021/02/07 03:24:46 UTC, 1 replies.
- 关于flink窗口state - posted by 沉醉寒風 <10...@qq.com> on 2021/02/07 06:40:43 UTC, 1 replies.
- Re: 关于1.12新增的initialize阶段时间较长问题 - posted by 赵一旦 <hi...@gmail.com> on 2021/02/07 07:12:37 UTC, 4 replies.
- java.lang.IllegalStateException: Mailbox is in state CLOSED, but is required to be in state OPEN for put operations - posted by "zhaoy@greatld.com" <zh...@greatld.com> on 2021/02/07 07:19:07 UTC, 0 replies.
- pyflink Failed to create stage bundle factory! INFO:root:Initializing python harness: - posted by 陈康 <84...@qq.com> on 2021/02/07 07:43:55 UTC, 0 replies.
- procesElement中每天数据都put 进入map，但下一条数据来时map都是空的咨询 - posted by 谌祖安 <sh...@pcitech.com> on 2021/02/07 08:25:20 UTC, 2 replies.
- flink 1.12.0 k8s session部署异常 - posted by "casel.chen" <ca...@126.com> on 2021/02/07 08:33:56 UTC, 0 replies.
- pyFlink UDF Caused by: java.lang.RuntimeException: Failed to create stage bundle factory! INFO:root:Initializing python harness: - posted by 陈康 <84...@qq.com> on 2021/02/08 02:28:34 UTC, 3 replies.
- Flink SQL temporal table join with Hive 报错 - posted by macia kk <pr...@gmail.com> on 2021/02/08 02:32:39 UTC, 7 replies.
- 求问 Yarn application state 和 Flink Job status 的对应关系？ - posted by 小旋锋 <wh...@qq.com> on 2021/02/08 10:14:49 UTC, 0 replies.
- 回复: flink升级hadoop3 - posted by "lxk7491@163.com" <lx...@163.com> on 2021/02/08 10:59:38 UTC, 0 replies.
- flink双流join如何确保数据不丢失 - posted by "lxk7491@163.com" <lx...@163.com> on 2021/02/08 11:05:56 UTC, 1 replies.
- 回复：flink双流join如何确保数据不丢失 - posted by Mailbox service <13...@qq.com> on 2021/02/08 13:38:47 UTC, 0 replies.
- Flink standalone on k8s HA异常 - posted by "casel.chen" <ca...@126.com> on 2021/02/08 16:09:39 UTC, 1 replies.
- 关于非keyedstream使用定时器问题 - posted by yidan zhao <hi...@gmail.com> on 2021/02/09 07:04:19 UTC, 4 replies.
- flink per job taskmanager 日志查看问题 - posted by automths <au...@163.com> on 2021/02/09 09:29:44 UTC, 0 replies.
- 回复：flink per job taskmanager 日志查看问题 - posted by 471419897 <47...@qq.com> on 2021/02/09 14:25:14 UTC, 2 replies.
- 答复: procesElement中每天数据都put 进入map，但下一条数据来时map都是空的咨询 - posted by 范超 <fa...@mgtv.com> on 2021/02/10 02:42:39 UTC, 0 replies.
- Fw:flinksql写入hive问题 - posted by 潘永克 <13...@163.com> on 2021/02/11 04:15:14 UTC, 1 replies.
- group by alias name - posted by "xiaolailong@163.com" <xi...@163.com> on 2021/02/13 16:37:27 UTC, 1 replies.
- PyFlink source使用场景求助 - posted by 刘旭 <li...@qq.com> on 2021/02/15 02:54:55 UTC, 0 replies.
- Flink实时统计结果波动时大时小 - posted by flink2021 <ye...@163.com> on 2021/02/16 07:30:13 UTC, 3 replies.
- flink k8s高可用如何使用oss作为high-availability.storageDir? - posted by "casel.chen" <ca...@126.com> on 2021/02/17 09:41:30 UTC, 1 replies.
- FlinkKafka Consumer can't dynamic discover the partition update - posted by 张云云 <yu...@gmail.com> on 2021/02/18 03:09:27 UTC, 2 replies.
- Re: blob server相关，文件找不到 - posted by Alex_gao <ga...@outlook.com> on 2021/02/18 05:49:42 UTC, 1 replies.
- flink cdc 遇到akka RemoteRpcInvocation 问题 - posted by william <71...@qq.com> on 2021/02/18 06:25:37 UTC, 0 replies.
- flink cdc 遇到Heartbeat of TaskManager with id timed out - posted by william <71...@qq.com> on 2021/02/18 06:27:07 UTC, 0 replies.
- FLINK 消费kafka 报错java.lang.OutOfMemoryError: Direct buffer memory - posted by flink2021 <ye...@163.com> on 2021/02/18 08:22:44 UTC, 3 replies.
- Re: flink1.12 on yarn per-job 运行问题 - posted by chaos <ji...@163.com> on 2021/02/18 09:25:33 UTC, 0 replies.
- flink1.12 不能同时在一个工程消费jdbc和kafka CDC数据 - posted by nosstock <12...@qq.com> on 2021/02/18 09:36:37 UTC, 1 replies.
- 回复：FLINK 消费kafka 报错java.lang.OutOfMemoryError: Direct buffer memory - posted by Shuai Xia <jk...@dingtalk.com.INVALID> on 2021/02/18 09:55:16 UTC, 0 replies.
- Re: FLINK消费kafka 报错java.lang.OutOfMemoryError: Direct buffer memory - posted by 主 Gmail <gc...@gmail.com> on 2021/02/18 13:24:49 UTC, 0 replies.
- Container is running beyond physical memory limits - posted by lian <lz...@126.com> on 2021/02/18 16:53:05 UTC, 2 replies.
- flink on k8s日志时间戳时区问题 - posted by "casel.chen" <ca...@126.com> on 2021/02/19 01:37:28 UTC, 2 replies.
- 任务运行期间hdfs重启，如何自动恢复？ - posted by amenhub <am...@163.com> on 2021/02/19 02:40:43 UTC, 0 replies.
- flink on yarn任务的唯一性id问题 - posted by datayangl <da...@gmail.com> on 2021/02/19 06:18:30 UTC, 0 replies.
- 如何在pyflink中使用全量窗口聚合ProcessWindowFunction - posted by Hongyuan Ma <cs...@163.com> on 2021/02/19 07:31:00 UTC, 0 replies.
- Flink1.12.0版本，Versioned Tables - posted by guanyq <dl...@163.com> on 2021/02/19 07:57:37 UTC, 0 replies.
- Flink SQL时间序列化问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2021/02/19 09:55:52 UTC, 0 replies.
- flink可以同时对接两套独立kerberos认证的kafka吗 - posted by liwei li <hi...@gmail.com> on 2021/02/19 10:33:08 UTC, 1 replies.
- SqlValidatorException: No match found for function signature prod() - posted by xiaoyue <18...@163.com> on 2021/02/20 05:14:18 UTC, 2 replies.
- flink sql source kafka sink 到 mysql 遇主健冲突出现append现象 - posted by Yu Wang <yu...@gmail.com> on 2021/02/20 07:16:07 UTC, 0 replies.
- 自定义partition，使用遇到问题，附代码 - posted by Ye Chen <ch...@163.com> on 2021/02/20 07:26:27 UTC, 1 replies.
- Flink standalone模式如何区分各个任务的日志? - posted by xingoo <23...@qq.com> on 2021/02/20 09:27:16 UTC, 3 replies.
- Flink SQL并发度问题 - posted by "guaishushu1103@163.com" <gu...@163.com> on 2021/02/20 10:23:52 UTC, 1 replies.
- 大佬们, keyby()两次, 然后再window(), 会有几个窗口? - posted by Hongyuan Ma <cs...@163.com> on 2021/02/21 14:43:12 UTC, 4 replies.
- pyflink对Redis sink的支持 - posted by whh_960101 <wh...@163.com> on 2021/02/22 01:45:46 UTC, 1 replies.
- flink生成大宽表 - posted by liujian <13...@qq.com> on 2021/02/22 03:05:46 UTC, 1 replies.
- 回复：flink生成大宽表 - posted by liujian <13...@qq.com> on 2021/02/22 03:15:30 UTC, 0 replies.
- 回复：Re:SqlValidatorException: No match found for function signature prod() - posted by Presley <ti...@foxmail.com> on 2021/02/22 03:17:27 UTC, 0 replies.
- SQL作业中使用python udfs语法检查报错，作业提交缺没问题 - posted by zilong xiao <ac...@gmail.com> on 2021/02/22 03:44:47 UTC, 0 replies.
- flinksql1.11连接hive：ClassNotFoundException: org.apache.hadoop.fs.PathHandle - posted by Presley <ti...@foxmail.com> on 2021/02/22 04:38:38 UTC, 0 replies.
- 回复：flinksql1.11连接hive：ClassNotFoundException: org.apache.hadoop.fs.PathHandle - posted by Presley <ti...@foxmail.com> on 2021/02/22 04:42:49 UTC, 0 replies.
- bahir-flink 的 flink-connector-kudu 能做批读取么？ - posted by Haseo Chen <tp...@outlook.com> on 2021/02/22 06:30:37 UTC, 0 replies.
- Flink SQL 写入Hive问题请教 - posted by "yinghua_zh@163.com" <yi...@163.com> on 2021/02/22 06:36:49 UTC, 6 replies.
- flink sql 写入clickhouse性能优化 - posted by "kandy.wang" <ka...@163.com> on 2021/02/22 10:16:07 UTC, 0 replies.
- 回复: Re: 大佬们, keyby()两次, 然后再window(), 会有几个窗口? - posted by hdxg1101300123 <hd...@163.com> on 2021/02/22 15:36:59 UTC, 0 replies.
- 大佬们, assignTimestampsAndWatermarks() 支持将eventTime设置为未来的时间吗 - posted by Hongyuan Ma <cs...@163.com> on 2021/02/23 05:50:21 UTC, 0 replies.
- 通过普通ddl来读写hive - posted by silence <sl...@aliyun.com.INVALID> on 2021/02/23 06:57:31 UTC, 7 replies.
- 退订 - posted by 万建国 <10...@qq.com> on 2021/02/23 07:35:50 UTC, 2 replies.
- flink1.11的Streaming File Sink问题 - posted by op <52...@qq.com> on 2021/02/23 07:47:54 UTC, 1 replies.
- Flink 1.12 On Yarn 作业提交失败问题 - posted by LakeShen <sh...@gmail.com> on 2021/02/23 10:46:55 UTC, 4 replies.
- 本地api提交jar包到Flink on Yarn集群，报错 Error: Could not find or load main class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint - posted by 凌战 <m1...@163.com> on 2021/02/23 10:57:53 UTC, 2 replies.
- 回复：本地api提交jar包到Flink on Yarn集群，报错 Error: Could not find or load main class org.apache.flink.yarn.entrypoint.YarnJobClusterEntrypoint - posted by 凌战 <m1...@163.com> on 2021/02/23 11:01:16 UTC, 3 replies.
- 回复：Flink 1.12 On Yarn 作业提交失败问题 - posted by 凌战 <m1...@163.com> on 2021/02/23 11:33:35 UTC, 0 replies.
- 回复： Flink 1.12 On Yarn 作业提交失败问题 - posted by 凌战 <m1...@163.com> on 2021/02/23 14:34:37 UTC, 2 replies.
- ValidationException: SQL validation failed.No match found for function signature count_uadf() - posted by Presley <ti...@foxmail.com> on 2021/02/24 01:37:42 UTC, 0 replies.
- flinksql1.11自定义聚合函数UDAF使用问题：No match found for function signature prod() - posted by Presley <ti...@foxmail.com> on 2021/02/24 02:32:31 UTC, 0 replies.
- Flink On Yarn Per Job 作业提交失败问题 - posted by 凌战 <m1...@163.com> on 2021/02/24 03:23:27 UTC, 1 replies.
- 社区有人实现过Flink的MongodbSource吗？ - posted by Evan <ch...@foxmail.com> on 2021/02/24 08:23:42 UTC, 5 replies.
- UpsertKafka state持续增加问题 - posted by xiaohui zhang <xh...@gmail.com> on 2021/02/24 13:44:29 UTC, 0 replies.
- UpsertKafka状态保存问题 - posted by xiaohui zhang <xh...@gmail.com> on 2021/02/24 14:57:31 UTC, 0 replies.
- flink-connector-hbase-2.2 模块的测试类：HBaseConnectorITCase 运行异常 - posted by Anlen <29...@qq.com> on 2021/02/25 02:05:58 UTC, 0 replies.
- 关于standalone集群jobmanager在操作时候web-ui卡顿的问题 - posted by yidan zhao <hi...@gmail.com> on 2021/02/25 02:58:38 UTC, 0 replies.
- flink sql 并发数问题 - posted by Jeff <zi...@126.com> on 2021/02/25 03:17:22 UTC, 1 replies.
- 关于Flink五分钟统计导致五分钟的CPU尖刺问题 - posted by yidan zhao <hi...@gmail.com> on 2021/02/25 03:47:42 UTC, 0 replies.
- Re: Flink 维表延迟join - posted by LakeShen <sh...@gmail.com> on 2021/02/25 04:00:18 UTC, 2 replies.
- Re: 关于flinksql 与维表mysql的关联问题 - posted by LakeShen <sh...@gmail.com> on 2021/02/25 04:09:14 UTC, 0 replies.
- flink sql tumble window 时区问题 - posted by xuhaiLong <xi...@163.com> on 2021/02/25 04:21:51 UTC, 0 replies.
- 回复： Flink 维表延迟join - posted by Suhan <ma...@foxmail.com> on 2021/02/25 06:40:29 UTC, 0 replies.
- Flink SQL UDF 如何自定义Metrics - posted by xingoo <23...@qq.com> on 2021/02/25 07:12:26 UTC, 0 replies.
- flink1.12读mysql问题 - posted by 酷酷的浑蛋 <ap...@163.com> on 2021/02/25 07:41:16 UTC, 0 replies.
- groupBy和keyBy的使用方式不同吗？ - posted by 李继 <li...@gmail.com> on 2021/02/25 08:58:38 UTC, 0 replies.
- Flink1.12.0版本 Distinct Aggregation - posted by guanyq <dl...@163.com> on 2021/02/25 09:47:59 UTC, 0 replies.
- ecommerce photography studio - posted by Jason <vs...@minefilms.com> on 2021/02/25 11:59:05 UTC, 0 replies.
- flinksql集成hive权限管理 - posted by 阿华田 <a1...@163.com> on 2021/02/25 12:48:32 UTC, 1 replies.
- 升级kafka导致fink job失败 - posted by "freeza1982@outlook.com" <fr...@outlook.com> on 2021/02/25 14:23:45 UTC, 0 replies.
- 回复: 升级kafka导致fink job失败 - posted by "freeza1982@outlook.com" <fr...@outlook.com> on 2021/02/25 14:24:33 UTC, 0 replies.
- Flink checkpoint恢复疑问 - posted by flink2021 <ye...@163.com> on 2021/02/26 01:33:30 UTC, 0 replies.
- 来自徐嘉培的邮件 - posted by 徐嘉培 <xu...@163.com> on 2021/02/26 02:03:32 UTC, 0 replies.
- flink版本：1.11.2，从kafka读取数据写到hdfs，运行一段时间报错 - posted by 史正超 <sh...@outlook.com> on 2021/02/26 02:39:09 UTC, 0 replies.
- flink1.12 执行sql_query()，同样的数据源表，pyflink执行时间9min，java执行3s - posted by xiaoyue <18...@163.com> on 2021/02/26 04:37:48 UTC, 0 replies.
- Flink SQL 应用情况请教 - posted by "yinghua_zh@163.com" <yi...@163.com> on 2021/02/26 06:36:47 UTC, 5 replies.
- 部署时Flink connector放置位置 - posted by automths <au...@163.com> on 2021/02/26 06:36:52 UTC, 0 replies.
- Re: [DISCUSS] Deprecation and removal of the legacy SQL planner - posted by Kurt Young <yk...@gmail.com> on 2021/02/26 06:54:14 UTC, 1 replies.
- 回复： flinksql集成hive权限管理 - posted by 阿华田 <a1...@163.com> on 2021/02/26 08:10:26 UTC, 0 replies.
- Re: Flink sql 1.12写入hive报metastore失败 - posted by will he <wo...@163.com> on 2021/02/26 08:50:18 UTC, 1 replies.
- Re:flink-Kafka 报错：ByteArraySerializer is not an instance of org.apache.kafka.common.serialization.Serializer - posted by felixzh <fe...@126.com> on 2021/02/26 09:42:02 UTC, 0 replies.
- 基于kafka中转数据流情况下，下游任务的watermark推进问题。 - posted by yidan zhao <hi...@gmail.com> on 2021/02/26 09:48:07 UTC, 1 replies.
- Flink checkpoint 速度慢问题请教 - posted by Jacob <17...@163.com> on 2021/02/27 06:14:58 UTC, 0 replies.
- 回复：Flink checkpoint 速度慢问题请教 - posted by 熊云昆 <xi...@163.com> on 2021/02/27 08:49:23 UTC, 0 replies.