Filed https://issues.apache.org/jira/browse/FLINK-10172. Seems like it is
affecting latest version.
--
Rong
On Sun, Aug 19, 2018 at 8:14 AM Rong Rong wrote:
> Hi Chris,
>
> This looks like a bug to me as
> val allOrders:Table = orderTable
> .select('id, 'order_date, 'amount, 'customer_i
Hi Chris,
This looks like a bug to me as
val allOrders:Table = orderTable
.select('id, 'order_date, 'amount, 'customer_id)
.orderBy('id.asc)
works perfectly fine. Could you file a bug report and kindly provide the
Flink version you are using? I can take a look into it
Thanks,
Ron
Use Case:
I have a CSV file with data that I want to do a SELECT with orderBy.
I'm getting this error below. What am I doing incorrectly? Thanks!
*Expression (('id).asc).asc failed on input check: Sort should only based on
field reference
*
*Input File structure:*
id,order_date,amount,customer_id
