[jira] [Assigned] (APEXMALHAR-2296) Apex SQL: Add support for SQL GROUP BY (Aggregate RelNode)

[ https://issues.apache.org/jira/browse/APEXMALHAR-2296?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar reassigned APEXMALHAR-2296: - Assignee: (was: Chinmay Kolhatkar) > Apex SQL: Add support for S

[jira] [Assigned] (APEXMALHAR-2295) Apex SQL: Replace POJOInnerJoinOperator with WindowedJoinOperator

[ https://issues.apache.org/jira/browse/APEXMALHAR-2295?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar reassigned APEXMALHAR-2295: - Assignee: (was: Chinmay Kolhatkar) > Apex SQL: Replace POJOInner

[jira] [Assigned] (APEXMALHAR-2294) Apex SQL: Make operator names user friendly for user to configure via properties.xml

[ https://issues.apache.org/jira/browse/APEXMALHAR-2294?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar reassigned APEXMALHAR-2294: - Assignee: (was: Chinmay Kolhatkar) > Apex SQL: Make operator nam

[jira] [Assigned] (APEXMALHAR-2293) Apex SQL: Add sql line cli to sql support of apex

[ https://issues.apache.org/jira/browse/APEXMALHAR-2293?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar reassigned APEXMALHAR-2293: - Assignee: (was: Chinmay Kolhatkar) > Apex SQL: Add sql line cli

[jira] [Assigned] (APEXMALHAR-2292) Apex SQL: Add generic endpoint to malhar-sql

[ https://issues.apache.org/jira/browse/APEXMALHAR-2292?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar reassigned APEXMALHAR-2292: - Assignee: (was: Chinmay Kolhatkar) > Apex SQL: Add generic endpo

Re: Apex Sandbox in Apex Dev Setup documentation

+1 this should be tracked in a JIRA. There are also some improvements that can be done to the instructions on the docker hub (separate activity). I would also suggest to list the Apex binary build on the downloads page for users that have an existing cluster: https://github.com/atrato/apex-cli-p

Re: open/close ports and active/inactive streams

It is exactly the same use case with the exception that it is not necessary to write data to files. Consider 3 operators, an input operator, an aggregate operator and an output operator. When the application starts, the output port of the aggregate operator should be in the closed state, the st

[jira] [Commented] (APEXMALHAR-2476) Unable to override tupleSeparator property of GenericFileOutputOperator using configurations

[ https://issues.apache.org/jira/browse/APEXMALHAR-2476?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15960003#comment-15960003 ] ASF GitHub Bot commented on APEXMALHAR-2476: GitHub user yogidevendra ope

[GitHub] apex-malhar pull request #603: APEXMALHAR-2476-Fix-tupleSeperator-override.

GitHub user yogidevendra opened a pull request: https://github.com/apache/apex-malhar/pull/603 APEXMALHAR-2476-Fix-tupleSeperator-override. You can merge this pull request into a Git repository by running: $ git pull https://github.com/yogidevendra/apex-malhar APEXMALHAR-2476

[GitHub] apex-malhar pull request #602: Inserted "threshold" log property in Log4j.pr...

GitHub user prasannapramod opened a pull request: https://github.com/apache/apex-malhar/pull/602 Inserted "threshold" log property in Log4j.properties file. Fixed log4j properties. You can merge this pull request into a Git repository by running: $ git pull https://github.com/p

[jira] [Assigned] (APEXMALHAR-2475) CacheStore needn't expire data if it read-only data

[ https://issues.apache.org/jira/browse/APEXMALHAR-2475?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oliver Winke reassigned APEXMALHAR-2475: Assignee: Oliver Winke > CacheStore needn't expire data if it read-only data >

[jira] [Assigned] (APEXMALHAR-2473) Support for global cache meta information in db CacheManager

[ https://issues.apache.org/jira/browse/APEXMALHAR-2473?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oliver Winke reassigned APEXMALHAR-2473: Assignee: Oliver Winke > Support for global cache meta information in db Cache

[jira] [Assigned] (APEXMALHAR-2474) FSLoader only returns value at the beginning

[ https://issues.apache.org/jira/browse/APEXMALHAR-2474?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Oliver Winke reassigned APEXMALHAR-2474: Assignee: Oliver Winke > FSLoader only returns value at the beginning > --

Apex Sandbox in Apex Dev Setup documentation

All, In the Sandbox section of the Apache Apex Development Environment Setup documentation ( https://apex.apache.org/docs/apex/apex_development_setup/#sandbox), instructions are provided for a vendor-specific Sandbox. I would like to propose that these instructions be changed to reference the Apa

Re: open/close ports and active/inactive streams

You would need to provide more specifics of the use case you are thinking to address to make this a meaningful discussion. An example for APEXCORE-408 (based on real batch use case): I have two stages, first stage produces a set of files that second stage needs as input. Stage 1 operators to be re

Re: open/close ports and active/inactive streams

It is not about a use case difference. My proposal and APEXCORE-408 address the same use case - how to re-allocate resources for batch applications or applications where processing happens in stages. The difference between APEXCORE-408 and the proposal is shift in complexity from application lo

[jira] [Commented] (APEXCORE-408) Ability to schedule Sub-DAG from running application

[ https://issues.apache.org/jira/browse/APEXCORE-408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15958879#comment-15958879 ] Tushar Gosavi commented on APEXCORE-408: [~thw] I have opened a pull request ht