Flink TableAPI 中后续的窗口化分组导致 RuntimeException

问题描述

我正在开发一个使用 Apache Flink 的 Table API (1.12.0) 对图形流进行分组/汇总的项目。在我们的算法中，我们首先处理顶点，即对它们进行分组并聚合一些属性。这是我的应用程序的片段：

Table table1 = vertices
    .window(Tumble.over(lit(10).seconds()).on($(EVENT_TIME)).as("w1"))
    .groupBy($(ID),$(LABEL),$("w1"))
    .select($(ID),$("w1").rowtime().as("w1_rowtime"));

// table1.execute().print(); --> works well

// 2. Group vertices by label and/or property values
Table table2 = table1
   .window(Tumble.over(lit(10).seconds()).on($("w1_rowtime")).as("w2"))
   .groupBy($(LABEL),$("w2"))
   .select(
       $(LABEL).as("super_label"),lit(1).count().as("super_count"),$("w2").rowtime().as("w2_rowtime"));

// table2.execute().print(); --> works well

table2.select($("super_label"),$("w2_rowtime"))
  .execute().print(); // --> throws exception

第一个窗口分组是删除重复项，因为多个边可以具有相同的源/目标顶点（即相同的 id、标签等）和不同的时间戳（时间戳从边获取）。第二个分组用于按给定的配置对不同的顶点进行分组并聚合其值。

问题：当我在后续步骤中使用 groupedVertices 时，例如只是投影（请参阅我剪下的最后几行），我收到以下异常（请参阅评论中的 Jira 问题）。别名 w1_rowtime 似乎不再“注册”了。

有没有人知道这种情况的解决方案或解决方法？

解决方法

暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！

如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@）