I am trying to add a new Row to each Partition in my Spark Job. I am using the following code to achieve this:

I am trying to add a new Row to each Partition in my Spark Job. I am using the following code to achieve this:

I’m facing the following error that I’m not able to overcome.
I’m utilizing Spark 3.1.2, Scala 2.12, and Java 17.

I have a dataset that have the following schema:
(timestamp, partitionKey, logValue)

Getting below error when running the job , not getting any idea how to resolve