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>

Reply via email to