yihua commented on PR #19304: URL: https://github.com/apache/hudi/pull/19304#issuecomment-5828538292
@danny0405 one Flink-side gap worth your eyes before this lands. `BaseHoodieWriteClient#initTable` now fails a record-keying write when a single-field complex keygen table carries no `hoodie.table.complex.keygenerator.encoding`, and only the Java client and the Spark datasource / Hudi Streamer setup paths backfill it -- Flink has no equivalent, so an existing Flink table created before this change throws with no in-job way to record the property (`StreamerUtil.checkKeygenGenerator` only defaults the job conf, and `initTableIfNotExists` writes it at creation only). Should Flink get the same backfill on job start, or is requiring the operator to set the property on the table out-of-band the intended contract? -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
