问答 2024-08-28 来自:开发者社区

Flink 使用维表加在 MC 的数据 ,MC中的某条数据变更了,sql统计的逻辑会变更吗?

Flink 使用维表加在 MC 的数据 ,下面sql用到 这张表的数据,然后MC中的某条数据变更了,sql统计的逻辑会变更吗?

问答 2024-08-07 来自:开发者社区

在Flink为什么我的sql统计count的结果会有负数存在呢?

在Flink为什么我的sql统计count的结果会有负数存在呢?

阿里云文档 2024-07-11

Hologres+Flink如何进行实时UV精确去重

实时UV计算主要依赖Hologres与Flink结合完成,本文将为您介绍Hologres如何进行实时UV精确去重。

问答 2023-09-05 来自:开发者社区

Flink sql怎么按窗口先去重再统计?

Flink sql怎么按窗口先去重再统计?

问答 2023-08-20 来自:开发者社区

一个Flink SQl的job中,消费同一个kafka,使用滚动窗口计算每小时的统计,使用渐进式窗?

一个Flink SQl的job中,消费同一个kafka,使用滚动窗口计算每小时的统计,使用渐进式窗口计算零点到当前的统计;现在遇到一个问题:滚动窗口计算 需要设置 table.exec.emit.early-fire.enabled = true; table.exec.emit.early-fire.delay = 10000; 也就是每10秒去触发计算一次(因为页面要展示,不能每一个小时计算....

问答 2023-08-09 来自:开发者社区

Flink CDC中为啥单表的sql 批任务,统计的数据都和写sql统计的数据不一致的呢?

Flink CDC中为啥单表的sql 批任务,统计的数据都和写sql统计的数据不一致的呢?是bug还是操作不对?

问答 2023-08-09 来自:开发者社区

Flink CDC中为啥我用mysql sql 统计的数量,和用flink sql 统计的数量不一致

Flink CDC中为啥我用mysql sql统计的数量,和用flink sql 统计的数量不一致呢?

问答 2023-08-01 来自:开发者社区

问个小白问题:Flink SQL里,source读取kafka数据,然后根据orderId 统计总?

问个小白问题:Flink SQL里,source读取kafka数据,然后根据orderId 统计总量;我使用 SELECT COUNT(orderId) FROM source_table;的方式来计算总数;我的疑问点是,flink是如何处理这些source数据的,比如 kafka推过来 100W条的数据,都在 flink的内存里吗?

问答 2022-08-30 来自:开发者社区

请问flink sql里面统计窗口内的数据的时候,想去重取最新状态,应该怎么做

请问flink sql里面统计窗口内的数据的时候,想去重取最新状态,应该怎么做

问答 2022-08-24 来自:开发者社区

求助:在使用flink sql实时统计用户跨越时间较长比如一个月或两个月的指标数据时(数据从kafk

求助:在使用flink sql实时统计用户跨越时间较长比如一个月或两个月的指标数据时(数据从kafka读取),启动的时候往往有很大背压且时间很长。如果我想用DataStream的方式来处理,一般应该怎么实现呢,不用事件时间。大致实现方式是什么样呢?

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

产品推荐

阿里云实时计算Flink

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

+关注