Example from Document: https://ci.apache.org/projects/flink/flink-docs-release-1.11/dev/table/tableApi.html part: Join with Temporal Table
Current Whole Code: https://paste.ubuntu.com/p/Jn3ChkNSpp/ Exception: Exception in thread "main" org.apache.flink.table.api.ValidationException: The proctime attribute can only be appended to the table schema and not replace an existing field. Please move 'proctime(r_proctime)' to the end of the schema. at org.apache.flink.table.typeutils.FieldInfoUtils$IndexedExprToFieldInfo.validateProcTimeAttributeAppended(FieldInfoUtils.java:512) at org.apache.flink.table.typeutils.FieldInfoUtils$IndexedExprToFieldInfo.visit(FieldInfoUtils.java:483) at org.apache.flink.table.typeutils.FieldInfoUtils$IndexedExprToFieldInfo.visit(FieldInfoUtils.java:459) 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$extractFieldInfosFromTupleType$6(FieldInfoUtils.java:421) at java.util.stream.IntPipeline$4$1.accept(IntPipeline.java:250) at java.util.stream.Streams$RangeIntSpliterator.forEachRemaining(Streams.java:110) at java.util.Spliterator$OfInt.forEachRemaining(Spliterator.java:693) 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.extractFieldInfosFromTupleType(FieldInfoUtils.java:422) at org.apache.flink.table.typeutils.FieldInfoUtils.extractFieldInformation(FieldInfoUtils.java:264) 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 JoinwithTemporalTable.main(JoinwithTemporalTable.java:51) Thanks for your help
