Re: Add me to JIRA?

Hi Bobby Jira has been spammed today (in the Lens project). Infra is on it.  RegardsJB  Sent from my Samsung device Original message From: Bobby Evans Date: 12/05/2016 01:29 (GMT+00:00) To: dev@beam.incubator.apache.org Subject: Re: Add me to JIRA? This is the mes

Re: Add me to JIRA?

I will unlock anyway. RegardsJB  Sent from my Samsung device Original message From: Bobby Evans Date: 12/05/2016 01:29 (GMT+00:00) To: dev@beam.incubator.apache.org Subject: Re: Add me to JIRA? This is the message that JIRA is showing. "Jira is in Temporary Lockd

Re: Beam and Storm

Amir, That link is for the Storm compatibility layer that Flink offers, it has nothing really to do with beam at all, except that flink offers support for both BEAM as an API layer, and storm as an API layer. - Bobby On Wed, May 11, 2016 at 6:58 PM amir bahmanyari wrote: > Thanks so much for y

Re: Add me to JIRA?

This is the message that JIRA is showing. "Jira is in Temporary Lockdown mode as a spam countermeasure. Only logged-in users with active roles (committer, contributor, PMC, etc.) will be able to create issues or comments during this time. Lockdown period from 11 May 2300 UTC to estimated 12 May 23

Re: Beam and Storm

Thanks so much for your response Bobby.I have been reading this link for a while, and researching its details.Apache Flink 0.10.2 Documentation: Storm Compatibility | | | | || | | | | | Apache Flink 0.10.2 Documentation: Storm Compatibility | | | | I h

Add me to JIRA?

Looks like I don't have permission to file a JIRA against BEAM. Could someone add me in? My jira user id is revans2. I found a small javadoc issue with PaneInfo.getTiming, it was copied and pasted from isLast. I figure it is a good place to start on submitting a BEAM fix. Thanks, Bobby

Re: Beam and Storm

Amir, I am kind of new at this so I might be wrong, but in general if your bolts are stateless then they would translate directly into ParDos one to one. The spouts are more complex and you would want to find an existing unbounded source, or you would have to write one. I don't know if there are

Re: Beam and Storm

Is there a guideline on how to port an existing Storm code to Beam?Thanks From: Bobby Evans To: dev@beam.incubator.apache.org Sent: Wednesday, May 11, 2016 1:25 PM Subject: Re: Beam and Storm Thanks for the quick response.  I'll keep digging. On Wed, May 11, 2016 at 3:14 PM Dan Hal

Re: Beam and Storm

Thanks for the quick response. I'll keep digging. On Wed, May 11, 2016 at 3:14 PM Dan Halperin wrote: > Hi Bobby, > > You are correct that unbounded sinks are currently implemented as > PTransforms that interact with an external service in a ParDo. Even bounded > sinks are implemented this way

Beam and Storm

I have been trying to get my head wrapped around some of the internals of beam so I can come up with an architecture/plan for STORM-1757 / BEAM-9 . I see that there are Sources and Sinks. Sources can

Re: add component tag to pull request title / commit comment

This will, however, also take precious space in the Commit Title. And some commits might not be about only one clear-cut component. On Wed, 11 May 2016 at 11:43 Maximilian Michels wrote: > +1 I think it makes it easier to see at a glance to which part of Beam > a commit belongs. We could use the

Re: add component tag to pull request title / commit comment

+1 I think it makes it easier to see at a glance to which part of Beam a commit belongs. We could use the Jira components as tags. On Wed, May 11, 2016 at 11:09 AM, Jean-Baptiste Onofré wrote: > Hi Manu, > > good idea. Theoretically the component in the corresponding Jira should give > the infor

Re: add component tag to pull request title / commit comment

Hi Manu, good idea. Theoretically the component in the corresponding Jira should give the information, but for convenience, we could add a "tag" in the commit comment. Regards JB On 05/10/2016 06:27 AM, Manu Zhang wrote: Guys, As I've been developing Gearpump runner for Beam, I've closely