[Date Prev][Date Next][Thread Prev][Thread Next][Date Index][Thread Index]

FlinkUserClassLoader in AggregateFunction

Hi All,

Is there any other way to get hold of the FlinkUserClassLoaderother than the RuntimeContext?

The problem is, AggregateFunction cant be a RichFunction. I understand that's because of the state merging issue(from a thread here earlier). Now, I need DynamicClassLoading in AggregateFunction. And apparently, the only way to get a UserClassLoader is through the RuntimeContext.

Any workaround around this? Or someway I can create my custom UserClassLoader in the AggregateFunction?

Thanks in advance!