in org.apache.flink.api.table.plan.PlanTranslator.
val inputType = set.getType().asInstanceOf[CompositeType[A]]
if (!inputType.hasDeterministicFieldOrder && checkDeterministicFields) {
throw new ExpressionException(s"You cannot rename fields upon Table
creation: " +
s"Field order o
Ok, then I think I have no better solution than use the Table API of the
upcoming 1.1 release. The Table API has been completely rewritten and
the POJO support is now much better. Maybe you could try the recent 1.1
RC1 release.
Am 01/08/16 um 11:11 schrieb Dong-iL, Kim:
I’ve tried like this,
I’ve tried like this, but not work.
dataSet.as(‘id as ‘id, ‘amount as ‘amount)
dataSet.as(‘id, ‘amount)
dataSet.as(“id, amount”)
thanks.
> On Aug 1, 2016, at 6:03 PM, Timo Walther wrote:
>
> I think you need to use ".as()" instead of "toTable()" to supply the field
> order.
>
> Am 01/08/16
I think you need to use ".as()" instead of "toTable()" to supply the
field order.
Am 01/08/16 um 10:56 schrieb Dong-iL, Kim:
Hi Timo.
I’m using scala API.
There is no error with java API.
my code snippet is this.
dataSet.toTable
.groupBy(“id")
.select(‘id, ‘am
Hi Timo.
I’m using scala API.
There is no error with java API.
my code snippet is this.
dataSet.toTable
.groupBy(“id")
.select(‘id, ‘amount.sum as ‘amount)
.where(‘amount > 0)
.toDataSet[TestPojo]
.print()
Thanks.
>
Hi Kim,
as the exception says: POJOs have no deterministic field order. You have
to specify the order during the DataSet to Table conversion:
Table table = tableEnv.fromDataSet(pojoDataSet, "pojoField as a,
pojoField2 as b");
I hope that helps. Otherwise it would help if you could supply a
my flink ver is 1.0.3.
thanks.
> On Aug 1, 2016, at 5:18 PM, Dong-iL, Kim wrote:
>
> I’ve create a program using table API and get an exception like this.
> org.apache.flink.api.table.ExpressionException: You cannot rename fields upon
> Table creation: Field order of input type PojoType<….> is
I’ve create a program using table API and get an exception like this.
org.apache.flink.api.table.ExpressionException: You cannot rename fields upon
Table creation: Field order of input type PojoType<….> is not deterministic.
There is an error not in java program, but in scala program.
how can I us
