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, Rong On Sun, Aug 19, 2018 at 5:42 AM chrisr123 <chris.rueg...@gmail.com> wrote: > 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 > 3000,2018-04-19,192.74,1005 > 3001,2017-08-18,432.87,1000 > 3002,2018-08-18,22.19,1002 > > *Source code:* > CsvTableSource orderTableSource = CsvTableSource.builder() > .path("input/batch/orders.csv") > .ignoreFirstLine() > .fieldDelimiter(",") > .field("id", Types.INT()) > .field("order_date", Types.SQL_DATE()) > .field("amount", Types.DECIMAL()) > .field("customer_id", Types.LONG()) > .build(); > > > tableEnv.registerTableSource("orders", orderTableSource); > Table orderTable = tableEnv.scan("orders"); > > // SELECT * > // FROM orders > Table allOrders = orderTable > .select("id,order_date,amount,customer_id") > .orderBy("id.asc"); > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >