iemejia commented on pull request #12937:
URL: https://github.com/apache/beam/pull/12937#issuecomment-700525027
@echauchot The exceptions with Structured Streaming runner seems too weird,
it is like if Spark was generating invalid code. I doubt that this is an issue
in the runner translation, but maybe we need to double check. maybe you have a
different insight?
```
Caused by: java.lang.IllegalAccessError:
org/apache/beam/sdk/transforms/GroupByKeyTest$BadEqualityKey
at
org.apache.spark.sql.catalyst.expressions.GeneratedClass$SpecificUnsafeProjection.apply(Unknown
Source)
at
org.apache.spark.sql.execution.ObjectOperator$$anonfun$serializeObjectToRow$1.apply(objects.scala:155)
```
----------------------------------------------------------------
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]
