Re: beam.io.ReadStringsFromPubSub Unexpected behaviour

Hmm I got a chance to test my code again and it worked perfectly without any changes. Is there any thoughts on why this is happen? So I can make sure that this is not happen again in the future. Thanks — bay On Fri, 5 Jan 2018 at 14.24 Bayu Aldi Yansyah wrote: > Hey

Re: Regarding Beam Slack Channel

Got it, thanks. On 9 Jan 2018 11:53 am, "Jean-Baptiste Onofré" wrote: > Done, you should have received the invite. > > Welcome ! > > Regards > JB > > On 01/09/2018 06:31 AM, Shashank Prabhakara wrote: > >> I'd also like to be added, please. >> >> Thanks. >> >> On 2018-01-04

Re: Regarding Beam Slack Channel

Done, you should have received the invite. Welcome ! Regards JB On 01/09/2018 06:31 AM, Shashank Prabhakara wrote: I'd also like to be added, please. Thanks. On 2018-01-04 11:58, Jean-Baptiste Onofr� > wrote: > Hi,> > > you should have

Re: Regarding Beam Slack Channel

Hi Austin, Not sure what you meant by follow along there, but I can't sign up on the slack page due to email domain restrictions and it does not allow me to request entry there. Regards, Shashank On Tue, Jan 9, 2018 at 11:11 AM, Austin Bennett wrote: > It'd be

Re: Regarding Beam Slack Channel

It'd be easier to follow along there On Jan 8, 2018 9:32 PM, "Shashank Prabhakara" wrote: > I'd also like to be added, please. > > Thanks. > > On 2018-01-04 11:58, Jean-Baptiste Onofr� wrote: > > Hi,> > > > > you should have received the invite.> > > >

Re: Regarding Beam Slack Channel

I'd also like to be added, please. Thanks. On 2018-01-04 11:58, Jean-Baptiste Onofr� wrote: > Hi,> > > you should have received the invite.> > > Welcome aboard !> > > Regards> > JB> > > On 01/04/2018 01:38 AM, David Sabater Dinter wrote:> > > Hi,> > > Can I join also,

Re: London Apache Beam meetup 2: 11/01

Yes, we put everything in place to record this time and hope to share the recordings soon after the meetup. Stay tuned! On 8 Jan 2018 10:32, "Carlos Alonso" wrote: Will it be recorded? On Fri, Jan 5, 2018 at 5:11 PM Matthias Baetens

Re: Need help running beam word count example on apex/hdfs

Forgot to mention: Execution works in embedded mode and counts are created on the local fs. I need this to run on hdfs/yarn with --embeddedExecution=false. Regards, Shashank On Mon, Jan 8, 2018 at 3:06 PM, Shashank Prabhakara wrote: > Hi All, > > I want to test beam on

Re: London Apache Beam meetup 2: 11/01

Will it be recorded? On Fri, Jan 5, 2018 at 5:11 PM Matthias Baetens < matthias.baet...@datatonic.com> wrote: > Hi all, > > Excited to announce the second Beam meet up located in the *Qubit offices > *next *Thursday 11/01.* > > We are very excited to have JB

Need help running beam word count example on apex/hdfs

Hi All, I want to test beam on apex using the word count example provided in the beam repository, but I'm facing some difficulties while executing word count as described in the documentation. I'm running hadoop version 2.8.2 on debian in a multi-node environment. I cloned the beam github