问答 2024-06-12 来自:开发者社区

Flink滚动统计一分钟内用户不重复的总数,这个函数怎么写呀?

Flink滚动统计一分钟内用户不重复的总数,这个函数怎么写呀,count(distinct(username))?

文章 2024-05-16 来自:开发者社区

实时计算 Flink版产品使用合集之可以配置滚动生成tm.err和tm.out文件吗

问题一:Flink版本升级完成了吗?我还没看到8.0.2 Flink版本升级完成了吗?我还没看到8.0.2 参考回答: 没有8.0.2 直接8.0.3 了。11.16 发完。 关于本问题的更多回答可点击原文查看:https://developer.aliyun.com/ask/572550 问题二:Flink现在普罗...

实时计算 Flink版产品使用合集之可以配置滚动生成tm.err和tm.out文件吗

基于阿里云Hologres&Flink实时计算平台搭建数据仓库(实时)

23 课时 |
320 人已学 |
免费

实时数据分析:使用Flink实时发现最热Github项目

1 课时 |
950 人已学 |
免费

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
515 人已学 |
免费
开发者课程背景图
文章 2024-05-16 来自:开发者社区

实时计算 Flink版产品使用合集之 Flink on YARN 中使用滚动日志时配置不生效如何解决

问题一:求问大家 ,flinksql 在idea调试都没问题 窗口触发都能出结果 ,部署到集群上就没反应了? 求问大家 ,flinksql 在idea调试都没问题 窗口触发都能出结果 ,部署到集群上就没反应了, 查看日志有数据数据读取到 就发不出去发kafka 。 就算使用无窗口sql select* 也发不出去数据 。版本是1.16 有没有人遇到类问题 。 ...

实时计算 Flink版产品使用合集之 Flink on YARN 中使用滚动日志时配置不生效如何解决
问答 2024-05-01 来自:开发者社区

Flink CDC里oracle上要开启归档日志,否则无法cdc,这个怎么处理?

Flink CDC里oracle上要开启归档日志,否则无法cdc,并且开启这个之后,对实际oracle是有很大性能影响,特别是事务。所以oracle cdc在生产环境是无法使用了,没有实际应用价值,测试玩玩也就可以了。这个问题我很早就在群里提出了flink cdc还存在其他的生产环境问题,其一,一般生产环境mysql的binlog会开启滚动日志,也就是为了节省空间,会删除掉之前的binlog,由....

问答 2024-03-11 来自:开发者社区

Flink CDC 里flink1.18滚动窗口不打印是什么情况?

Flink CDC 里flink1.18滚动窗口不打印是什么情况?我直接select kafkaTable是有打印的,窗口统计就没有打印是为什么?

问答 2024-02-01 来自:开发者社区

Flink CDC里我一执行滚动开窗,就报下面的错误怎么解决?

Flink CDC里就是消费kafka中的debezium-json格式数据,使用滚动窗口统计1分钟新增的数据量,这个简单的需求,被卡住了。之前一直写的datastream,现在想用flink sql来实现我本来就是消费的kafka数据,为什么还要推到kafka里面?我现在数据源是kafka,kafka中的数据是flink cdc同步到kafka中的,数据有更新,有插入。 // 源...

文章 2024-01-07 来自:开发者社区

Flink sql滚动窗口怎么操作能实现stream里的allowlateness?

【1月更文挑战第3天】【1月更文挑战第12篇】 Flink sql滚动窗口怎么操作能实现stream里的allowlateness? 要对接OpenSearch LLM智能问答到钉钉机器人,首先需要在智能问答版控制台中创建一个接入点。点击生态对接->创建,生态平台选择钉钉企业内部机器人或钉钉自定义机器人。然后,需要按要求填入接入点名称...

问答 2024-01-04 来自:开发者社区

Flink sql滚动窗口怎么操作能实现stream里的allowlateness?

Flink sql滚动窗口怎么操作能实现stream里的allowlateness?

问答 2023-11-30 来自:开发者社区

请教下,flink on yarn中在flink conf目录下的中配置的滚动日志,为啥不生效?

请教下,flink on yarn中在flink conf目录下的log4j.properties中配置的滚动日志,为啥不生效?

问答 2023-11-22 来自:开发者社区

Flink可以配置滚动tm.err和tm.out文件吗?

Flink可以配置滚动tm.err和tm.out文件吗?业务经常写满机器磁盘

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注