Hi, fengqi.
这看起来像是select语句中,不能直接使用非来源于window
agg的proctime或者event函数。目前不确定这是不是预期行为,方便的话可以在社区jira[1]上提一个bug看看。
快速绕过的话,可以试试下面的代码:
DataStream flintstones = env.fromCollection(list); // Table select =
table.select($("name"), $("age"), $("addtime").proctime()); Table table =
tEnv.fromDataStream( fli
在非窗口化的表上使用窗口属性
At 2024-03-08 09:28:10, "ha.fen...@aisino.com" wrote:
>public static void main(String[] args) {
>StreamExecutionEnvironment env =
> StreamExecutionEnvironment.getExecutionEnvironment();
>StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
>List
public static void main(String[] args) throws Exception {
StreamExecutionEnvironment env =
StreamExecutionEnvironment.getExecutionEnvironment();
StreamTableEnvironment tEnv = StreamTableEnvironment.create(env);
List list = new ArrayList<>();list.add(new
Person("Fred",35));