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
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;
> 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
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
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
Hi Flinksters,
I would like to randomly choose a element of my data set. But somehow I
cannot use scala.util inside my filter functions:
val sample_x = X filter(new RichFilterFunction[Vector](){
var i: Int = -1
override def open(config: Configuration) = {
i = scal
