Hi Max,
the problem is that you’re trying to serialize the companion object of
scala.util.Random. Try to create an instance of the scala.util.Random class
and use this instance within your RIchFilterFunction to generate the random
numbers.
Cheers,
Till
On Mon, Jun 15, 2015 at 1:56 PM Maximilian
scope of the function).
Cheers,
Sebastian
From: Till Rohrmann [mailto:trohrm...@apache.org]
Sent: Montag, 15. Juni 2015 14:16
To: user@flink.apache.org
Subject: Re: Random Selection
Hi Max,
the problem is that you’re trying to serialize the companion object of
scala.util.Random. Try to create
gt;
> Cheers,
>
> Sebastian
>
>
>
> *From:* Till Rohrmann [mailto:trohrm...@apache.org]
> *Sent:* Montag, 15. Juni 2015 14:16
> *To:* user@flink.apache.org
> *Subject:* Re: Random Selection
>
>
>
> Hi Max,
>
> the problem is that you’re trying to serialize the co
to the scope of the function).
>>
>>
>>
>> Cheers,
>>
>> Sebastian
>>
>>
>>
>> *From:* Till Rohrmann [mailto:trohrm...@apache.org]
>> *Sent:* Montag, 15. Juni 2015 14:16
>> *To:* user@flink.apache.org
>> *Subject:* Re:
gt;>
>>> If that really is the problem, you should either define your anonymous
>>> class within the companion object of your job class or resort directly to a
>>> function (and make sure that you do not pass a variable from your job class
>>> into the sco
