You are viewing a plain text version of this content. The canonical link for it is here.
- 退订 - posted by Times Tang <ho...@163.com> on 2021/11/01 01:38:32 UTC, 12 replies.
- Re:Re: Re: 公司数据密文，实现group by和join - posted by lyh1067341434 <ly...@163.com> on 2021/11/01 02:42:34 UTC, 3 replies.
- Re:回复：Re:回复: flink sql消费kafka各分区消息不均衡问题 - posted by "casel.chen" <ca...@126.com> on 2021/11/01 02:47:44 UTC, 1 replies.
- standalone集群重启后自动回复任务，任务的jobmaster如果失败会导致JM进程失败 - posted by yidan zhao <hi...@gmail.com> on 2021/11/01 06:25:15 UTC, 1 replies.
- 关于FlinkSQL从kafka读取数据写到hive的一些问题 - posted by yidan zhao <hi...@gmail.com> on 2021/11/01 07:05:32 UTC, 4 replies.
- 关于窗口计算，数据不连续，导致窗口延迟触发的问题。 - posted by "yuankuo.xia" <en...@vip.qq.com> on 2021/11/01 09:20:27 UTC, 1 replies.
- New blog post published - Sort-Based Blocking Shuffle Implementation in Flink - posted by Daisy Tsang <da...@ververica.com> on 2021/11/01 10:24:30 UTC, 1 replies.
- flink yarn-per-job dubug - posted by GCAM <63...@qq.com.INVALID> on 2021/11/02 04:13:21 UTC, 0 replies.
- 创建表t1的视图v1之后rowtime属性丢失 - posted by yidan zhao <hi...@gmail.com> on 2021/11/02 11:05:41 UTC, 1 replies.
- FlinkSQL 使用 streamingSink 写入 hive orc数据，如何控制文件数量。 - posted by yidan zhao <hi...@gmail.com> on 2021/11/03 02:03:11 UTC, 8 replies.
- 回复：关于窗口计算，数据不连续，导致窗口延迟触发的问题。 - posted by "罗根(夕肆)" <lu...@alibaba-inc.com.INVALID> on 2021/11/03 07:13:11 UTC, 0 replies.
- flinkSQL写hive表，timestamp-pattern设置，分区是yyyyMMdd而不是yyyy-MM-dd的情况怎么搞。 - posted by yidan zhao <hi...@gmail.com> on 2021/11/04 03:46:14 UTC, 3 replies.
- 回复: 关于窗口计算，数据不连续，导致窗口延迟触发的问题。 - posted by wang edmond <ed...@hotmail.com> on 2021/11/04 05:33:03 UTC, 0 replies.
- flink 1.13.1 通过yarn-application运行批应用，处理mysql源一亿条数据到hive，发现需要配置16G+的Taskmangaer内存 - posted by Asahi Lee <97...@qq.com.INVALID> on 2021/11/04 07:52:14 UTC, 2 replies.
- Flink在下游算子没有idle的情况下自动产生背压 - posted by carryxyh <ca...@gmail.com> on 2021/11/04 08:50:25 UTC, 0 replies.
- Re: Flink没有Operator级别的数据量Metrics - posted by zhisheng <zh...@gmail.com> on 2021/11/04 08:56:29 UTC, 3 replies.
- Re: flink-yarn的pre-job模式 - posted by zhisheng <zh...@gmail.com> on 2021/11/04 08:58:04 UTC, 0 replies.
- Re: Re: 回复:回复:Re: 在开启checkpoint后如何设置offset的自动提交以方便监控 - posted by zhisheng <zh...@gmail.com> on 2021/11/04 09:00:04 UTC, 0 replies.
- flink on yarn 的pre_job提交失败,但是session模式可以成功 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/04 10:28:50 UTC, 1 replies.
- flink启动yarn-session失败 - posted by "casel.chen" <ca...@126.com> on 2021/11/04 10:42:15 UTC, 3 replies.
- 回复：flink on yarn 的pre_job提交失败,但是session模式可以成功 - posted by JasonLee <17...@163.com> on 2021/11/04 10:46:23 UTC, 0 replies.
- flink 1.14 Hybrid Source切换source时机问题 - posted by "casel.chen" <ca...@126.com> on 2021/11/05 00:39:35 UTC, 1 replies.
- flink1.12.1 读取kafka的数据写入到clickhouse如何支持upsert操作呢 - posted by 扯 <tz...@foxmail.com> on 2021/11/05 02:50:39 UTC, 1 replies.
- Tumbling Windows 窗口可开的最小单位 - posted by 李航飞 <te...@163.com> on 2021/11/05 04:32:00 UTC, 2 replies.
- flink广播流 - posted by 程俊超 <c_...@163.com> on 2021/11/05 11:46:18 UTC, 2 replies.
- 提交flink作业抛 java.lang.LinkageError - posted by "casel.chen" <ca...@126.com> on 2021/11/05 15:12:56 UTC, 2 replies.
- 小心你的flink作业正成为某些人的挖矿工具 - posted by "casel.chen" <ca...@126.com> on 2021/11/05 15:29:26 UTC, 1 replies.
- idea 导入编译报错，类似代码没有提交全 - posted by weiguangjin <we...@163.com> on 2021/11/07 04:26:42 UTC, 1 replies.
- Flink Sql读取Hbase表 - posted by guanyq <dl...@163.com> on 2021/11/07 08:15:46 UTC, 0 replies.
- 回复：Flink Sql读取Hbase表 - posted by "zstraw@163.com" <zs...@163.com> on 2021/11/07 11:30:34 UTC, 0 replies.
- 窗口时间不准 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/08 03:23:42 UTC, 1 replies.
- 取消订阅 - posted by lpf <li...@beyondsoft.com> on 2021/11/08 04:28:08 UTC, 4 replies.
- 回复： 窗口时间不准 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/08 06:34:47 UTC, 0 replies.
- flink的一个场景问题 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/08 06:40:20 UTC, 1 replies.
- checkpoint的路径问题 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/08 07:24:02 UTC, 2 replies.
- Flink1.12 Streaming 消费kafka - posted by guanyq <dl...@163.com> on 2021/11/08 08:55:50 UTC, 0 replies.
- 回复：Flink1.12 Streaming 消费kafka - posted by JasonLee <17...@163.com> on 2021/11/08 09:13:31 UTC, 0 replies.
- 回复: Re: 提交flink作业抛 java.lang.LinkageError - posted by WuKong <wu...@foxmail.com> on 2021/11/08 09:18:19 UTC, 3 replies.
- 回复: 取消订阅 - posted by WuKong <wu...@foxmail.com> on 2021/11/08 09:24:09 UTC, 1 replies.
- Flink SQL Join 如何使用minBatch 方式查询 - posted by WuKong <wu...@foxmail.com> on 2021/11/08 09:44:52 UTC, 2 replies.
- flinksql insert问题 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/08 10:52:09 UTC, 0 replies.
- flink1.12.4 写入hdfs报错 java.lang.OutOfMemoryError: Direct buffer memory - posted by xiao cai <fl...@163.com> on 2021/11/08 14:20:21 UTC, 1 replies.
- flink 1.13.2 在 Java/Scala 程序中调用 Python UDF函数，通过yarn-application执行，yarn集群的每台机器都需要安装pyflink? - posted by Asahi Lee <97...@qq.com.INVALID> on 2021/11/09 06:00:49 UTC, 2 replies.
- 求使用oracle jdk8的flink docker镜像Dockerfile - posted by "casel.chen" <ca...@126.com> on 2021/11/09 08:49:35 UTC, 1 replies.
- Could not start rest endpoint on any port in port range 8081报错，但是8081未占用啊 - posted by Geoff nie <ge...@163.com> on 2021/11/09 09:14:36 UTC, 0 replies.
- flink 1.12.1 写入hdfs 存在inProgress文件 - posted by jie han <ba...@gmail.com> on 2021/11/10 03:17:23 UTC, 0 replies.
- MongoDB sink - posted by 不许人间见白头 <da...@qq.com.INVALID> on 2021/11/10 14:28:30 UTC, 1 replies.
- flink 1.10 sql 读写 hive 2.1.0 - posted by liuyehan <ly...@163.com> on 2021/11/11 01:49:50 UTC, 1 replies.
- Re: flink 1.10 sql 读写 hive 2.1.0 - posted by yidan zhao <hi...@gmail.com> on 2021/11/11 02:06:06 UTC, 2 replies.
- flinksql 写 hive ，orc格式，应该支持下压缩。 - posted by yidan zhao <hi...@gmail.com> on 2021/11/11 04:37:31 UTC, 4 replies.
- flink new source api， kafka部分对kafka-client的版本要求。 - posted by yidan zhao <hi...@gmail.com> on 2021/11/11 07:22:22 UTC, 1 replies.
- flinksql sink写csv小文件问题 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/11 08:50:19 UTC, 1 replies.
- FlinkSQL 1.12 Temporal Joins 多表关联问题 - posted by WuKong <wu...@foxmail.com> on 2021/11/11 09:42:11 UTC, 0 replies.
- Flinksql 多表进行full join 出现异常 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/11 13:43:50 UTC, 2 replies.
- Flink jdbc Connector 特殊类型问题 - posted by Ada Luna <gf...@gmail.com> on 2021/11/12 03:23:14 UTC, 4 replies.
- Re: FlinkSQL 1.12 Temporal Joins 多表关联问题 - posted by Caizhi Weng <ts...@gmail.com> on 2021/11/12 03:32:30 UTC, 3 replies.
- 回复： Flinksql 多表进行full join 出现异常 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/12 04:07:00 UTC, 4 replies.
- 检查点和保存点 - posted by lei-tian <to...@163.com> on 2021/11/12 08:13:07 UTC, 1 replies.
- 请求帮助 - posted by sky <su...@qq.com.INVALID> on 2021/11/12 12:59:59 UTC, 2 replies.
- flink on native k8s application模式作业启动慢问题 - posted by "casel.chen" <ca...@126.com> on 2021/11/13 00:46:36 UTC, 1 replies.
- flink on native k8s资源弹性伸缩问题 - posted by "casel.chen" <ca...@126.com> on 2021/11/13 00:52:28 UTC, 1 replies.
- flink sql检查点是否可恢复问题 - posted by "casel.chen" <ca...@126.com> on 2021/11/13 01:00:52 UTC, 2 replies.
- 回复： flink 触发保存点失败 - posted by 仙剑……情动人间 <15...@qq.com.INVALID> on 2021/11/13 04:27:14 UTC, 0 replies.
- Flink资源动态分配 - posted by 疾鹰击皓月 <17...@qq.com.INVALID> on 2021/11/15 07:41:03 UTC, 1 replies.
- flink on native k8s调度控制 - posted by "casel.chen" <ca...@126.com> on 2021/11/15 10:25:00 UTC, 1 replies.
- io.tmp.dirs的配置如何做到高可用？ - posted by 鲁成祥 <97...@qq.com.INVALID> on 2021/11/15 12:30:13 UTC, 1 replies.
- Flink工程停止问题 - posted by 疾鹰击皓月 <17...@qq.com.INVALID> on 2021/11/16 06:56:27 UTC, 4 replies.
- FlinkSQL写hive orc表开启compact，任务异常重启，compact不生效？ - posted by yidan zhao <hi...@gmail.com> on 2021/11/16 09:36:07 UTC, 4 replies.
- flink sql建表异常问题 - posted by "18765295908@163.com" <18...@163.com> on 2021/11/17 06:01:06 UTC, 1 replies.
- 回复: flink sql建表异常问题 - posted by aiden <18...@163.com> on 2021/11/17 06:34:03 UTC, 0 replies.
- 如何添加source保障程序状态不丢 - posted by 杨浩 <ya...@163.com> on 2021/11/17 06:56:37 UTC, 1 replies.
- 回复:如何添加source保障程序状态不丢 - posted by 杨浩 <ya...@163.com> on 2021/11/17 09:58:40 UTC, 0 replies.
- 在进行table转streaming后报一个异常 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/17 11:44:22 UTC, 1 replies.
- flink的sql写hdfs如何指定文件名称 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/18 03:47:41 UTC, 1 replies.
- flink的job运行一段时间后， checkpoint就一直失败 - posted by "yukai@kiscloud.net" <yu...@kiscloud.net> on 2021/11/18 06:54:07 UTC, 1 replies.
- 哪里可以下载到downloads/setup-pyflink-virtual-env.sh脚本 - posted by Asahi Lee <97...@qq.com.INVALID> on 2021/11/18 07:05:03 UTC, 4 replies.
- Re:FlinkSQL ES7连接器无法使用 - posted by mispower <mi...@163.com> on 2021/11/18 09:25:49 UTC, 2 replies.
- flink1.13.1 sql client connect hivecatalog 报错 - posted by drewfranklin <dr...@163.com> on 2021/11/18 10:01:15 UTC, 5 replies.
- inStreamingMode和inBatchMode打印内容不同产生的疑惑 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/18 12:01:43 UTC, 1 replies.
- 回复：哪里可以下载到downloads/setup-pyflink-virtual-env.sh脚本 - posted by Asahi Lee <97...@qq.com.INVALID> on 2021/11/18 13:00:10 UTC, 0 replies.
- 回复： flink1.13.1 sql client connect hivecatalog 报错 - posted by drewfranklin <dr...@163.com> on 2021/11/18 13:40:42 UTC, 0 replies.
- flink job进行cancel后kafka producer报错 - posted by "yukai@kiscloud.net" <yu...@kiscloud.net> on 2021/11/19 02:01:11 UTC, 0 replies.
- 回复： 哪里可以下载到downloads/setup-pyflink-virtual-env.sh脚本 - posted by Asahi Lee <97...@qq.com.INVALID> on 2021/11/19 02:47:48 UTC, 2 replies.
- SQL解析疑惑 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/19 08:10:47 UTC, 0 replies.
- Flink1.14 table api GroupBy Window Aggregation - posted by guanyq <dl...@163.com> on 2021/11/20 10:45:25 UTC, 1 replies.
- 关于TableAPI的filesystem中compact功能 - posted by yidan zhao <hi...@gmail.com> on 2021/11/20 12:15:49 UTC, 3 replies.
- jdk11创建hive catalog抛错 - posted by aiden <18...@163.com> on 2021/11/22 04:00:07 UTC, 1 replies.
- 回复：flink1.13.1 sql client connect hivecatalog 报错 - posted by zhiyuan su <zh...@gmail.com> on 2021/11/22 05:14:13 UTC, 2 replies.
- 如何实现event triggered window？ - posted by Pinjie Huang <pi...@afterpay.com.INVALID> on 2021/11/22 07:51:21 UTC, 9 replies.
- 询问下Flink分布式缓存的问题 - posted by anig kus <an...@gmail.com> on 2021/11/22 09:39:19 UTC, 0 replies.
- flink1.12 请教下如何配置多hadoop参数，s3使用问题 - posted by RS <ti...@163.com> on 2021/11/22 11:13:11 UTC, 0 replies.
- 关于flink plugins目录不生效的疑问 - posted by RS <ti...@163.com> on 2021/11/23 02:14:19 UTC, 0 replies.
- flink1.12 请教下如何配置state.checkpoints.num-retained不生效的问题 - posted by 黑暗使者 <44...@qq.com.INVALID> on 2021/11/23 03:59:03 UTC, 0 replies.
- stop命令保存点成功，任务停止不了，这种情况强制停任务是安全的吗？ - posted by yidan zhao <hi...@gmail.com> on 2021/11/23 11:00:18 UTC, 0 replies.
- 空指针异常 - posted by 陈卓宇 <25...@qq.com.INVALID> on 2021/11/23 12:28:35 UTC, 2 replies.
- Re:PartitionNotFoundException - posted by "casel.chen" <ca...@126.com> on 2021/11/23 15:13:25 UTC, 0 replies.
- FlinkSQL源码分段优化中，物理计划转换为ExecNodeGraph的时候，SameRelObjectShuttle、SubplanReuseShuttle一拆一合目的是啥 - posted by 岳晗 <yu...@qq.com.INVALID> on 2021/11/24 07:52:23 UTC, 1 replies.
- 检查点的start-delay、alignment duration理解。 - posted by yidan zhao <hi...@gmail.com> on 2021/11/24 11:02:39 UTC, 3 replies.
- FlinkSql回撤流 - posted by wushijjian5 <ws...@163.com> on 2021/11/24 13:04:48 UTC, 5 replies.
- Re: Flink HIve 文件压缩报错 - posted by yidan zhao <hi...@gmail.com> on 2021/11/25 03:13:40 UTC, 0 replies.
- flink cancel和stop的区别。 - posted by yidan zhao <hi...@gmail.com> on 2021/11/25 03:16:16 UTC, 0 replies.
- keyed state重新指定并行度后，比如2->4或者4->2，请问下是不是会丢失部分老的状态？ - posted by 杨浩 <ya...@163.com> on 2021/11/25 09:30:05 UTC, 1 replies.
- 怎么样构建模拟一些数据倾斜，各类算子反压的场景 - posted by drewfranklin <dr...@163.com> on 2021/11/25 09:31:07 UTC, 0 replies.
- flink rest 端口是通过什么方法进行认证的 - posted by Mabin <ma...@163.com> on 2021/11/26 02:25:35 UTC, 1 replies.
- flink远程调用时环境变量问题 - posted by 王健 <13...@163.com> on 2021/11/26 02:59:40 UTC, 3 replies.
- 回复： flink远程调用时环境变量问题 - posted by 王健 <13...@163.com> on 2021/11/26 03:14:17 UTC, 1 replies.
- 回复：flink远程调用时环境变量问题 - posted by liuyehan <ly...@163.com> on 2021/11/26 03:18:10 UTC, 1 replies.
- FlinkSQL kafka2hive每次检查点导致任务失败 - posted by yidan zhao <hi...@gmail.com> on 2021/11/26 03:18:24 UTC, 2 replies.
- flink DAY_INTERVAL_TYPES precision is not support:4 - posted by Hui Wang <46...@qq.com.INVALID> on 2021/11/26 03:30:43 UTC, 0 replies.
- 【flink1.12.1版本如何确认minibatch功能已开启】 - posted by lian <lz...@126.com> on 2021/11/26 04:51:17 UTC, 0 replies.
- 回复：Flink kafka自定义metrics在influxdb上解析失败 - posted by 信华哺 <la...@163.com> on 2021/11/26 09:22:19 UTC, 1 replies.
- Time attribute will be lost after two(or more) table joining - posted by Pinjie Huang <pi...@afterpay.com.INVALID> on 2021/11/29 02:43:57 UTC, 1 replies.
- 回复： Flink工程停止问题 - posted by JasonLee <17...@163.com> on 2021/11/29 03:38:02 UTC, 0 replies.
- no more slot 这种错误是啥情况，slot肯定足够。 - posted by yidan zhao <hi...@gmail.com> on 2021/11/29 06:54:25 UTC, 1 replies.
- How to run SQL Client by Per-Job - posted by wa...@163.com on 2021/11/29 10:48:07 UTC, 1 replies.
- Flink1.13.3 on Native K8s 任务取消问题 - posted by 研发-江志洋 <ej...@foxmail.com> on 2021/11/29 11:23:41 UTC, 1 replies.
- Flink1.13.3 on Native K8s 任务取消问题 - posted by 研发-江志洋 <ej...@foxmail.com> on 2021/11/29 11:39:24 UTC, 1 replies.
- Flink1.13.3 on Native K8s 任务问题 - posted by 研发-江志洋 <51...@qq.com.INVALID> on 2021/11/29 11:54:20 UTC, 0 replies.
- Flink web ui job overwrite 不显示算子接收数据条数 - posted by drewfranklin <dr...@163.com> on 2021/11/29 12:14:01 UTC, 1 replies.
- 关于flink on yarn 跨多hdfs集群访问的问题 - posted by chenqizhu <qi...@163.com> on 2021/11/30 01:53:00 UTC, 1 replies.
- flink web UI job overview 中的算子记录条数不更新 - posted by zhiyuan su <zh...@gmail.com> on 2021/11/30 02:08:39 UTC, 1 replies.
- flink on k8s 使用OSS作为backend遇到的业务数据丢失问题 - posted by 赵旭晨 <jj...@163.com> on 2021/11/30 04:04:12 UTC, 0 replies.
- flink web ui job overview 无法显示算子接收到的数据条数 - posted by su wenwen <zh...@outlook.com> on 2021/11/30 06:49:53 UTC, 0 replies.
- [ANNOUNCE] Open source of remote shuffle project for Flink batch data processing - posted by Yingjie Cao <ke...@gmail.com> on 2021/11/30 13:32:20 UTC, 1 replies.
- flink sql group by后收集数据问题 - posted by "casel.chen" <ca...@126.com> on 2021/11/30 23:56:35 UTC, 0 replies.
- flink sql ROW()语句中是不是不能再使用case when？ - posted by "casel.chen" <ca...@126.com> on 2021/11/30 23:59:40 UTC, 0 replies.