The proctime attribute ‘rowtime‘ must not replace an existing field.

故障代碼如下:


// *************************************************************************
//     USER DATA TYPES
// *************************************************************************/** Simple POJO.*/import java.sql.Timestamp;
import org.apache.flink.streaming.api.windowing.time.Time;
/*** Simple POJO.*/
public class OrderStream
{public int id;public Long user;public String product;public int amount;public Long rowtime;public OrderStream(){}public OrderStream(int id,Long user,String product,int amount,Long rowtime){this.id=id;this.user = user;this.product = product;this.amount = amount;this.rowtime = rowtime;}@Overridepublic String toString(){return "Order{" +"id="+id+", user=" + user +", product='" + product + '\'' +", amount=" + amount +", ts=" + rowtime +'}';}
}DataStream<OrderStream> orderA = env.fromCollection(Arrays.asList(new OrderStream(1, 1L, "beer", 3, 1505529000L), //2017-09-16 10:30:00new OrderStream(2, 1L, "beer", 3, 1505529000L), //2017-09-16 10:30:00new OrderStream(3, 3L, "rubber", 2, 1505527800L),//2017-09-16 10:10:00new OrderStream(4, 3L, "rubber", 2, 1505527800L),//2017-09-16 10:10:00new OrderStream(5, 1L, "diaper", 4, 1505528400L),//2017-09-16 10:20:00new OrderStream(6, 1L, "diaper", 4, 1505528400L)//2017-09-16 10:20:00));tEnv.createTemporaryView("Orders", orderA,$("id"),$("user"), $("product"), $("amount"), $("rowtime").proctime());

完整報錯如下:

Exception in thread "main" org.apache.flink.table.api.ValidationException: The proctime attribute 'rowtime' must not replace an existing field.at org.apache.flink.table.typeutils.FieldInfoUtils$ExprToFieldInfo.validateProctimeDoesNotReplaceField(FieldInfoUtils.java:606)at org.apache.flink.table.typeutils.FieldInfoUtils$ExprToFieldInfo.createProctimeFieldInfo(FieldInfoUtils.java:599)at org.apache.flink.table.typeutils.FieldInfoUtils$ExprToFieldInfo.visit(FieldInfoUtils.java:564)at org.apache.flink.table.typeutils.FieldInfoUtils$ExprToFieldInfo.visit(FieldInfoUtils.java:536)at org.apache.flink.table.expressions.ApiExpressionVisitor.visit(ApiExpressionVisitor.java:39)at org.apache.flink.table.expressions.UnresolvedCallExpression.accept(UnresolvedCallExpression.java:132)at org.apache.flink.table.typeutils.FieldInfoUtils.lambda$extractFieldInfosByNameReference$7(FieldInfoUtils.java:431)at java.util.stream.ReferencePipeline$3$1.accept(ReferencePipeline.java:193)at java.util.Spliterators$ArraySpliterator.forEachRemaining(Spliterators.java:948)at java.util.stream.AbstractPipeline.copyInto(AbstractPipeline.java:481)at java.util.stream.AbstractPipeline.wrapAndCopyInto(AbstractPipeline.java:471)at java.util.stream.ReduceOps$ReduceOp.evaluateSequential(ReduceOps.java:708)at java.util.stream.AbstractPipeline.evaluate(AbstractPipeline.java:234)at java.util.stream.ReferencePipeline.collect(ReferencePipeline.java:499)at org.apache.flink.table.typeutils.FieldInfoUtils.extractFieldInfosByNameReference(FieldInfoUtils.java:432)at org.apache.flink.table.typeutils.FieldInfoUtils.extractFieldInformation(FieldInfoUtils.java:266)at org.apache.flink.table.typeutils.FieldInfoUtils.getFieldsInfo(FieldInfoUtils.java:233)at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.lambda$asQueryOperation$0(StreamTableEnvironmentImpl.java:384)at java.util.Optional.map(Optional.java:215)at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.asQueryOperation(StreamTableEnvironmentImpl.java:383)at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.fromDataStream(StreamTableEnvironmentImpl.java:230)at org.apache.flink.table.api.bridge.java.internal.StreamTableEnvironmentImpl.createTemporaryView(StreamTableEnvironmentImpl.java:262)at DistinctAggregation4.main(DistinctAggregation4.java:35)

The proctime attribute 'rowtime' must not replace an existing field.

原因與解決方案：

原因	解決方案
使用proctime，那麼列名不能是OrderStream中的	tEnv.createTemporaryView("Orders", orderA,$("id"),$("user"), $("product"), $("amount"), $("rowtime1").proctime());
使用rowtime,，列名可以是OrderStream中的．	tEnv.createTemporaryView("Orders", orderA,$("id"),$("user"), $("product"), $("amount"), $("rowtime").rowtime());

The proctime attribute ‘rowtime‘ must not replace an existing field.相关推荐

Caused by: java.lang.IllegalArgumentException: The handle attribute is must refer to an existing chi
最近一直在忙着写代码,就忘记了来CSDN上写博客了.哈哈,我真是个懒蛋... 今天在做SlidingDrawer,就是类似于抽屉那样的效果,遇到了下面这样的一个问题, Caused by: java. ...
Please move ‘proctime(r_proctime)‘ to the end of the schema.以及rowtime和proctime
代码: List<Tuple3<String,Long,Timestamp>>ratesHistoryData = new ArrayList<>();ratesH ...
使用solr的完整流程
本文摘要一.下载与安装二.运行solr 三.创建core实例四.配置schema 五.DIH导入数据六.solrJ(java客户端) 本文所用到的工具 Postman :简单说就是一个可以发送 ...
（九）solr 相关教程
本文为学习笔记,主要用于记录本人学习过程.部分内容为转载!!!!. 1. solr7.4教程使用solr的完整流程本文摘要一.下载与安装二.运行solr 三.创建core实例四.配置sche ...
python替换文本换行符_python解决replace(“/n“,““)无法替换换行符
先看原数据,一直在想办法清除 "\n"和"/"这两个符号. # 从提取出的几列来看,还有些细节需要再洗洗:例如为了统计和美观需要,"\n"和 ...
Attribute在.net编程中的应用
作者:niwalker 出处:csdn SqlCommandGenerator类的设计 SqlCommandGEnerator类的设计思路就是通过反射得到方法的参数,使用被SqlComma ...
sql视图语句_SQL视图：Replace View语句的示例语法
sql视图语句 A View is a database object that presents data from in one or more tables. The same SQL stat ...
android add fragment,fragment中的add和replace方法的区别浅析
使用 FragmentTransaction 的时候,它提供了这样两个方法,一个 add , 一个 replace ,对这两个方法的区别一直有点疑惑. 我觉得使用 add 的话,在按返回键应该是回退到 ...
MySQL中 replace 替换字符
阅读目录语法:replace(field,search,replace) 说明: field - 数据库表的列名 search - 需要替换的字符串 replace - 替换成的字符串语义:将列名 ...

The proctime attribute ‘rowtime‘ must not replace an existing field.

The proctime attribute ‘rowtime‘ must not replace an existing field.相关推荐

最新文章

热门文章