Re: Streaming JSON parser

2016-03-22 Thread Justin Mclean
Hi, Would this help? http://johnzon.incubator.apache.org Justin

[jira] [Closed] (APEXMALHAR-2010) Add transform operator

2016-03-22 Thread Sandeep Deshmukh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2010?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandeep Deshmukh closed APEXMALHAR-2010. Resolution: Done Fix Version/s: 3.4.0 > Add transform operator > ---

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-2010 Add Tranform o...

2016-03-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-apex-malhar/pull/209 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the

[jira] [Commented] (APEXMALHAR-2010) Add transform operator

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2010?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207950#comment-15207950 ] ASF GitHub Bot commented on APEXMALHAR-2010: Github user asfgit closed th

Re: Streaming JSON parser

2016-03-22 Thread Ashish Tadose
+1 This would be a good value add. It will result in achieving higher throughput for input operators which needs to consume selective json fields. Thx, Ashish > On 23-Mar-2016, at 10:31 AM, Bhupesh Chawda wrote: > > A multi-line JSON format is very common and is usually the case with REST >

Re: Bandwidth control for Input operators in Apex

2016-03-22 Thread Priyanka Gugale
Right now it's not for output operator, but one can very well use bandwidth manager to keep track of bandwidth usage and limit your output speed. The bigger challenge there would be, you won't be able to process window data sent by upstream operator in same window. For that you need to do more than

Re: Bandwidth control for Input operators in Apex

2016-03-22 Thread Priyanka Gugale
That's a good question Chaitanya, Right now the bandwidth control is at Input Operator level and not application level. So if you have two input operator you need to set bandwidth on both separately by this design. May be it would be good to have bandwidth control at Application level than operator

Re: Bandwidth control for Input operators in Apex

2016-03-22 Thread Yogi Devendra
Priyanka, >From the design description it is not clear how it will be used to control output bandwidth (point #2,3,4 mentioned by Sandeep) ~ Yogi On 23 March 2016 at 11:39, Chaitanya Chebolu wrote: > This is very useful feature. > I would like to know, how you are distributing the bandwidth fo

Re: Bandwidth control for Input operators in Apex

2016-03-22 Thread Chaitanya Chebolu
This is very useful feature. I would like to know, how you are distributing the bandwidth for the below situation: - Two input operators say i1 and i2 are deployed on same node and both the operators have bandwidthManager as plugin. On Fri, Mar 18, 2016 at 5:43 PM, Priyanka Gugale wrote: > Hi, >

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Priyanka Gugale
+1 -Priyanka On Wed, Mar 23, 2016 at 11:09 AM, Akshay Gore wrote: > +1 > > Looking forward Apex as Apache TLP. > > -Akshay > > On Wed, Mar 23, 2016 at 10:53 AM, Shubham Pathak > wrote: > > > +1 > > > > Thanks, > > Shubham > > > > On Wed, Mar 23, 2016 at 10:47 AM, Yogi Devendra > > > wrote: >

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Akshay Gore
+1 Looking forward Apex as Apache TLP. -Akshay On Wed, Mar 23, 2016 at 10:53 AM, Shubham Pathak wrote: > +1 > > Thanks, > Shubham > > On Wed, Mar 23, 2016 at 10:47 AM, Yogi Devendra > wrote: > > > +1 > > > > > > ~ Yogi > > > > On 23 March 2016 at 10:20, Chaitanya Chebolu > > wrote: > > > > >

Re: FileLineInputOperator in AbstractFileInputOperator

2016-03-22 Thread Chandni Singh
Hi, Since we have a lot of support for this I will create a ticket. Thanks, Chandni On Tue, Mar 22, 2016 at 1:14 AM, Shubham Pathak wrote: > +1 to have it as a separate class. > > On Tue, Mar 22, 2016 at 11:35 AM, Chaitanya Chebolu < > chaita...@datatorrent.com> wrote: > > > +1. Move it out fr

Re: Reg IndexOutOfBoundsException while serializing the object

2016-03-22 Thread Timothy Farkas
Sure I'll pick it up. Thanks, Tim On Tue, Mar 22, 2016 at 8:17 PM, Pramod Immaneni wrote: > Do you want to dig into the issue Tim? > > On Tue, Mar 22, 2016 at 8:53 PM, Timothy Farkas > wrote: > > > This is a platform bug I encountered as well. I reported it a while ago. > > > > https://issues.

[jira] [Created] (APEXCORE-404) Move FileLineInputOperator out of AbstractFileInputOperator

2016-03-22 Thread Chandni Singh (JIRA)
Chandni Singh created APEXCORE-404: -- Summary: Move FileLineInputOperator out of AbstractFileInputOperator Key: APEXCORE-404 URL: https://issues.apache.org/jira/browse/APEXCORE-404 Project: Apache Ape

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Shubham Pathak
+1 Thanks, Shubham On Wed, Mar 23, 2016 at 10:47 AM, Yogi Devendra wrote: > +1 > > > ~ Yogi > > On 23 March 2016 at 10:20, Chaitanya Chebolu > wrote: > > > +1 > > > > On Wed, Mar 23, 2016 at 10:19 AM, HARSH PATHAK > > wrote: > > > > > +1 > > > On 23-Mar-2016 10:09 am, "Pradeep Kumbhar" > > >

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Yogi Devendra
+1 ~ Yogi On 23 March 2016 at 10:20, Chaitanya Chebolu wrote: > +1 > > On Wed, Mar 23, 2016 at 10:19 AM, HARSH PATHAK > wrote: > > > +1 > > On 23-Mar-2016 10:09 am, "Pradeep Kumbhar" > > wrote: > > > > > +1 > > > > > > On Wed, Mar 23, 2016 at 7:05 AM, Vlad Rozov > > > wrote: > > > > > > > +

[jira] [Commented] (APEXMALHAR-2017) Use pre checkpoint notification to optimize operator IO

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2017?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207881#comment-15207881 ] ASF GitHub Bot commented on APEXMALHAR-2017: Github user chandnisingh com

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-2017 Use pre checkp...

2016-03-22 Thread chandnisingh
Github user chandnisingh commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/218#discussion_r57111096 --- Diff: library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileOutputOperator.java --- @@ -1195,6 +1188,24 @@ public void close()

Re: Streaming JSON parser

2016-03-22 Thread Bhupesh Chawda
A multi-line JSON format is very common and is usually the case with REST API results. I think this could be a valuable addition. Regarding the issues that you mentioned, I think it can be solved by having a custom file splitter which takes care of splitting on a JSON record boundary. +1 for a st

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Chaitanya Chebolu
+1 On Wed, Mar 23, 2016 at 10:19 AM, HARSH PATHAK wrote: > +1 > On 23-Mar-2016 10:09 am, "Pradeep Kumbhar" > wrote: > > > +1 > > > > On Wed, Mar 23, 2016 at 7:05 AM, Vlad Rozov > > wrote: > > > > > +1 (binding) > > > > > > Thank you, > > > > > > Vlad > > > > > > > > > On 3/22/16 12:09, Amol Ke

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread HARSH PATHAK
+1 On 23-Mar-2016 10:09 am, "Pradeep Kumbhar" wrote: > +1 > > On Wed, Mar 23, 2016 at 7:05 AM, Vlad Rozov > wrote: > > > +1 (binding) > > > > Thank you, > > > > Vlad > > > > > > On 3/22/16 12:09, Amol Kekre wrote: > > > >> +1 (binding) > >> > >> Thks > >> Amol > >> > >> > >> On Tue, Mar 22, 2016

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Pradeep Kumbhar
+1 On Wed, Mar 23, 2016 at 7:05 AM, Vlad Rozov wrote: > +1 (binding) > > Thank you, > > Vlad > > > On 3/22/16 12:09, Amol Kekre wrote: > >> +1 (binding) >> >> Thks >> Amol >> >> >> On Tue, Mar 22, 2016 at 10:36 AM, Pramod Immaneni >> wrote: >> >> Dear Community, >>> >>> Based on the positive di

Re: Reg IndexOutOfBoundsException while serializing the object

2016-03-22 Thread Pramod Immaneni
Do you want to dig into the issue Tim? On Tue, Mar 22, 2016 at 8:53 PM, Timothy Farkas wrote: > This is a platform bug I encountered as well. I reported it a while ago. > > https://issues.apache.org/jira/browse/APEXCORE-316 > > I believe the root cause is that when you set the stream codec on a

[jira] [Commented] (APEXMALHAR-2015) Projection Operator

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2015?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207845#comment-15207845 ] ASF GitHub Bot commented on APEXMALHAR-2015: Github user pradeepdalvi com

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-2015: Projection Op...

2016-03-22 Thread pradeepdalvi
Github user pradeepdalvi commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/217#discussion_r57107850 --- Diff: library/src/main/java/com/datatorrent/lib/projection/ProjectionOperator.java --- @@ -0,0 +1,303 @@ +/** + * Licensed to

Re: Reg IndexOutOfBoundsException while serializing the object

2016-03-22 Thread Timothy Farkas
This is a platform bug I encountered as well. I reported it a while ago. https://issues.apache.org/jira/browse/APEXCORE-316 I believe the root cause is that when you set the stream codec on a stream the default is only replaced for the downstream or upstream, but the default stream codec continue

Re: Reg IndexOutOfBoundsException while serializing the object

2016-03-22 Thread Thomas Weise
You don't need to override the stream codec unless you want a different serialization or partitioning than what the default provides. The default codec uses Kryo for serialization and hashCode() for partitioning. On Tue, Mar 22, 2016 at 4:20 PM, Pramod Immaneni wrote: > Venkatesh, > > Any speci

[jira] [Resolved] (APEXCORE-392) Stack Overflow when launching jobs

2016-03-22 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh resolved APEXCORE-392. Resolution: Cannot Reproduce > Stack Overflow when launching jobs > --

[jira] [Closed] (APEXCORE-392) Stack Overflow when launching jobs

2016-03-22 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh closed APEXCORE-392. -- > Stack Overflow when launching jobs > -- > > Key:

[jira] [Resolved] (APEXCORE-393) Reset failure count when consecutive failed node is removed from blacklist

2016-03-22 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved APEXCORE-393. --- Resolution: Fixed > Reset failure count when consecutive failed node is removed from blackli

[jira] [Updated] (APEXCORE-393) Reset failure count when consecutive failed node is removed from blacklist

2016-03-22 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-393?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXCORE-393: -- Fix Version/s: 3.4.0 > Reset failure count when consecutive failed node is removed from blackl

[jira] [Commented] (APEXCORE-393) Reset failure count when consecutive failed node is removed from blacklist

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207699#comment-15207699 ] ASF GitHub Bot commented on APEXCORE-393: - Github user asfgit closed the pull re

[GitHub] incubator-apex-core pull request: APEXCORE-393 #resolve Adding Dag...

2016-03-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-apex-core/pull/274 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the fe

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Vlad Rozov
+1 (binding) Thank you, Vlad On 3/22/16 12:09, Amol Kekre wrote: +1 (binding) Thks Amol On Tue, Mar 22, 2016 at 10:36 AM, Pramod Immaneni wrote: Dear Community, Based on the positive discussion, I'm calling for the community VOTE to graduate Apache Apex (incubating) to top level project

RE: Apex DataFrame

2016-03-22 Thread Ganelin, Ilya
Would love the community's input on this idea and thoughts on technical challenges we may run into when implementing this within Apex. Sent with Good (www.good.com) From: Herger, Brendan Sent: Tuesday, March 22, 2016 7:49:51 PM To: dev@apex.incubator.apache.org

[jira] [Commented] (APEXMALHAR-1897) Create ManagedState

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207624#comment-15207624 ] ASF GitHub Bot commented on APEXMALHAR-1897: Github user chandnisingh com

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-1897 added managed ...

2016-03-22 Thread chandnisingh
Github user chandnisingh commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/145#discussion_r57094062 --- Diff: library/src/main/java/com/datatorrent/lib/state/managed/ManagedTimeStateImpl.java --- @@ -51,63 +51,57 @@ public void put(long

[GitHub] incubator-apex-core pull request: Testing DelayOperator unit test ...

2016-03-22 Thread davidyan74
GitHub user davidyan74 reopened a pull request: https://github.com/apache/incubator-apex-core/pull/284 Testing DelayOperator unit test with travis, DO NOT merge You can merge this pull request into a Git repository by running: $ git pull https://github.com/davidyan74/incubator

[GitHub] incubator-apex-core pull request: Testing DelayOperator unit test ...

2016-03-22 Thread davidyan74
Github user davidyan74 closed the pull request at: https://github.com/apache/incubator-apex-core/pull/284 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if th

[GitHub] incubator-apex-core pull request: Testing DelayOperator unit test ...

2016-03-22 Thread davidyan74
GitHub user davidyan74 opened a pull request: https://github.com/apache/incubator-apex-core/pull/284 Testing DelayOperator unit test with travis, DO NOT merge You can merge this pull request into a Git repository by running: $ git pull https://github.com/davidyan74/incubator-a

[jira] [Created] (APEXCORE-403) DelayOperato unit test fails intermittently

2016-03-22 Thread David Yan (JIRA)
David Yan created APEXCORE-403: -- Summary: DelayOperato unit test fails intermittently Key: APEXCORE-403 URL: https://issues.apache.org/jira/browse/APEXCORE-403 Project: Apache Apex Core Issue Ty

[jira] [Resolved] (APEXCORE-397) Allow configurability of stram web services authentication

2016-03-22 Thread David Yan (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-397?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan resolved APEXCORE-397. Resolution: Fixed Fix Version/s: 3.3.1 3.4.0 > Allow configurability of

[jira] [Commented] (APEXCORE-397) Allow configurability of stram web services authentication

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207597#comment-15207597 ] ASF GitHub Bot commented on APEXCORE-397: - Github user asfgit closed the pull re

[GitHub] incubator-apex-core pull request: APEXCORE-397 Allow configurabili...

2016-03-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-apex-core/pull/277 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the fe

[jira] [Commented] (APEXCORE-393) Reset failure count when consecutive failed node is removed from blacklist

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207563#comment-15207563 ] ASF GitHub Bot commented on APEXCORE-393: - Github user ishark commented on a dif

[GitHub] incubator-apex-core pull request: APEXCORE-393 #resolve Adding Dag...

2016-03-22 Thread ishark
Github user ishark commented on a diff in the pull request: https://github.com/apache/incubator-apex-core/pull/274#discussion_r57090295 --- Diff: engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java --- @@ -950,7 +977,11 @@ private void execute() throws YarnExc

Streaming JSON parser

2016-03-22 Thread Devendra Tagare
Hi All, Starting this thread to get opinions for adding a streaming JSON parser for converting a JSON to POJO.This parser would be in addition to the databind parser (com.fasterxml.jackson.databind) we already have. The advantage of a streaming JSON parser is, 1.The parser need not parse entire

Apex DataFrame

2016-03-22 Thread Herger, Brendan
Hey all, I and the Data Innovation Lab team at Capital One (including Ilya Ganelin, Brennon York, Dongming Liang and Rikin Shah) would like to propose the DataFrame for Apache Apex. We feel that a DataFrame object would solve Apex’s need for a standardized internal data format (schema aware o

[jira] [Commented] (APEXCORE-393) Reset failure count when consecutive failed node is removed from blacklist

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207541#comment-15207541 ] ASF GitHub Bot commented on APEXCORE-393: - Github user tweise commented on the p

[GitHub] incubator-apex-core pull request: APEXCORE-393 #resolve Adding Dag...

2016-03-22 Thread tweise
Github user tweise commented on the pull request: https://github.com/apache/incubator-apex-core/pull/274#issuecomment-200081121 @ishark this looks good! --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project doe

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Devendra Tagare
+ 1 ~Dev On Tue, Mar 22, 2016 at 3:44 PM, Ashish Tadose wrote: > + 1 > > Thanks, > Ashish > > > On 23-Mar-2016, at 3:19 AM, Bright Chen wrote: > > > > +1 > > > > Thanks > > Bright > > > >> On Mar 22, 2016, at 12:13 PM, Sairam Kannan > wrote: > >> > >> +1 > >> On Mar 22, 2016 2:09 PM, "Ashwin

[GitHub] incubator-apex-core pull request: Update security.md

2016-03-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-apex-core/pull/283 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the fe

[jira] [Commented] (APEXCORE-393) Reset failure count when consecutive failed node is removed from blacklist

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207530#comment-15207530 ] ASF GitHub Bot commented on APEXCORE-393: - Github user tweise commented on a dif

[GitHub] incubator-apex-core pull request: APEXCORE-393 #resolve Adding Dag...

2016-03-22 Thread tweise
Github user tweise commented on a diff in the pull request: https://github.com/apache/incubator-apex-core/pull/274#discussion_r57088465 --- Diff: engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java --- @@ -950,7 +977,11 @@ private void execute() throws YarnExc

[jira] [Commented] (APEXCORE-393) Reset failure count when consecutive failed node is removed from blacklist

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-393?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207511#comment-15207511 ] ASF GitHub Bot commented on APEXCORE-393: - Github user tweise commented on a dif

[GitHub] incubator-apex-core pull request: APEXCORE-393 #resolve Adding Dag...

2016-03-22 Thread tweise
Github user tweise commented on a diff in the pull request: https://github.com/apache/incubator-apex-core/pull/274#discussion_r57087518 --- Diff: engine/src/main/java/com/datatorrent/stram/StreamingAppMasterService.java --- @@ -781,18 +794,19 @@ private void execute() throws YarnEx

[GitHub] incubator-apex-core pull request: Update security.md

2016-03-22 Thread trusli
GitHub user trusli opened a pull request: https://github.com/apache/incubator-apex-core/pull/283 Update security.md Corrected some typo and rewrote one sentence. You can merge this pull request into a Git repository by running: $ git pull https://github.com/trusli/incubator-ape

[jira] [Commented] (APEXMALHAR-1897) Create ManagedState

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207508#comment-15207508 ] ASF GitHub Bot commented on APEXMALHAR-1897: Github user amberarrow comme

Re: Reg IndexOutOfBoundsException while serializing the object

2016-03-22 Thread Pramod Immaneni
Venkatesh, Any specific reason you replaced the default stream codec with KryoSerializableStreamCodec? Also what apex version are you using? Thanks On Tue, Mar 22, 2016 at 4:16 PM, Kottapalli, Venkatesh < vkottapa...@directv.com> wrote: > Yes Ashwin, It has the default constructor as below. > >

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-1897 added managed ...

2016-03-22 Thread amberarrow
Github user amberarrow commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/145#discussion_r57086936 --- Diff: library/src/main/java/com/datatorrent/lib/state/managed/ManagedTimeStateImpl.java --- @@ -51,63 +51,57 @@ public void put(long b

RE: Reg IndexOutOfBoundsException while serializing the object

2016-03-22 Thread Kottapalli, Venkatesh
Yes Ashwin, It has the default constructor as below. public Results() { super(); } -Venkatesh. -Original Message- From: Ashwin Chandra Putta [mailto:ashwinchand...@gmail.com] Sent: Tuesday, March 22, 2016 4:07 PM To: dev@apex.incubator.apache.org Subject: Re: Reg IndexOutOfBound

Re: Reg IndexOutOfBoundsException while serializing the object

2016-03-22 Thread Ashwin Chandra Putta
For any class to be serializable by kryo, it needs to have the default no arg constructor. Regards, Ashwin. On Tue, Mar 22, 2016 at 3:56 PM, Kottapalli, Venkatesh < vkottapa...@directv.com> wrote: > Yes Ashwin, I know the details of the class. It is a new class that I have > added to the project

[jira] [Commented] (APEXCORE-397) Allow configurability of stram web services authentication

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207477#comment-15207477 ] ASF GitHub Bot commented on APEXCORE-397: - Github user davidyan74 commented on a

[GitHub] incubator-apex-core pull request: APEXCORE-397 Allow configurabili...

2016-03-22 Thread davidyan74
Github user davidyan74 commented on a diff in the pull request: https://github.com/apache/incubator-apex-core/pull/277#discussion_r57084367 --- Diff: engine/src/test/java/com/datatorrent/stram/util/SecurityUtilsTest.java --- @@ -0,0 +1,64 @@ +/** + * Licensed to the Apache

RE: Reg IndexOutOfBoundsException while serializing the object

2016-03-22 Thread Kottapalli, Venkatesh
Yes Ashwin, I know the details of the class. It is a new class that I have added to the project. Do I have check that for anything specific that might cause this issue? -Venkatesh. -Original Message- From: Ashwin Chandra Putta [mailto:ashwinchand...@gmail.com] Sent: Tuesday, March 22,

[jira] [Commented] (APEXMALHAR-1897) Create ManagedState

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207466#comment-15207466 ] ASF GitHub Bot commented on APEXMALHAR-1897: Github user amberarrow comme

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-1897 added managed ...

2016-03-22 Thread amberarrow
Github user amberarrow commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/145#discussion_r57083270 --- Diff: library/src/main/java/com/datatorrent/lib/state/managed/ManagedTimeStateImpl.java --- @@ -0,0 +1,125 @@ +/** + * License

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Ashish Tadose
+ 1 Thanks, Ashish > On 23-Mar-2016, at 3:19 AM, Bright Chen wrote: > > +1 > > Thanks > Bright > >> On Mar 22, 2016, at 12:13 PM, Sairam Kannan wrote: >> >> +1 >> On Mar 22, 2016 2:09 PM, "Ashwin Chandra Putta" >> wrote: >> >>> +1 >>> >>> Regards, >>> Ashwin. >>> >>> On Tue, Mar 22, 201

[jira] [Commented] (APEXMALHAR-1897) Create ManagedState

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1897?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207439#comment-15207439 ] ASF GitHub Bot commented on APEXMALHAR-1897: Github user chandnisingh com

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-1897 added managed ...

2016-03-22 Thread chandnisingh
Github user chandnisingh commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/145#discussion_r57081100 --- Diff: library/src/main/java/com/datatorrent/lib/state/managed/ManagedTimeStateImpl.java --- @@ -0,0 +1,125 @@ +/** + * Licen

Re: Reg IndexOutOfBoundsException while serializing the object

2016-03-22 Thread Ashwin Chandra Putta
Venkatesh, Do you know the name of the class it is not finding? Is it any new dependency you added to the project? Regards, Ashwin. On Tue, Mar 22, 2016 at 3:03 PM, Kottapalli, Venkatesh < vkottapa...@directv.com> wrote: > Hi, > > I ran into the below issues while running the ap

Re: [DISCUSS] [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread P. Taylor Goetz
Yes, committers carry over. -Taylor > On Mar 22, 2016, at 2:47 PM, Thomas Weise wrote: > > My understanding is committers are automatically carried over. Can mentors > please confirm? > > >> On Tue, Mar 22, 2016 at 11:41 AM, Atri Sharma wrote: >> >> Do the committers retain their committer

Reg IndexOutOfBoundsException while serializing the object

2016-03-22 Thread Kottapalli, Venkatesh
Hi, I ran into the below issues while running the app today. Any inputs on why this is happening? I see this JIRA raised already but closed as "Not reproducible". https://malhar.atlassian.net/browse/MLHR-1709 Stopped running due to an exception. java.lang.IndexOutOf

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Bright Chen
+1 Thanks Bright > On Mar 22, 2016, at 12:13 PM, Sairam Kannan wrote: > > +1 > On Mar 22, 2016 2:09 PM, "Ashwin Chandra Putta" > wrote: > >> +1 >> >> Regards, >> Ashwin. >> >> On Tue, Mar 22, 2016 at 11:41 AM, Chinmay Kolhatkar < >> chin...@datatorrent.com >>> wrote: >> >>> +1. >>> >>> Re

RE: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Ganelin, Ilya
+1 [binding] Sent with Good (www.good.com) From: Sairam Kannan Sent: Tuesday, March 22, 2016 3:13:16 PM To: dev@apex.incubator.apache.org Subject: Re: [VOTE] Graduate Apex from the Incubator +1 On Mar 22, 2016 2:09 PM, "Ashwin Chandra Putta" wrote: > +1 > > R

[jira] [Comment Edited] (APEXCORE-392) Stack Overflow when launching jobs

2016-03-22 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207364#comment-15207364 ] Chandni Singh edited comment on APEXCORE-392 at 3/22/16 9:37 PM: -

[jira] [Commented] (APEXCORE-392) Stack Overflow when launching jobs

2016-03-22 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207364#comment-15207364 ] Chandni Singh commented on APEXCORE-392: [~ilganeli] I highly suspect that it ca

[jira] [Resolved] (APEXCORE-326) Iteration causes problems when there are multiple streams between two operators

2016-03-22 Thread David Yan (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-326?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan resolved APEXCORE-326. Resolution: Fixed Assignee: Bhupesh Chawda (was: David Yan) Fix Version/s: 3.3.1

[jira] [Commented] (APEXCORE-326) Iteration causes problems when there are multiple streams between two operators

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207346#comment-15207346 ] ASF GitHub Bot commented on APEXCORE-326: - Github user asfgit closed the pull re

[GitHub] incubator-apex-core pull request: APEXCORE-326: Bug fix. Added uni...

2016-03-22 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/incubator-apex-core/pull/282 --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your project does not have this feature enabled and wishes so, or if the fe

[jira] [Commented] (APEXCORE-392) Stack Overflow when launching jobs

2016-03-22 Thread Ilya Ganelin (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207343#comment-15207343 ] Ilya Ganelin commented on APEXCORE-392: --- [~csingh] The issue is not due to incompa

[jira] [Commented] (APEXCORE-392) Stack Overflow when launching jobs

2016-03-22 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-392?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207297#comment-15207297 ] Chandni Singh commented on APEXCORE-392: The bug cannot be reproduced and seems

[jira] [Commented] (APEXCORE-397) Allow configurability of stram web services authentication

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207285#comment-15207285 ] ASF GitHub Bot commented on APEXCORE-397: - Github user davidyan74 commented on a

[GitHub] incubator-apex-core pull request: APEXCORE-397 Allow configurabili...

2016-03-22 Thread davidyan74
Github user davidyan74 commented on a diff in the pull request: https://github.com/apache/incubator-apex-core/pull/277#discussion_r57067551 --- Diff: api/src/main/java/com/datatorrent/api/Context.java --- @@ -101,6 +101,20 @@ String getJVMOptions(List operatorMetaList);

[jira] [Updated] (APEXCORE-392) Stack Overflow when launching jobs

2016-03-22 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-392?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXCORE-392: --- Priority: Major (was: Blocker) > Stack Overflow when launching jobs > -

[jira] [Commented] (APEXCORE-397) Allow configurability of stram web services authentication

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-397?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207207#comment-15207207 ] ASF GitHub Bot commented on APEXCORE-397: - Github user PramodSSImmaneni commente

[GitHub] incubator-apex-core pull request: APEXCORE-397 Allow configurabili...

2016-03-22 Thread PramodSSImmaneni
Github user PramodSSImmaneni commented on a diff in the pull request: https://github.com/apache/incubator-apex-core/pull/277#discussion_r57061658 --- Diff: api/src/main/java/com/datatorrent/api/Context.java --- @@ -101,6 +101,20 @@ String getJVMOptions(List operatorMetaList

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Amol Kekre
Atri, Yes they do. Thks Amol On Tue, Mar 22, 2016 at 11:41 AM, Atri Sharma wrote: > Do the committers retain their committer rights, when the project graduates > to TLP (non PMC members)? > > +1 for graduation > > On Tue, Mar 22, 2016 at 11:43 PM, Siyuan Hua > wrote: > > > +1 > > > > On Tue,

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Ashwin Chandra Putta
+1 Regards, Ashwin. On Tue, Mar 22, 2016 at 11:41 AM, Chinmay Kolhatkar wrote: > +1. > > Regards, > Chinmay. > > --- > Sent from mobile. > On 22 Mar 2016 11:55 p.m., "Milind Barve" wrote: > > > +1 > > > > Regards, > > ~Milind > > On Mar 22, 2016 11:50 PM, "Tushar Gosavi" > wrote: > > > > > +1

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Amol Kekre
+1 (binding) Thks Amol On Tue, Mar 22, 2016 at 10:36 AM, Pramod Immaneni wrote: > Dear Community, > > Based on the positive discussion, I'm calling for the community VOTE > to graduate Apache Apex (incubating) to top level project (TLP). > > Please vote on the resolution pasted below. > > [ ]

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Sairam Kannan
+1 On Mar 22, 2016 2:09 PM, "Ashwin Chandra Putta" wrote: > +1 > > Regards, > Ashwin. > > On Tue, Mar 22, 2016 at 11:41 AM, Chinmay Kolhatkar < > chin...@datatorrent.com > > wrote: > > > +1. > > > > Regards, > > Chinmay. > > > > --- > > Sent from mobile. > > On 22 Mar 2016 11:55 p.m., "Milind Bar

[jira] [Commented] (APEXCORE-326) Iteration causes problems when there are multiple streams between two operators

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207061#comment-15207061 ] ASF GitHub Bot commented on APEXCORE-326: - Github user bhupeshchawda commented o

[GitHub] incubator-apex-core pull request: APEXCORE-326: Bug fix. Added uni...

2016-03-22 Thread bhupeshchawda
Github user bhupeshchawda commented on the pull request: https://github.com/apache/incubator-apex-core/pull/282#issuecomment-199967100 @davidyan74 Please review --- If your project is set up for it, you can reply to this email and have your reply appear on GitHub as well. If your pro

Re: [DISCUSS] [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Amol Kekre
I believe so too. Even if it an official policy, we should carry over committers as is. Thks Amol On Tue, Mar 22, 2016 at 11:47 AM, Thomas Weise wrote: > My understanding is committers are automatically carried over. Can mentors > please confirm? > > > On Tue, Mar 22, 2016 at 11:41 AM, Atri Sh

Re: [DISCUSS] [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Amol Kekre
Sorry I meant "Even if it *not *an official policy, ..." Thks Amol On Tue, Mar 22, 2016 at 12:11 PM, Amol Kekre wrote: > > I believe so too. Even if it an official policy, we should carry over > committers as is. > > Thks > Amol > > > On Tue, Mar 22, 2016 at 11:47 AM, Thomas Weise > wrote: > >

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Bhupesh Chawda
+1 ~Bhupesh On Wed, Mar 23, 2016 at 12:11 AM, Chinmay Kolhatkar wrote: > +1. > > Regards, > Chinmay. > > --- > Sent from mobile. > On 22 Mar 2016 11:55 p.m., "Milind Barve" wrote: > > > +1 > > > > Regards, > > ~Milind > > On Mar 22, 2016 11:50 PM, "Tushar Gosavi" > wrote: > > > > > +1 > > > >

[jira] [Commented] (APEXCORE-326) Iteration causes problems when there are multiple streams between two operators

2016-03-22 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15207039#comment-15207039 ] ASF GitHub Bot commented on APEXCORE-326: - GitHub user bhupeshchawda opened a pu

[GitHub] incubator-apex-core pull request: APEXCORE-326: Bug fix. Added uni...

2016-03-22 Thread bhupeshchawda
GitHub user bhupeshchawda opened a pull request: https://github.com/apache/incubator-apex-core/pull/282 APEXCORE-326: Bug fix. Added unit test. Fixed validation in case of multiple streams between two operators. You can merge this pull request into a Git repository by running:

[DISCUSS] [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Thomas Weise
My understanding is committers are automatically carried over. Can mentors please confirm? On Tue, Mar 22, 2016 at 11:41 AM, Atri Sharma wrote: > Do the committers retain their committer rights, when the project graduates > to TLP (non PMC members)? > > +1 for graduation > > On Tue, Mar 22, 201

Re: [VOTE] Graduate Apex from the Incubator

2016-03-22 Thread Atri Sharma
Do the committers retain their committer rights, when the project graduates to TLP (non PMC members)? +1 for graduation On Tue, Mar 22, 2016 at 11:43 PM, Siyuan Hua wrote: > +1 > > On Tue, Mar 22, 2016 at 10:36 AM, Pramod Immaneni > wrote: > > > Dear Community, > > > > Based on the positive di

  1   2   >