Romain Rigaux

Maybe it is a Flink concept that I don't know, but even a basic LIMIT 2 returns a lot more rows: e.g. `SELECT rideId, rideTime FROM default_database.Rides ORDER BY rideTime...

Still learning the Flink terminology but it is the dataset from: https://github.com/ververica/sql-training/wiki/Setting-up-the-Training-Environment#running-a-simple-query Opened via a execution_type/streaming & planner/blink session.

Maybe LIMIT is invalid but we don't tell the user: https://ci.apache.org/projects/flink/flink-docs-master/dev/table/sql/queries.html#orderby--limit

https://github.com/ververica/flink-sql-gateway/pull/45

I got something like: ```7:39:46.094 [flink-rest-server-netty-worker-thread-1] ERROR com.ververica.flink.table.gateway.rest.handler.StatementExecuteHandler - Unhandled exception. com.ververica.flink.table.gateway.utils.SqlExecutionException: Invalid SQL query. at com.ververica.flink.table.gateway.operation.SelectOperation.executeQueryInternal(SelectOperation.java:225) ~[flink-sql-gateway-0.2-SNAPSHOT.jar:?] at com.ververica.flink.table.gateway.operation.SelectOperation.execute(SelectOperation.java:87) ~[flink-sql-gateway-0.2-SNAPSHOT.jar:?] at com.ververica.flink.table.gateway.rest.session.Session.runStatement(Session.java:106) ~[flink-sql-gateway-0.2-SNAPSHOT.jar:?] at com.ververica.flink.table.gateway.rest.handler.StatementExecuteHandler.handleRequest(StatementExecuteHandler.java:81) ~[flink-sql-gateway-0.2-SNAPSHOT.jar:?] at com.ververica.flink.table.gateway.rest.handler.AbstractRestHandler.respondToRequest(AbstractRestHandler.java:77) ~[flink-sql-gateway-0.2-SNAPSHOT.jar:?]...

+1 this would be nice

I would need to clean-up a bit, but the source should show up there https://hub.docker.com/layers/romainr/flink-sql-api/0.3-1.12.0/images/sha256-37be5b6098d4546611fb8bbd5e11d4d8047788ca37d9758d46f1d073ce6d1d16?context=explore Is it enough for now?

Nice, indeed I tried a few SELECTs and CREATEs and it worked! This is great for playing with all the improvements of 1.12.

In case people want to help/give a try, I put a pre-release snapshot of above on https://github.com/romainr/flink-sql-gateway/releases/tag/0.3-1.12-pre

Maybe related to using the Hive connector? Do you have the create table?