[GitHub] apex-malhar pull request #327: Review-Only WindowedStream API

GitHub user siyuanh opened a pull request: https://github.com/apache/apex-malhar/pull/327 Review-Only WindowedStream API This is for review only, please ignore all checkstyle violations, format issue etc. For windowed operator changes, refer to

[jira] [Updated] (APEXMALHAR-2068) FileSplitter- having multiple file splitters in an application results in incorrect behavior

[ https://issues.apache.org/jira/browse/APEXMALHAR-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vlad Rozov updated APEXMALHAR-2068: --- Assignee: Chandni Singh > FileSplitter- having multiple file splitters in an application

[jira] [Updated] (APEXMALHAR-2068) FileSplitter- having multiple file splitters in an application results in incorrect behavior

[ https://issues.apache.org/jira/browse/APEXMALHAR-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vlad Rozov updated APEXMALHAR-2068: --- Assignee: (was: Chandni Singh) > FileSplitter- having multiple file splitters in an

[jira] [Commented] (APEXCORE-222) Delegate Buffer Server purge to StreamingContainer

[ https://issues.apache.org/jira/browse/APEXCORE-222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347248#comment-15347248 ] ASF GitHub Bot commented on APEXCORE-222: - Github user vrozov commented on a diff in the pull

[jira] [Created] (APEXCORE-474) Default unifier placement during M*1 deployment

Sandesh created APEXCORE-474: Summary: Default unifier placement during M*1 deployment Key: APEXCORE-474 URL: https://issues.apache.org/jira/browse/APEXCORE-474 Project: Apache Apex Core Issue

Re: Update to apex.apache.org site?

+1 to the redesign. Great idea! On 6/23/16, 10:08 AM, "Amol Kekre" wrote: >Wanted to see what the community thinks of re-design off apex.apache.org >site. Do comment on "Is is time to do a re-design". > >If we all think it is time for a re-design given that Apex is top

Re: Update to apex.apache.org site?

+1 I personally think "announcement" and "upcoming meetups" take too much space on the home page while features/introduction to apex should have taken more space. On Thu, Jun 23, 2016 at 10:16 AM, Thomas Weise wrote: > +1 > > There are a couple of related JIRAs: > > >

[jira] [Commented] (APEXCORE-417) Web site: Improve landing page

[ https://issues.apache.org/jira/browse/APEXCORE-417?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346791#comment-15346791 ] Amol Kekre commented on APEXCORE-417: - We should take a look at the following sites as examples -

Update to apex.apache.org site?

Wanted to see what the community thinks of re-design off apex.apache.org site. Do comment on "Is is time to do a re-design". If we all think it is time for a re-design given that Apex is top level project, here are some thoughts that IMHO should be taken up. - Have a powered by Apex page - Bring

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346565#comment-15346565 ] ASF GitHub Bot commented on APEXMALHAR-2045: Github user vrozov commented on a diff in

Re: Should YARN_APPLICATION_TYPE be changed to ApacheApex from DataTorrent

We should capture these things in JIRA and put a label like "major-release" so that we don't forget it when the time comes. On Thu, Jun 23, 2016 at 7:34 AM, Sandesh Hegde wrote: > It is a backward incompatible change. That's used to list Apex apps. > > On Thu, Jun 23,

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

Github user vrozov commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/279#discussion_r68251593 --- Diff: library/src/test/java/com/datatorrent/lib/bandwidth/BandwidthManagerTest.java --- @@ -0,0 +1,150 @@ +/** + * Licensed to the Apache

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

Github user amberarrow commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/326#discussion_r68229511 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordReaderModule.java --- @@ -0,0 +1,331 @@ +/** + * Licensed to the

[jira] [Commented] (APEXMALHAR-2116) File Record reader module

[ https://issues.apache.org/jira/browse/APEXMALHAR-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346391#comment-15346391 ] ASF GitHub Bot commented on APEXMALHAR-2116: Github user amberarrow commented on a diff

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

Github user amberarrow commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/326#discussion_r68229454 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordReaderModule.java --- @@ -0,0 +1,331 @@ +/** + * Licensed to the

[jira] [Commented] (APEXMALHAR-2116) File Record reader module

[ https://issues.apache.org/jira/browse/APEXMALHAR-2116?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15346390#comment-15346390 ] ASF GitHub Bot commented on APEXMALHAR-2116: Github user amberarrow commented on a diff

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

Github user amberarrow commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/326#discussion_r68229363 --- Diff: library/src/main/java/org/apache/apex/malhar/lib/fs/FSRecordReaderModule.java --- @@ -0,0 +1,331 @@ +/** + * Licensed to the

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

Github user DT-Priyanka commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/279#discussion_r68220624 --- Diff: library/src/test/java/com/datatorrent/lib/bandwidth/BandwidthManagerTest.java --- @@ -0,0 +1,150 @@ +/** + * Licensed to the

Re: Should YARN_APPLICATION_TYPE be changed to ApacheApex from DataTorrent

Yes, good idea. Will that be a backward compatible change? I think, we should wait for 4.0. On Thu, Jun 23, 2016 at 1:44 PM, Aniruddha Thombare < anirud...@datatorrent.com> wrote: > Hi, > > StramClient.java still refers the yarn application type to be > "DataTorrent". > Should it be ApacheApex?

Listing Apex under hadoop-related projects on hadoop page

Hi All, Hadoop main page http://hadoop.apache.org/ lists hadoop-related projects. Apex being hadoop native should also be listed there. Can we explore option to be listed there? Regards, Sandeep

[GitHub] apex-core pull request #350: APEXCORE-222 Purging the stale data present in ...

Github user sandeshh commented on a diff in the pull request: https://github.com/apache/apex-core/pull/350#discussion_r68184470 --- Diff: engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java --- @@ -769,7 +769,11 @@ public void

[GitHub] apex-malhar pull request #295: APEXMALHAR-1966: Update cassandra output opre...

Github user DT-Priyanka commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/295#discussion_r68182365 --- Diff: contrib/src/main/java/com/datatorrent/contrib/cassandra/AbstractCassandraTransactionableOutputOperator.java --- @@ -48,29 +54,58 @@

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

Github user DT-Priyanka commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/279#discussion_r68181372 --- Diff: library/src/test/java/com/datatorrent/lib/bandwidth/BandwidthManagerTest.java --- @@ -0,0 +1,150 @@ +/** + * Licensed to the

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

Github user DT-Priyanka commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/279#discussion_r68180956 --- Diff: library/src/test/java/com/datatorrent/lib/bandwidth/BandwidthManagerTest.java --- @@ -0,0 +1,150 @@ +/** + * Licensed to the

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345868#comment-15345868 ] ASF GitHub Bot commented on APEXMALHAR-2086: Github user siyuanh commented on a diff in

[GitHub] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output: 0.9.1 first c...

Github user siyuanh commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/298#discussion_r68180895 --- Diff: kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java --- @@ -0,0 +1,369 @@ +/** + *

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345859#comment-15345859 ] ASF GitHub Bot commented on APEXMALHAR-2086: Github user siyuanh commented on a diff in

[GitHub] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output: 0.9.1 first c...

Github user siyuanh commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/298#discussion_r68180501 --- Diff: kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java --- @@ -0,0 +1,369 @@ +/** + *

[jira] [Commented] (APEXMALHAR-1966) Cassandra output operator improvements

[ https://issues.apache.org/jira/browse/APEXMALHAR-1966?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345854#comment-15345854 ] ASF GitHub Bot commented on APEXMALHAR-1966: Github user bhupeshchawda commented on a

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345851#comment-15345851 ] ASF GitHub Bot commented on APEXMALHAR-2045: Github user DT-Priyanka commented on a diff

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345850#comment-15345850 ] ASF GitHub Bot commented on APEXMALHAR-2045: Github user DT-Priyanka commented on a diff

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

Github user DT-Priyanka commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/279#discussion_r68180270 --- Diff: library/src/main/java/com/datatorrent/lib/bandwidth/BandwidthPartitioner.java --- @@ -0,0 +1,78 @@ +/** + * Licensed to the

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

Github user DT-Priyanka commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/279#discussion_r68180287 --- Diff: library/src/main/java/com/datatorrent/lib/bandwidth/BandwidthManager.java --- @@ -0,0 +1,139 @@ +/** + * Licensed to the Apache

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345837#comment-15345837 ] ASF GitHub Bot commented on APEXMALHAR-2086: Github user siyuanh commented on a diff in

[GitHub] apex-malhar pull request #298: [APEXMALHAR-2086] Kafka output: 0.9.1 first c...

Github user siyuanh commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/298#discussion_r68179972 --- Diff: kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java --- @@ -0,0 +1,369 @@ +/** + *