Hi, @pabloem,
Thank your for a wonderful Dataflow CDC Template!
When exploring it for MySQL tables ingestion, I faced an issue - cdc-embedded-connector fails on startup when trying to push schema to Data Catalog if a whitelisted table contains MySQL TINYINT columns.
This occurs because FIELD_TYPE_NAMES mapping in SchemaUtils.java misses INT16 Beam schema type, which represents TINYINT coming from MYSQL.
I am submitting PR with a fix.
Thanks