vijaykumarbotla
New Contributor III

Hi All,

the issue is resolved, i have executed column conversion and from next run the code is working fine.

df = spark.read.format("delta").load("/mnt/dev/deltav2/X")

df= df.withColumn("LIFNR", df.LIFNR.cast("string"))

df.write.format('delta').option("overwriteSchema", "true").mode('overwrite').save("/mnt/dev/deltav2/X")

View solution in original post