Re: Error on SQL orderBy Error
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_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 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/ >> >
Re: Error on SQL orderBy Error
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 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/ >
Error on SQL orderBy Error
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/