xxxx is not found in PojoType＜Order, fields = [amount: Integer, product: String, user: Long]＞

代码如下:

Table orders = tEnv.from("Orders");
Table result = orders.select($("product"), $("user"),$("amount").as("total"));
tEnv.toAppendStream(result, Order.class).print();
env.execute();

完整报错如下:

Exception in thread "main" org.apache.flink.table.api.TableException: total is not found in PojoType<Order, fields = [amount: Integer, product: String, user: Long]>at org.apache.flink.table.planner.sinks.TableSinkUtils$.$anonfun$expandPojoTypeToSchema$1(TableSinkUtils.scala:263)at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)at scala.collection.Iterator.foreach(Iterator.scala:937)at scala.collection.Iterator.foreach$(Iterator.scala:937)at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)at scala.collection.IterableLike.foreach(IterableLike.scala:70)at scala.collection.IterableLike.foreach$(IterableLike.scala:69)at scala.collection.AbstractIterable.foreach(Iterable.scala:54)at scala.collection.TraversableLike.map(TraversableLike.scala:233)at scala.collection.TraversableLike.map$(TraversableLike.scala:226)at scala.collection.AbstractTraversable.map(Traversable.scala:104)at org.apache.flink.table.planner.sinks.TableSinkUtils$.expandPojoTypeToSchema(TableSinkUtils.scala:260)at org.apache.flink.table.planner.sinks.TableSinkUtils$.inferSinkPhysicalSchema(TableSinkUtils.scala:240)at org.apache.flink.table.planner.delegation.PlannerBase.translateToRel(PlannerBase.scala:258)at org.apache.flink.table.planner.delegation.PlannerBase.$anonfun$translate$1(PlannerBase.scala:163)at scala.collection.TraversableLike.$anonfun$map$1(TraversableLike.scala:233)at scala.collection.Iterator.foreach(Iterator.scala:937)at scala.collection.Iterator.foreach$(Iterator.scala:937)at scala.collection.AbstractIterator.foreach(Iterator.scala:1425)at scala.collection.IterableLike.foreach(IterableLike.scala:70)at scala.collection.IterableLike.foreach$(IterableLike.scala:69)at scala.collection.AbstractIterable.foreach(Iterable.scala:54)at scala.collection.TraversableLike.map(TraversableLike.scala:233)at scala.collection.TraversableLike.map$(TraversableLike.scala:226)at scala.collection.AbstractTraversable.map(Traversable.scala:104)at org.apache.flink.table.planner.delegation.PlannerBase.translate(PlannerBase.scala:163)at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.toDataStream(StreamTableEnvironmentImpl.java:331)at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.toAppendStream(StreamTableEnvironmentImpl.java:292)at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.toAppendStream(StreamTableEnvironmentImpl.java:283)at Select.main(Select.java:32)

原因:

由于代码中使用了AS，也就是说新建了一个field名，所以原来的Order这个pojo中已经找不到你AS以后的名字了．

total没有在Order.class中查到，所以要改成Row.class

代码改成:

Table orders = tEnv.from("Orders");
Table result = orders.select($("product"), $("user"),$("amount").as("total"));
tEnv.toAppendStream(result, Order.class).print();
env.execute();

xxxx is not found in PojoType＜Order, fields = [amount: Integer, product: String, user: Long]＞相关推荐

no instance(s) of type variable(s) X exist so that DataSource＜X＞ conforms to DataStream＜Order＞
代码如下: ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();BatchTableEnvironmen ...
xxxx无法转换为java.lang.Class＜? extends javax.validation.Payload＞
将校验器中的groups字段修改为以下内容即可.
Idea SpringBoot工程提示 Error running 'xxxx': Command line is too long. In order to reduce its leng...
解决方法: 1.找到workspace.xml文件 2.在<component name="PropertiesComponent">中添加<property n ...
打怪升级之小白的大数据之旅(六十七)＜Hive旅程第八站:Hive的函数＞
打怪升级之小白的大数据之旅(六十七) Hive旅程第八站:Hive的函数上次回顾上一章,我们学习了如何对数据进行拆分–分区表与分桶表,使用分区表与分桶表,可以加快我们的查询效率..本章节是Hive ...
＜极客时间：零基础入门Spark＞学习笔记（持续更新中...）
看的是极客时间的课,讲得很不错零基础入门 Spark (geekbang.org) 基础知识 01 Spark:从"大数据的Hello World"开始准备工作 IDEA安装S ...
顺序表基本操作＜小白一听就懂！！！＞＜超详细＞＜接地气＞
顺序表基本操作<小白一听就懂!!!><超详细>&&<接地气> ***小编前言*** 完整代码 // 头文件 //主函数 // 初始化 /*运用指针* ...
＜X86汇编语言：实模式到保护模式＞四十六中断和异常的处理与抢占式多任务
中断和异常概述抢占式任务切换(依赖于硬件中断信号) 用来处理异常或者中断的程序叫做中断处理过程(程序) 中断描述符表
＜X86汇编语言：实模式到保护模式＞四十四协同式任务切换
多任务和任务切换概述什么时候切换到另一个任务? 以及切换到哪一个任务? 都是操作系统决定. 内核任务的创建和I/O特权级IOPL 0特权级始终高于或等于 IOPL 先使用and,将iopl清0,再使 ...
＜%=(String)request.getAttribute(““) %＞的作用是什么
<%=(String)request.getAttribute("") %>

xxxx is not found in PojoType＜Order, fields = [amount: Integer, product: String, user: Long]＞

xxxx is not found in PojoType＜Order, fields = [amount: Integer, product: String, user: Long]＞相关推荐

最新文章

热门文章