hbgstc123 commented on pull request #3645:
URL: https://github.com/apache/iceberg/pull/3645#issuecomment-985145057
Hi @kbendick!
I get this error when I'm trying to rewrite iceberg table in scala spark
code with a partition filter like this:
`
SparkActions.get().rewriteDataFiles(table)
.filter(Expressions.startsWith("imp_date",'20211202'))
.execute()
`
"imp_date" is a time partition field, it contains null value from some
abnormal rows.
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
