sathyaprakashg commented on issue #1971: URL: https://github.com/apache/hudi/issues/1971#issuecomment-678117088
`java.io.EOFException` error means, schema you provided has more fields than fields available in RDD/Dataset. If your source is also kafka, then find out which schema version is used by kafka producer and use that schema version as workaround in `hoodie.deltastreamer.schemaprovider.registry.url` instead of latest schema. I think solution is try to use the same schema (get it from RDD/Dataset) to convert avro to bytes and to convert bytes back to avro. Once we have suggestion from @bvaradar or @bhasudha, I will see if i can create PR to get it fixed. ---------------------------------------------------------------- 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. For queries about this service, please contact Infrastructure at: [email protected]
