Join GitHub today
GitHub is home to over 31 million developers working together to host and review code, manage projects, and build software together.Sign up
DataException is thrown if timestamp column is not present in SELECT list #561
Given a table:
It is valid to run a query with the predicate column not present in the
However the JDBC connector throws an error if the
The JDBC source connector should not mandate that the field is present, if the query can successfully execute without it.
@rmoff The final query that connector would fire will be:
SELECT FIRST_NAME, LAST_NAME, GENDER, COMMENTS FROM demo.customers where UPDATE_TS > '<last_saved_offset_timestamp> || 1970-01-01 00:00:00'
The important aspect is that the timestamp column or increment column actually build the WHERE clause. See this class for Timestamp+Incrementing mode (last 3 methods). For other modes there are other classes.