[PR] [flink] Fix schema inference for multi partition Kafka topics [paimon]

["ArnavBalyan (via GitHub)" <gi...@apache.org>]

ArnavBalyan opened a new pull request, #9478:
URL: https://github.com/apache/paimon/pull/9478

   ### Purpose
    - Kafka table sync fails table creation when 1st partition has no cdc records, even when other partitions have records.
    - Schema discovery reads only the 1st partition and fails with SchemaRetrievalException.
   -  Read records from all topic partitions so the schema is inferred from the first valid CDC record.
   
   ### Tests
    - UT


-- 
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: issues-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] [flink] Fix schema inference for multi partition Kafka topics [paimon]

["JingsongLi (via GitHub)" <gi...@apache.org>]

JingsongLi commented on PR #9478:
URL: https://github.com/apache/paimon/pull/9478#issuecomment-5506641096

   +1


-- 
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: issues-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

Re: [PR] [flink] Fix schema inference for multi partition Kafka topics [paimon]

["JingsongLi (via GitHub)" <gi...@apache.org>]

JingsongLi merged PR #9478:
URL: https://github.com/apache/paimon/pull/9478


-- 
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: issues-unsubscribe@paimon.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org