Pratyaksh Sharma

I see the changes were introduced in this commit - https://github.com/apache/hudi/pull/755. Hence tagging @bvaradar here.

@codope Let us connect sometime next week to discuss this. This has been pending for some time.

Can you share the entire stacktrace?

@nleena123 I meant to say please share the detailed error log and not just the exception message. :)

Sorry for being late here. I see the class `DFAvroKafkaSource` in logs. Are you having your own custom class for reading the data?

I see `hoodie.datasource.write.hive_styling_partioning` should be changed to `hoodie.datasource.write.hive_style_partitioning`. Looking at your timeline, `20211211183554__commit__COMPLETED` is the last time the job ran successfully, after that you have been running into issues. So...

Yes, changing to `hoodie.datasource.write.hive_style_partitioning` will not fix your issue. That was just a typo in your configs (unrelated to this error), so I just highlighted this.

Also I guess there is some confusion with respect to the code that you shared and the logs that you shared. In the code, I see multiple logs getting printed...

@NikhilCollooru gentle ping!

@imjalpreet @agrawalreetika @fgwang7w Can you guys take the first pass here?