While trying to use a mutable.Set and later .asJava I receive the following flink-jobmanager_1 | Caused by: java.lang.ClassCastException: scala.collection.convert.Wrappers$MutableSetWrapper cannot be cast to [J flink-jobmanager_1 | at org.apache.flink.table.data.util.DataFormatConverters$PrimitiveLongArrayConverter.toInternalImpl(DataFormatConverters.java:1014) ~[flink-table-blink_2.12-1.11.1.jar:1.11.1] ...
On Wed, Oct 14, 2020 at 2:54 PM Rex Fenley <r...@remind101.com> wrote: > Hello, > > I've been playing with UDFs using the Scala API and have repeatedly run > into issues such as this: > ``` > flink-taskmanager_1 | java.lang.ClassCastException: > scala.collection.immutable.Set$EmptySet$ cannot be cast to [J > ``` > Is there something that can be done on Flink's end, either to catch these > errors in type checking or to cast them in a sane manner during runtime? > > Thanks! > > -- > > Rex Fenley | Software Engineer - Mobile and Backend > > > Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/> | > FOLLOW US <https://twitter.com/remindhq> | LIKE US > <https://www.facebook.com/remindhq> > -- Rex Fenley | Software Engineer - Mobile and Backend Remind.com <https://www.remind.com/> | BLOG <http://blog.remind.com/> | FOLLOW US <https://twitter.com/remindhq> | LIKE US <https://www.facebook.com/remindhq>
