Flink Window TOPN: The window can only be ordered in ASCENDING mode.

先看报错信息：

Exception in thread "main" org.apache.flink.table.api.TableException: The window can only be ordered in ASCENDING mode

再看代码：

Table table = tEnv.sqlQuery("select *," +"ROW_NUMBER() OVER (PARTITION BY window_start, window_end ORDER BY cnt DESC) as rownum" +" from (" +"select window_start, window_end, id, count(status) as cnt from TABLE(CUMULATE(TABLE KafkaSourceTable, DESCRIPTOR(event_time), INTERVAL '30' SECOND, INTERVAL '2' MINUTES)) group by window_start, window_end, id" +")");

第一次运行把最外层的取前N的代码去掉了，想着看看如果不取前N的话，运行结果是怎样的，结果就报了上面的错误，这个时候一直不知道是什么问题导致的，也没找到底层的根本原因。

抱着尝试的心态，加上了最外层代码，再去尝试的时候发现不报错了，可以正常运行，但不清楚为什么去掉最外层不取TOPN就报错呢？大佬们，有清楚的感谢指点一二。

Table table = tEnv.sqlQuery("select * from (select *," +"ROW_NUMBER() OVER (PARTITION BY window_start, window_end ORDER BY cnt DESC) as rownum" +" from (" +"select window_start, window_end, id, count(status) as cnt from TABLE(CUMULATE(TABLE KafkaSourceTable, DESCRIPTOR(event_time), INTERVAL '30' SECOND, INTERVAL '2' MINUTES)) group by window_start, window_end, id" +")" +") where rownum <= 3");

Flink Window TOPN: The window can only be ordered in ASCENDING mode.相关推荐

项目案例：Flink1.14 SQL实现Window TOPN
摘要: 在Flink1.13版本中,提出了窗口表值函数(Window TVF)的实现,用于替代旧版的窗口分组(group window)语法,极大简化了Flink SQL代码量,同时提高了执行性能. ...
【Flink实战系列】Flink SQL 之 Session Window 的用法
Flink SQL 之 Session Window 的用法 Session Windows 会话窗口分配器按活动的会话对元素进行分组.与翻滚窗口和滑动窗口相比,会话窗口没有重叠,也没有固定的开始和结 ...
Flink教程（11）- Flink高级API（Window）
文章目录 01 引言 02 Window 2.1 为什么需要Window? 2.2 Window分类 2.2.1 按照time和count分类 2.2.2 按照slide和size分类 2.2.3 总 ...
if(window.event) e = window.event
浏览器事件对象兼容 function func(e){ if(window.event){ e = window.event; } } 浏览器中的事件都是以对象的形式存在的,IE浏览器与标准DOM浏览 ...
js操作frame详细解说,window.opener和window.parent的区别
js操作frame详细解说,window.opener和window.parent的区别 frame框架里的页面要改其他同框架下的页面或父框架的页面就用parent window.opener引用的是 ...
总结JavaScript(Iframe、window.open、window.showModalDialog)父窗口与子窗口之间的操作
前些日子,一直奔波于这三种操作,想想以后会常用,干脆整理下来,供自己以后查看.也给大家分享一下! 以下面写出自己认为有用的操作和代码. 第一次在园里面写,肯定有很多不足够之处,希望大家多多指点. 一. ...
自己使用window.open和window.showModalDialog在父子窗口传值的实践简单总结
朋友最近问我一个问题:子窗口添加数据并返回给父窗口一些添加成功的数据,同时父窗口刷新显示添加前的页面.相比很多人都相当熟知了,顺便记录一下: ==========================win ...
window.open和window.showModalDialog用法
View Code window.open和window.showModalDialog用法2008/06/18 14:16一.window.open()支持环境: JavaScript1.0+/JS ...
window.atob()与window.btoa()方法实现编码与解码
转载于https://www.cnblogs.com/moqiutao/p/6280099.html 文章目录 window.atob() 与window.btoa() Unicode 字符串 dec ...
window.parent和window.opener区别
下面一段代码是关于window.parent和window.opener区别来讲的,我们如果要用到iframe的值传到另一框架就要用到window.opener.document.getElemen ...

Flink Window TOPN: The window can only be ordered in ASCENDING mode.

Flink Window TOPN: The window can only be ordered in ASCENDING mode.相关推荐

最新文章

热门文章