Subject: Re: InvalidProgramException when trying to sort a group within a
dataset
Hi,
If you have a closer look at the excecption, you'll see that the issue is cause
by com.iri.aa.etl.rgm.service.ThresholdAcvCalcServiceImpl not being
serializable.
It seems that you have a reference to
o success.
>
> I got the same NotSerializableException.
>
>
>
> Best,
>
> Konstantinos
>
>
>
> *From:* Fabian Hueske
> *Sent:* Σάββατο, 6 Απριλίου 2019 2:26 πμ
> *To:* Papadopoulos, Konstantinos
>
> *Cc:* Chesnay Schepler ; user
> *Subject:* Re: InvalidProgramExcep
Subject: Re: InvalidProgramException when trying to sort a group within a
dataset
Hi,
You POJO should implement the Serializable interface.
Otherwise it's not considered to be serializable.
Best, Fabian
Papadopoulos, Konstantinos
mailto:konstantinos.papadopou...@iriworldwide.com>>
sc
new ThresholdAcvPromoPriceFactMapper(customerId));
>
>
>
> return basePriceFacts
>
> .fullOuterJoin(promoPriceFacts)
>
> .where(PRODUCT_ID_FIELD, TIME_PERIOD_ID_FIELD,
> GEOGRAPHY_ID, "basePrice")
>
>
der.ASCENDING)
.reduceGroup(new ThresholdAcvFactCountGroupReducer());
}
Regards,
Konstantinos
From: Chesnay Schepler
Sent: Τετάρτη, 3 Απριλίου 2019 12:59 μμ
To: Papadopoulos, Konstantinos ;
user@flink.apache.org
Subject: Re: InvalidProgramException when trying to sort a group
Your user-defined functions are referencing the class
"com.iri.aa.etl.rgm.service.ThresholdAcvCalcServiceImpl" which isn't
serializable.
My guess is that "ThresholdAcvFact" is a non-static inner class, however
I would need to see the entire class to give an accurate analysis.
On 02/04/2019 1
