[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

2016-10-19 Thread Chaitanya (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588040#comment-15588040 ] Chaitanya commented on APEXMALHAR-2284: --- Join operator uses: 1) put(Slice key,

[jira] [Commented] (APEXMALHAR-2301) Implement another TimeBucketAssigner to work with any time

2016-10-19 Thread Bhupesh Chawda (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2301?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588154#comment-15588154 ] Bhupesh Chawda commented on APEXMALHAR-2301: Hi Siyuan, Just wondering a

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

2016-10-19 Thread Bhupesh Chawda (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588218#comment-15588218 ] Bhupesh Chawda commented on APEXMALHAR-2284: If ManagedTimeStateMultiValu

[jira] [Created] (APEXMALHAR-2309) TimeBasedDedupOperator marks new tuples as duplicates if expired tuples exist

2016-10-19 Thread Francis Fernandes (JIRA)
Francis Fernandes created APEXMALHAR-2309: - Summary: TimeBasedDedupOperator marks new tuples as duplicates if expired tuples exist Key: APEXMALHAR-2309 URL: https://issues.apache.org/jira/browse/APEXMALHAR

[jira] [Updated] (APEXMALHAR-2038) Whilelist tests in contrib instead of skipTests=true

2016-10-19 Thread Chinmay Kolhatkar (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar updated APEXMALHAR-2038: -- Assignee: (was: Chinmay Kolhatkar) > Whilelist tests in contrib instead

[jira] [Updated] (APEXMALHAR-2038) Whilelist tests in contrib instead of skipTests=true

2016-10-19 Thread Chinmay Kolhatkar (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2038?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar updated APEXMALHAR-2038: -- Labels: newbie (was: ) > Whilelist tests in contrib instead of skipTests=t

[jira] [Updated] (APEXMALHAR-1963) Add abstract operator for Async Processing

2016-10-19 Thread Chinmay Kolhatkar (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1963?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar updated APEXMALHAR-1963: -- Assignee: (was: Chinmay Kolhatkar) > Add abstract operator for Async Pr

[jira] [Updated] (APEXMALHAR-2117) JDBCLoader for Enricher should generate default queryStmt even when value is empty string

2016-10-19 Thread Chinmay Kolhatkar (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2117?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar updated APEXMALHAR-2117: -- Assignee: (was: Chinmay Kolhatkar) > JDBCLoader for Enricher should gen

[jira] [Updated] (APEXMALHAR-2150) Allow enricher to map input fields and db columns to output fields

2016-10-19 Thread Chinmay Kolhatkar (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2150?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar updated APEXMALHAR-2150: -- Assignee: (was: Chinmay Kolhatkar) > Allow enricher to map input fields

[jira] [Created] (APEXCORE-562) RecordingsAgent: returns records for offset beyond number of tuples

2016-10-19 Thread Priyanka Gugale (JIRA)
Priyanka Gugale created APEXCORE-562: Summary: RecordingsAgent: returns records for offset beyond number of tuples Key: APEXCORE-562 URL: https://issues.apache.org/jira/browse/APEXCORE-562 Project

[jira] [Commented] (APEXCORE-562) RecordingsAgent: returns records for offset beyond number of tuples

2016-10-19 Thread Priyanka Gugale (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588531#comment-15588531 ] Priyanka Gugale commented on APEXCORE-562: -- getTuplesInfo function incorrectly

[jira] [Updated] (APEXCORE-562) RecordingsAgent: returns records for offset beyond number of tuples

2016-10-19 Thread Priyanka Gugale (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Priyanka Gugale updated APEXCORE-562: - Affects Version/s: 3.4.0 > RecordingsAgent: returns records for offset beyond number of

[jira] [Commented] (APEXCORE-562) RecordingsAgent: returns records for offset beyond number of tuples

2016-10-19 Thread Priyanka Gugale (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588709#comment-15588709 ] Priyanka Gugale commented on APEXCORE-562: -- [~thw] please add me as contributor

Re: [jira] [Assigned] (APEXMALHAR-2303) S3 Line By Line Module

2016-10-19 Thread AJAY GUPTA
Hi I need suggestion of Apex dev community on the following. For the S3RecordReader approach mentioned in previous mail, I am facing an issue with determining the end of file. Note that the input to this operator will not contain the file size. Following approaches are possible 1) The S3 getObj

[jira] [Updated] (APEXCORE-562) RecordingsAgent: returns records for offset beyond number of tuples

2016-10-19 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-562?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXCORE-562: -- Assignee: Priyanka Gugale > RecordingsAgent: returns records for offset beyond number of tuple

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

2016-10-19 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588941#comment-15588941 ] Chandni Singh commented on APEXMALHAR-2284: --- [~bhup...@apache.org], [~chait

[jira] [Comment Edited] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

2016-10-19 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588941#comment-15588941 ] Chandni Singh edited comment on APEXMALHAR-2284 at 10/19/16 2:36 PM: --

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

2016-10-19 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588953#comment-15588953 ] Thomas Weise commented on APEXMALHAR-2284: -- Have a look at this PR: https://

Re: CFP for upcoming big data conferences

2016-10-19 Thread Thomas Weise
Strata Hadoop London CFP is open, so maybe we should submit these topics there also. http://conferences.oreilly.com/strata/strata-eu On Mon, Oct 17, 2016 at 4:22 PM, Thomas Weise wrote: > It is good to see security as topic. > > This would make a good webcast also ;-) > > On Mon, Oct 17, 2016

Re: CFP for upcoming big data conferences

2016-10-19 Thread Pramod Immaneni
Sounds good. I will submit the same. > On Oct 19, 2016, at 10:43 AM, Thomas Weise wrote: > > Strata Hadoop London CFP is open, so maybe we should submit these topics > there also. > > http://conferences.oreilly.com/strata/strata-eu > > >> On Mon, Oct 17, 2016 at 4:22 PM, Thomas Weise wrote: >> >

[GitHub] apex-malhar pull request #458: APEXMALHAR-2305 #resolve Mirror the proto-ses...

2016-10-19 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/apex-malhar/pull/458 --- 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 feature is

[jira] [Resolved] (APEXMALHAR-2305) Change implementation of session window to reflect what is described in streaming 102 blog

2016-10-19 Thread David Yan (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2305?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan resolved APEXMALHAR-2305. --- Resolution: Fixed Fix Version/s: 3.6.0 > Change implementation of session window t

[jira] [Resolved] (APEXMALHAR-2307) Session windows are not deleted properly after merge or extend in InMemorySessionWindowedStorage

2016-10-19 Thread David Yan (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2307?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan resolved APEXMALHAR-2307. --- Resolution: Fixed Fix Version/s: 3.6.0 > Session windows are not deleted properly

[jira] [Commented] (APEXMALHAR-2305) Change implementation of session window to reflect what is described in streaming 102 blog

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

[jira] [Updated] (APEXCORE-235) Improve support for batch processing

2016-10-19 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-235?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXCORE-235: -- Summary: Improve support for batch processing (was: Explicit support for batch processing) >

[jira] [Updated] (APEXCORE-119) Add Support For A New Type Of (Distributed) Operator

2016-10-19 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-119?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXCORE-119: -- Labels: (was: roadmap) > Add Support For A New Type Of (Distributed) Operator >

[jira] [Updated] (APEXCORE-231) Ability to change attributes at runtime

2016-10-19 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXCORE-231: -- Summary: Ability to change attributes at runtime (was: Ability to configure attributes dynami

[jira] [Commented] (APEXMALHAR-2305) Change implementation of session window to reflect what is described in streaming 102 blog

2016-10-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2305?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15590422#comment-15590422 ] ASF GitHub Bot commented on APEXMALHAR-2305: GitHub user davidyan74 opene

[GitHub] apex-core pull request #412: APEXCORE-562: RecordingsAgent returns records f...

2016-10-19 Thread DT-Priyanka
GitHub user DT-Priyanka opened a pull request: https://github.com/apache/apex-core/pull/412 APEXCORE-562: RecordingsAgent returns records for offset beyond number of tuples You can merge this pull request into a Git repository by running: $ git pull https://github.com/DT-Priy

[jira] [Commented] (APEXCORE-562) RecordingsAgent: returns records for offset beyond number of tuples

2016-10-19 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-562?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15590813#comment-15590813 ] ASF GitHub Bot commented on APEXCORE-562: - GitHub user DT-Priyanka opened a pull

Re: [jira] [Assigned] (APEXMALHAR-2303) S3 Line By Line Module

2016-10-19 Thread AJAY GUPTA
Hi Following is another approach for getting information regarding the file length for S3. We have an existing class FileBlockMetadata which currently contains only filePath. To this, we can add the fileLength field which will then get passed to the module. This approach will be a lot cleaner and

Re: [jira] [Assigned] (APEXMALHAR-2303) S3 Line By Line Module

2016-10-19 Thread Tushar Gosavi
I think this approach is clean compare to previous two approached you have mentioned. Depending on exception/non standard error code to determine eof is not good approach, as we might consider other valid exception as eof and not take corrective actions. Also this will avoid multiple request to get