Re: Beam SparkRunner and Spark KryoSerializer problem

Hi Jean, Thank you! On Thu, Oct 4, 2018 at 7:54 AM Jean-Baptiste Onofré wrote: > Hi Juan > > I'm on it. > > Regards > JB > Le 4 oct. 2018, à 07:19, Juan Carlos Garcia a écrit: >> >> Bump, >> >> can someone from the core-dev provide a feedback about: >>

Re: Beam SparkRunner and Spark KryoSerializer problem

Hi Juan I'm on it. Regards JB Le 4 oct. 2018 à 07:19, à 07:19, Juan Carlos Garcia a écrit: >Bump, > >can someone from the core-dev provide a feedback about: > https://issues.apache.org/jira/browse/BEAM-4597 > >Thanks > >On Mon, Jul 30, 2018 at 3:15 PM Juan Carlos Garcia > >wrote: > >> Hi

Re: Beam SparkRunner and Spark KryoSerializer problem

Bump, can someone from the core-dev provide a feedback about: https://issues.apache.org/jira/browse/BEAM-4597 Thanks On Mon, Jul 30, 2018 at 3:15 PM Juan Carlos Garcia wrote: > Hi Jean, > > Thanks for taking a look. > > > On Mon, Jul 30, 2018 at 2:49 PM, Jean-Baptiste Onofré > wrote: > >>

Re: Beam SparkRunner and Spark KryoSerializer problem

Hi Jean, Thanks for taking a look. On Mon, Jul 30, 2018 at 2:49 PM, Jean-Baptiste Onofré wrote: > Hi Juan, > > it seems that has been introduce by the metrics layer in the core runner > API. > > Let me check. > > Regards > JB > > On 30/07/2018 14:47, Juan Carlos Garcia wrote: > > Bump! > > >

Re: Beam SparkRunner and Spark KryoSerializer problem

Hi Juan, it seems that has been introduce by the metrics layer in the core runner API. Let me check. Regards JB On 30/07/2018 14:47, Juan Carlos Garcia wrote: > Bump! > > Does any of the core-dev roam around here? > > Can someone provide a feedback about BEAM-4597 >

Re: Beam SparkRunner and Spark KryoSerializer problem

Bump! Does any of the core-dev roam around here? Can someone provide a feedback about BEAM-4597 Thanks and regards, On Thu, Jul 19, 2018 at 3:41 PM, Juan Carlos Garcia wrote: > Folks, > > Its someone using the SparkRunner out there with the

Beam SparkRunner and Spark KryoSerializer problem

Folks, Its someone using the SparkRunner out there with the Spark KryoSerializer ? We are being force to use the not so efficient 'JavaSerializer' with Spark because we face the following exception: Exception in thread "main" java.lang.RuntimeException: org.apache.spark.SparkException: Job