Re: Samza container hang on exception

2016-09-02 Thread 李斯宁
Can any one help on this? Thanks! On Thu, Sep 1, 2016 at 11:59 AM, 李斯宁 wrote: > If you cannot see the attachment, please try http://note.youdao.com/ > noteshare?id=56b826c24af47a9fdb600490ce788710 > > On Thu, Sep 1, 2016 at 1:50 AM, Chinmay Soman > wrote: > >> Sorry dont see anything in the att

Re: Review Request 47835: SAMZA-914: Initial draft for Java programming APIs on operators supporting DAGs

2016-09-02 Thread Yi Pan (Data Infrastructure)
> On Sept. 1, 2016, 9:25 p.m., Jake Maes wrote: > > samza-operator/src/main/java/org/apache/samza/operators/api/Scan.java, > > lines 36-41 > > > > > > Tuple/Message > > > > Also, I don't see anything called

Re: Review Request 47835: SAMZA-914: Initial draft for Java programming APIs on operators supporting DAGs

2016-09-02 Thread Yi Pan (Data Infrastructure)
> On Aug. 31, 2016, 2:18 a.m., Jake Maes wrote: > > samza-operator/src/main/java/org/apache/samza/operators/api/MessageStream.java, > > line 147 > > > > > > I think it would be useful to call out why SinkFunction i

Re: Review Request 47835: SAMZA-914: Initial draft for Java programming APIs on operators supporting DAGs

2016-09-02 Thread Yi Pan (Data Infrastructure)
> On Sept. 1, 2016, 5:58 p.m., Jake Maes wrote: > > samza-operator/src/main/java/org/apache/samza/operators/api/MessageStream.java, > > line 47 > > > > > > Does MessageStream need to have the key type parameter? > >

Re: Samza container hang on exception

2016-09-02 Thread Yi Pan
Hi, Sining, You note is on a site that I don't have account/access and it requires sign-up. Can you share it via google doc, since you have a gmail account? And just to confirm, you have upgrade and using 0.10.1 now, right? Thanks and apologize for the delay. -Yi On Fri, Sep 2, 2016 at 1:03 AM,

Re: Review Request 51516: SAMZA-702: Document the significance of all the different metrics emitted by Samza out of the box

2016-09-02 Thread Branislav Cogic
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/51516/ --- (Updated Sept. 2, 2016, 9:06 a.m.) Review request for samza. Bugs: SAMZA-702

Re: Review Request 51516: SAMZA-702: Document the significance of all the different metrics emitted by Samza out of the box

2016-09-02 Thread Branislav Cogic
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/51516/ --- (Updated Sept. 2, 2016, 9:10 a.m.) Review request for samza. Bugs: SAMZA-702

Re: Samza container hang on exception

2016-09-02 Thread 李斯宁
yes, upgraded to 0.10.1 jstack: https://drive.google.com/open?id=0B19olQZ1dUO8VjltQmtxLTJ4SVdFZWhYWHZ3Y2hMOVhCMWNn task log: https://drive.google.com/open?id=0B19olQZ1dUO8eVRLWmJCVl9nRlg2UUM4c21udUViWW8tSUVV On Fri, Sep 2, 2016 at 4:41 PM, Yi Pan wrote: > Hi, Sining, > > You note is on a site t

Re: Review Request 51516: SAMZA-702: Document the significance of all the different metrics emitted by Samza out of the box

2016-09-02 Thread Branislav Cogic
> On Sept. 1, 2016, 1:50 a.m., Navina Ramesh wrote: > > docs/learn/documentation/versioned/container/metrics-table.html, line 795 > > > > > > did you mean per-system here? No, i meant per system strea. Maybe the des

Review Request 51613: Fix SAMZA-842

2016-09-02 Thread Tommy Becker
--- This is an automatically generated e-mail. To reply, visit: https://reviews.apache.org/r/51613/ --- Review request for samza. Bugs: SAMZA-842 https://issues.apache.org/jira/br

Re: [DISCUSS] End of Stream Feature in Samza

2016-09-02 Thread Jagadish Venkatraman
Thank you Renato for the insightful feedback! :-) I don't think we have a complete scoping and design for the "punctuated streams" feature as of yet. However, one way to implement it would be to leverage something similar to what this feature does. We could have a special offset for a "punctuation