Get hands-on experience with 20+ free Google Cloud products and $300 in free credit for new customers.

DataFlow: java.lang.IllegalArgumentException: The partition column value is an instance of unsupport

Job template: DataPlex JDBC ingestion

Source: CloudSQL - MySQL

The job starts to fail when partition column parameter (i.e. ingestion_date) is specific. When its not use the job runs successfully. 

Error: java.lang.IllegalArgumentException: The partition column value is an instance of unsupported class: class java.lang.Integer

I have the query below :

select current_date as ingestion_date, personid, lastname, firstname, address, city from ddldb.persons

1 0 70
0 REPLIES 0