[jira] [Commented] (APEXMALHAR-2086) Kafka Output Operator with Kafka 0.9 API

2016-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15358430#comment-15358430 ] ASF GitHub Bot commented on APEXMALHAR-2086: Github user tweise commented on a diff in

[jira] [Commented] (APEXMALHAR-2086) Kafka Output Operator with Kafka 0.9 API

2016-06-30 Thread Sandesh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15358427#comment-15358427 ] Sandesh commented on APEXMALHAR-2086: - Most of the work went into writing Exactly Once output

[jira] [Commented] (APEXMALHAR-2086) Kafka Output Operator with Kafka 0.9 API

2016-06-30 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15358398#comment-15358398 ] Thomas Weise commented on APEXMALHAR-2086: -- Isn't the producer API in 0.9 same as 0.8.x? If

[jira] [Commented] (APEXMALHAR-2045) Add bandwidth control feature to Apex

2016-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15358369#comment-15358369 ] ASF GitHub Bot commented on APEXMALHAR-2045: Github user asfgit closed the pull request

[jira] [Resolved] (APEXMALHAR-2045) Add bandwidth control feature to Apex

2016-06-30 Thread Vlad Rozov (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vlad Rozov resolved APEXMALHAR-2045. Resolution: Done Fix Version/s: 3.5.0 > Add bandwidth control feature to Apex >

[GitHub] apex-malhar pull request #279: APEXMALHAR-2045: Adding bandwidth control fea...

2016-06-30 Thread asfgit
Github user asfgit closed the pull request at: https://github.com/apache/apex-malhar/pull/279 --- 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

[jira] [Commented] (APEXMALHAR-2069) FileSplitterInput and TimeBasedDirectoryScanner - move operational fields initialization from constructor to setup

2016-06-30 Thread ASF GitHub Bot (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15358192#comment-15358192 ] ASF GitHub Bot commented on APEXMALHAR-2069: Github user sanjaypujare closed the pull

[jira] [Commented] (APEXMALHAR-2069) FileSplitterInput and TimeBasedDirectoryScanner - move operational fields initialization from constructor to setup

2016-06-30 Thread Sanjay M Pujare (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15358074#comment-15358074 ] Sanjay M Pujare commented on APEXMALHAR-2069: - [~csingh] Can you comment on how we can

[jira] [Commented] (APEXMALHAR-2069) FileSplitterInput and TimeBasedDirectoryScanner - move operational fields initialization from constructor to setup

2016-06-30 Thread Sanjay M Pujare (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15358061#comment-15358061 ] Sanjay M Pujare commented on APEXMALHAR-2069: - > IMO, it is safer to create new execution

[jira] [Updated] (APEXMALHAR-2130) implement scalable windowed storage

2016-06-30 Thread David Yan (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan updated APEXMALHAR-2130: -- Description: This feature is used for supporting windowing. The storage needs to have the

[jira] [Updated] (APEXMALHAR-2130) implement scalable windowed storage

2016-06-30 Thread David Yan (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan updated APEXMALHAR-2130: -- Description: This feature is used for supporting windowing. The storage needs to have the

[jira] [Updated] (APEXMALHAR-2130) implement scalable windowed storage

2016-06-30 Thread David Yan (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan updated APEXMALHAR-2130: -- Description: This feature is used for supporting windowing. The storage needs to have the

[jira] [Updated] (APEXMALHAR-2130) implement scalable windowed storage

2016-06-30 Thread David Yan (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan updated APEXMALHAR-2130: -- Description: This feature is used for supporting windowing. The storage needs to have the

[jira] [Updated] (APEXMALHAR-2130) implement scalable windowed storage

2016-06-30 Thread David Yan (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan updated APEXMALHAR-2130: -- Description: This feature is used for supporting windowing. The storage needs to have the

[jira] [Commented] (APEXMALHAR-2069) FileSplitterInput and TimeBasedDirectoryScanner - move operational fields initialization from constructor to setup

2016-06-30 Thread Sanjay M Pujare (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15357592#comment-15357592 ] Sanjay M Pujare commented on APEXMALHAR-2069: - Yes, I noticed that but the actual test

[jira] [Updated] (APEXMALHAR-2130) implement scalable windowed storage

2016-06-30 Thread bright chen (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] bright chen updated APEXMALHAR-2130: Description: This feature is used for supporting windowing. > implement scalable

[jira] [Commented] (APEXMALHAR-2069) FileSplitterInput and TimeBasedDirectoryScanner - move operational fields initialization from constructor to setup

2016-06-30 Thread Sanjay M Pujare (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2069?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15357517#comment-15357517 ] Sanjay M Pujare commented on APEXMALHAR-2069: - Without the null check I get the following

[jira] [Commented] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-06-30 Thread Thomas Weise (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15357484#comment-15357484 ] Thomas Weise commented on APEXMALHAR-2129: -- It still isn't clear to me why this would be

[GitHub] apex-malhar pull request #326: APEXMALHAR-2116 Added FS record reader operat...

2016-06-30 Thread yogidevendra
Github user yogidevendra commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/326#discussion_r69111489 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordReaderModule.java --- @@ -0,0 +1,332 @@ +/** + * Licensed to the

[jira] [Commented] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-06-30 Thread Bhupesh Chawda (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15356775#comment-15356775 ] Bhupesh Chawda commented on APEXMALHAR-2129: Okay, sure. Just another point: Disabling