• 关于

    flink sql 窗口

    的搜索结果

回答

我有个问题想请教一下 我使用的Flink sql 1.9.1 在测试的发现,当窗口数量有4个或者5个时候开始触发窗口计算,当触发窗口计算之后会保留三个窗口,触发其余的窗口,每当新创建一个窗口,就会触发一个之前的窗口,当我没有...
黄一刀 2020-06-15 19:55:24 1 浏览量 回答数 1

回答

40.Flink SQL在使用Groupby时出现热点数据&xff0c;如何处理&xff1f;41.Flink任务&xff0c;delay极高&xff0c;请问你有什么调优策略&xff1f;42.Flink是如何处理反压的&xff1f;和Spark有什么区别&xff1f;Storm呢&xff1f;43....
茶什i 2019-12-01 22:02:36 263 浏览量 回答数 0

回答

Flink 中默认窗口有哪些Flink 中数据进入窗口流程是怎样的Flink 窗口触发器是什么Flink 窗口触发器&xff08;Trigger&xff09;有哪些状态&xff1f;Flink 窗口过滤器&xff08;Evictor&xff09;作用是什么Flink 内置窗口过滤器&...
一人吃饱,全家不饿 2021-01-08 15:32:13 1901 浏览量 回答数 2

回答

请教一个与Flink SQL的事件时间和watermark的场景&xff1a;读入kafka流的时候水位设置为&xff1a;WATERMARK FOR ts AS ts-INTERVAL&39;20&39;SECOND 聚合的时候&xff0c;时间窗口是一分钟&xff1a;GROUP BY TUMBLE(ts,...
黄一刀 2020-08-21 21:28:00 2 浏览量 回答数 1

回答

12月17日更新 请问下同时消费多个topic的情况下&xff0c;在richmap里面可以获取到当前消息所属的topic吗&xff1f;各位大佬&xff0c;你们实时都是怎样重跑数据的?...flink sql目前是不是不支持tumbling window join&xff0...
问问小秘 2019-12-02 03:19:17 0 浏览量 回答数 0

回答

发现这一周checkpoint size在不断增加 6、flink sql 支持trigger么&xff1f;EMIT这个aliyun有 开源版本好像没有这个语法命令 7、flink 的timewindow设置为24小时一天的话&xff0c;怎么在第二天0点自动重新计算 8、请教下...
黄一刀 2020-05-19 17:51:47 11230 浏览量 回答数 2

回答

使用flink-sql。想写一个Table的自定义UDAF&xff0c;在UDAF中使用State存储上一分钟的最高温度&xff0c;但是发现UDAF的open函数的FunctionContext中对于RuntimeContext是一个private&xff0c;无法使用&xff0c;同时&xff0c;...
黄一刀 2019-12-01 21:57:25 49 浏览量 回答数 1

回答

使用flink-sql。想写一个Table的自定义UDAF&xff0c;在UDAF中使用State存储上一分钟的最高温度&xff0c;但是发现UDAF的open函数的FunctionContext中对于RuntimeContext是一个private&xff0c;无法使用&xff0c;同时&xff0c;...
黄一刀 2019-12-01 21:57:24 28 浏览量 回答数 1

回答

大家有没有在flink SQL中遇到过这种情况&xff0c;比如现在用滚动窗口&xff0c;在case when 中使用时间字段&xff0c;例如create_time和TUMBLE_START以及TUMBLE_END比较的&xff1f;我现在在select后面使用create_time和TUMBLE_...
茶什i 2019-12-01 21:50:55 17 浏览量 回答数 0

回答

使用ROW_NUMBER()去重&xff0c;key值会保留多久&xff1f;会一直等到下一个key数据出现吗&xff1f;还是需要在sql中设定一个时间窗口&xff1f;Flink
黄一刀 2020-07-26 21:02:31 3 浏览量 回答数 1

回答

军长:为啥不直接用join呢,比如这里:https://ci.apache.org/projects/flink/flink-docs-master/dev/table/tableApi.html#joins问:因为我有几个指标需要用到sql api的TUMBLE窗口,不知道表join的话 还能不能用啊...
赵慧 2019-12-02 01:56:01 0 浏览量 回答数 0

回答

大家好,我有个业务场景&xff0c;就是统计近7天的 每个用户vid 所对应的 所有搜索词searchterm&xff0c;如果我用时间窗口去做&xff0c;就会7天7天出来一个统计结果&xff0c;有没有办法实时出结果的 sql聚合 写法&xff1a;Flink
黄一刀 2020-07-16 14:11:51 2 浏览量 回答数 1

回答

概念窗口函数:Group Window Aggregation 是一种在窗口上的聚合。Group Window Aggregation 是每个窗口结束发出一条结果数据(无early fire时),有点类似 micro batch。最常见的是几种时间窗口,如 TUMBLE(滚动...
李博 bluemind 2019-12-01 20:27:19 884 浏览量 回答数 1

回答

flink/blink sql 执行count操作&xff0c;得到的结果进行了多次计算&xff0c;之前本来没有这问题的&xff0c;后来不懂什么时候开始就有这问题了。看图片&xff0c;大概就是10min的sql翻转窗口执行count操作&xff0c;数据不停的往...
Assassinxc 2019-12-01 19:52:28 93 浏览量 回答数 1

回答

flinksql读取kafka数据用滑动窗口&xff08;窗口长度是7天&xff0c;滑动时长是1秒&xff09;的聚合操作最后输出&xff0c;然后读取kafka的表设置&39;connector.startup-mode&39;61;39;earliest-offset&39;...DAY)#Flink
黄一刀 2020-07-17 15:00:37 0 浏览量 回答数 1

回答

这在BatchTable中工作正常,但它在StreamTable中不起作用:Exception in thread"main"org.apache.flink.table.api.ValidationException:TumblingGroupWindow('w,'rowtime,300000.millis)is invalid:Tumbling window ...
flink小助手 2019-12-01 19:23:57 1564 浏览量 回答数 1

回答

flink-SQL Table API和SQL捆绑在flink-table Maven工件中。必须将以下依赖项添加到你的项目才能使用Table API和SQL&xff1a;org.apache.flink flink-table_2.11 1.5.0 另外&xff0c;你需要为Flink的Scala批处理或流式API...
凹凹凸曼 2020-06-16 19:23:12 0 浏览量 回答数 0

回答

支持对Storm、Spark Streaming、Flink等计算系统消费延迟监控与告警。Logtail&xff1a;采集目录支持通配符模式&xff08;参见文档&xff09;xff1a;日志采集目录支持通配符模式&xff0c;便于用户以更细的粒度、更加灵活的方式...
轩墨 2019-12-01 21:50:57 1618 浏览量 回答数 0

回答

SQL&xff0c;主被同步&xff0c;读写分离等都可能是你学的时候要了解到的。上面我们提到了安全&xff0c;不要把鸡蛋放一个篮子的道理大家应该都知道&xff0c;那分库的意义就很明显了&xff0c;然后你会发现时间久了表的数据大了&...
剑曼红尘 2020-03-06 11:35:37 0 浏览量 回答数 0

云产品推荐

视频直播 大数据计算服务 MaxCompute 国内短信套餐包 ECS云服务器安全配置相关的云产品 开发者问答 阿里云建站 新零售智能客服 万网 小程序开发制作 视频内容分析 视频集锦 代理记账服务 阿里云AIoT 阿里云科技驱动中小企业数字化