Re: [VOTE] Release 2.4.0, release candidate #3

+1. Ran a Python Streaming wordcount pipeline on Direct and Dataflow runners and Batch mobile gaming examples on Dataflow runner. On Mon, Mar 19, 2018 at 6:02 PM, Alan Myrvold wrote: > +1 I ran the java quickstarts against 2.4.0 and they passed. > ./gradlew

Re: [VOTE] Release 2.4.0, release candidate #3

I was able to run hourly_team_score. I was passing a wrong argument. No need for an alarm. :) On Mon, Mar 19, 2018 at 5:33 PM, Ahmet Altay wrote: > +1 Thank you Robert. > > Verified python mobile gaming examples using the wheel files on direct > runner. Got user_score working

Re: [VOTE] Release 2.4.0, release candidate #3

+1 Thank you Robert. Verified python mobile gaming examples using the wheel files on direct runner. Got user_score working but hourly_team_score failed with ( https://issues.apache.org/jira/browse/BEAM-3824). Since this is an example, I think it is fine to continue with the release. I will work

Pubsub API feedback

Hi, I wanted to get feedback about the upcoming Python Pubsub API. It is currently experimental and only supports reading and writing UTF-8 strings. My current proposal only concerns reading from Pubsub. Classes: - PubsubMessage: encapsulates Pubsub message payload and attributes. PTransforms: -

Implementing @OnWindowExpiration in StatefulParDo [BEAM-1589]

Hi everyone, I am working on BEAM-1589 . In short, currently, there is no default way of saving/flushing state before a window is garbage collected. My current plan is to provide a method annotation, @OnWindowExpiration, which allows user-provided

Re: [VOTE] Release 2.4.0, release candidate #3

+1, since Tf.Transform 0.6 depends on (and is blocked by) Beam 2.4 On Sat, Mar 17, 2018 at 2:19 AM, Robert Bradshaw wrote: > Hi everyone, > > Please review and vote on the release candidate #3 for the version 2.4.0, > as follows: >

Re: [VOTE] Release 2.4.0, release candidate #3

+1. Verified the Python Quickstart on local and Dataflow (Mac / Linux). Also verified that the Mac / Linux wheels were built correctly with fast / compiled Cython coder support. On Mon, Mar 19, 2018 at 1:49 PM Robert Bradshaw wrote: > Thanks! > > BTW, in case anyone's

Re: [VOTE] Release 2.4.0, release candidate #3

Thanks! BTW, in case anyone's wondering where the md5 files went, they're now discouraged: http://www.apache.org/dev/release-distribution#sigs-and-sums On Mon, Mar 19, 2018 at 12:53 PM Lukasz Cwik wrote: > +1 (binding), verified Java quickstart on Apex local, DirectRunner, >

Re: [VOTE] Release 2.4.0, release candidate #3

+1 (binding), verified Java quickstart on Apex local, DirectRunner, Dataflow, Flink local, Spark local. On Mon, Mar 19, 2018 at 3:54 AM Romain Manni-Bucau wrote: > -0 (cause of the teardown issue which is still a blocker), otherwise > spark/direct runners work in my

Re: [Proposal] Defining and Adding SDK Metrics - Looking for Feedback

Took a look, made some suggestions. On Mon, Mar 19, 2018 at 11:46 AM Scott Wegner wrote: > Thanks for writing this up! I'll take a look and add comments in the doc. > > On Tue, Mar 13, 2018 at 8:55 PM Alex Amato wrote: > >> Hello beam community, >> >> I

Re: [Proposal] Defining and Adding SDK Metrics - Looking for Feedback

Thanks for writing this up! I'll take a look and add comments in the doc. On Tue, Mar 13, 2018 at 8:55 PM Alex Amato wrote: > Hello beam community, > > I have put together a proposal > , >

Re: [VOTE] Release 2.4.0, release candidate #3

-0 (cause of the teardown issue which is still a blocker), otherwise spark/direct runners work in my projects Romain Manni-Bucau @rmannibucau | Blog | Old Blog | Github

Jenkins build is back to normal : beam_Release_NightlySnapshot #718

See