apache-flink - org.apache.flink.table.api.TableException: 结果的 Arity [3] 与请求类型的 number[2] 不匹配
问题描述
我有一个简单的测试用例来学习如何使用 Table API 和 case/when,如下所示:
import org.apache.flink.api.scala.ExecutionEnvironment
import org.apache.flink.table.api.TableEnvironment
import org.apache.flink.api.scala._
case class Person(name: String, age: Int)
object TableTest {
def main(args: Array[String]): Unit = {
val env = ExecutionEnvironment.getExecutionEnvironment
val te = TableEnvironment.getTableEnvironment(env)
val ds = env.fromCollection(Seq(Person("a",20), Person("b",40), Person("c", 60)))
te.registerDataSet("person", ds)
te.toDataSet[Person](table).print()
val table = te.sqlQuery(
"""
select name,age,
case
when age <= 20 then 'A'
when age <=40 then 'B'
when age <= 60 then 'C'
else 'D'
end as age_level
from person
""".stripMargin(' '))
te.toDataSet[Person](table).print()
}
}
运行时遇到如下异常,age_level
是计算列,不知道为什么会报错
Exception in thread "main" org.apache.flink.table.api.TableException: Arity [3] of result [ArrayBuffer(String, Integer, String)] does not match the number[2] of requested type [com.flink.table.Person(name: String, age: Integer)].
at org.apache.flink.table.api.TableEnvironment.generateRowConverterFunction(TableEnvironment.scala:1165)
at org.apache.flink.table.api.BatchTableEnvironment.getConversionMapper(BatchTableEnvironment.scala:339)
at org.apache.flink.table.api.BatchTableEnvironment.translate(BatchTableEnvironment.scala:504)
at org.apache.flink.table.api.BatchTableEnvironment.translate(BatchTableEnvironment.scala:476)
at org.apache.flink.table.api.scala.BatchTableEnvironment.toDataSet(BatchTableEnvironment.scala:141)
at com.flink.table.TableTest$.main(TableTest.scala:37)
at com.flink.table.TableTest.main(TableTest.scala)
解决方案
问题是要转换为 a 的表DataSet[Person]
有三个属性:(name, age, age_level)
而Person
case 类只有两个字段:(name, age)
.
你可以实现一个新的案例类
case class PersonWithAgeLevel(name: String, age: Int, age_level: String)
并将表格转换为DataSet[PersonWithAgeLevel]
.
推荐阅读
- python-3.x - Python替换字典中的值(在类对象中设置)失败:TypeError:'annotation'对象不支持项目分配
- javascript - 如何在材质 UI 文本字段中格式化日期?
- javascript - 输入重复字符时文本区域溢出文本
- visual-studio - 在 Visual Studio 2010 中为我的项目创建安装程序后缺少 dll 错误
- javascript - 如何处理以错误顺序调用的多个 setState?
- apache-spark - 在 Google Colab 中使用图框
- python - 如何根据一列重新采样 df 并添加另一列的值?
- javascript - 有没有办法在一个立方体上有两个图像?
- mysql - 从一年中的每个月选择注册用户数,但更改时间戳的值会导致错误的计数
- sql - 如何在sql中使用解码部分数字