[jira] [Commented] (APEXCORE-718) How to Use one Kafka input operator and Feed to multiple operator

Did any one got a chance to look at it .. -- ---RohitGarg.

Re: Image processing library

The injunction that tuple processing should be "as fast as possible" is based on anassumption and a fact: 1. In most cases, users want to maximize application throughput.2. If a callback (like beginWindow(), process(), endWindow(), etc.) takes too long,    the platform deems the operator hung

Re: Image processing library

I guess the use cases as documented look really compelling. There might be more comments from code review perspective and below is more from a use case perspective only. I was wondering if you have any latency measurements for the tests you ran. If the image processing calls ( in the process

Re: Proposal to upgrade Apex Core dependency in Malhar to 3.6

+1 On Thu, May 11, 2017 at 5:51 AM, AJAY GUPTA wrote: > Hi all, > > Apex Malhar currently depends on core 3.4. Custom tuple support has been > added to core in 3.6. Hence, malhar dependency needs to be updated. > This is necessary for changing the malhar operators for

[jira] [Commented] (APEXCORE-712) Support distribution of custom SSL material to the Stram node while launch the app

[ https://issues.apache.org/jira/browse/APEXCORE-712?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008792#comment-16008792 ] ASF GitHub Bot commented on APEXCORE-712: - GitHub user devtagare opened a pull request:

[GitHub] apex-core pull request #526: APEXCORE-712 custom keystore at launch

GitHub user devtagare opened a pull request: https://github.com/apache/apex-core/pull/526 APEXCORE-712 custom keystore at launch You can merge this pull request into a Git repository by running: $ git pull https://github.com/devtagare/incubator-apex-core APEXCORE-712

[jira] [Resolved] (APEXCORE-718) How to Use one Kafka input operator and Feed to multiple operator

[ https://issues.apache.org/jira/browse/APEXCORE-718?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] devendra tagare resolved APEXCORE-718. -- Resolution: Invalid > How to Use one Kafka input operator and Feed to multiple

[jira] [Commented] (APEXCORE-718) How to Use one Kafka input operator and Feed to multiple operator

[ https://issues.apache.org/jira/browse/APEXCORE-718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16008462#comment-16008462 ] devendra tagare commented on APEXCORE-718: -- Issue is being followed up on dev/user lists.

[jira] [Updated] (APEXCORE-712) Support distribution of custom SSL material to the Stram node while launch the app

[ https://issues.apache.org/jira/browse/APEXCORE-712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] devendra tagare updated APEXCORE-712: - Remaining Estimate: 2h (was: 168h) Original Estimate: 2h (was: 168h) > Support

[jira] [Assigned] (APEXCORE-712) Support distribution of custom SSL material to the Stram node while launch the app

[ https://issues.apache.org/jira/browse/APEXCORE-712?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] devendra tagare reassigned APEXCORE-712: Assignee: devendra tagare > Support distribution of custom SSL material to the

Re: Proposal to upgrade Apex Core dependency in Malhar to 3.6

+1 On Fri, May 12, 2017 at 2:06 PM, Chinmay Kolhatkar wrote: > +1 > > On Fri, May 12, 2017 at 1:41 PM, Mohit Jotwani > wrote: > > > +1 > > > > Regards, > > Mohit > > > > On Fri, May 12, 2017 at 10:49 AM, Bhupesh Chawda < >

Image processing library

Hello, I have been working on an image processing library for Malhar and few of the operators are ready. I would like to merge them in Malhar contrib. You can read about the operators and the applications I have created so far here.

[jira] [Commented] (APEXCORE-720) In DAGExecution plugin, Context.getDAG returns null

[ https://issues.apache.org/jira/browse/APEXCORE-720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007950#comment-16007950 ] ASF GitHub Bot commented on APEXCORE-720: - GitHub user chinmaykolhatkar opened a pull request:

[GitHub] apex-core pull request #525: APEXCORE-720 Update cloned LogicalPlan in Conte...

GitHub user chinmaykolhatkar opened a pull request: https://github.com/apache/apex-core/pull/525 APEXCORE-720 Update cloned LogicalPlan in Context before discovery of plugins In DAGExecution plugin, Context.getDAG returns null unless there is any update in LogicalPlan.

[jira] [Commented] (APEXCORE-720) In DAGExecution plugin, Context.getDAG returns null

[ https://issues.apache.org/jira/browse/APEXCORE-720?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007939#comment-16007939 ] Chinmay Kolhatkar commented on APEXCORE-720: RCA: Plugin event of type:

[jira] [Created] (APEXCORE-720) In DAGExecution plugin, Context.getDAG returns null

Chinmay Kolhatkar created APEXCORE-720: -- Summary: In DAGExecution plugin, Context.getDAG returns null Key: APEXCORE-720 URL: https://issues.apache.org/jira/browse/APEXCORE-720 Project: Apache

[jira] [Updated] (APEXMALHAR-2487) Malhar should support outputting data in Snappy compression

[ https://issues.apache.org/jira/browse/APEXMALHAR-2487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Priyanka Gugale updated APEXMALHAR-2487: Fix Version/s: 3.8.0 > Malhar should support outputting data in Snappy

[jira] [Resolved] (APEXMALHAR-2487) Malhar should support outputting data in Snappy compression

[ https://issues.apache.org/jira/browse/APEXMALHAR-2487?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Priyanka Gugale resolved APEXMALHAR-2487. - Resolution: Fixed > Malhar should support outputting data in Snappy

[jira] [Commented] (APEXMALHAR-2487) Malhar should support outputting data in Snappy compression

[ https://issues.apache.org/jira/browse/APEXMALHAR-2487?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007897#comment-16007897 ] ASF GitHub Bot commented on APEXMALHAR-2487: Github user asfgit closed the pull request

[GitHub] apex-malhar pull request #616: APEXMALHAR-2487 Added support for Snappy comp...

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

Re: Proposal to upgrade Apex Core dependency in Malhar to 3.6

+1 On Fri, May 12, 2017 at 1:41 PM, Mohit Jotwani wrote: > +1 > > Regards, > Mohit > > On Fri, May 12, 2017 at 10:49 AM, Bhupesh Chawda > wrote: > > > +1 > > > > ~ Bhupesh > > > > > > ___ > > >

[jira] [Commented] (APEXCORE-718) How to Use one Kafka input operator and Feed to multiple operator

[ https://issues.apache.org/jira/browse/APEXCORE-718?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=16007749#comment-16007749 ] ROHIT RAJKUMAR GARG commented on APEXCORE-718: -- Thanks [~tushargosavi] I will use the