[jira] [Commented] (APEXMALHAR-2411) Avoid isreplaystate variable, incorporate logic in activate() and replay() for Kinesis Input Operator

[ https://issues.apache.org/jira/browse/APEXMALHAR-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15871245#comment-15871245 ] ASF GitHub Bot commented on APEXMALHAR-2411: GitHub user deepak-narkhede opened a pull

[GitHub] apex-malhar pull request #555: APEXMALHAR-2411 Avoid isreplaystate variable,...

GitHub user deepak-narkhede opened a pull request: https://github.com/apache/apex-malhar/pull/555 APEXMALHAR-2411 Avoid isreplaystate variable, incorporate logic in activate() and replay() for Kinesis Input Operator Avoid isreplaystate variable, incorporate logic in activate() and

[jira] [Commented] (APEXMALHAR-2409) Improve PojoInnerJoin accumulation to emit a POJO instead of Map

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

[GitHub] apex-malhar pull request #554: APEXMALHAR-2409 PojoInnerJoin accumulation to...

GitHub user chinmaykolhatkar opened a pull request: https://github.com/apache/apex-malhar/pull/554 APEXMALHAR-2409 PojoInnerJoin accumulation to emit a POJO @tushargosavi Please review and merge. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (APEXMALHAR-2414) Improve performance of PojoInnerJoin accum by using PojoUtils

Chinmay Kolhatkar created APEXMALHAR-2414: - Summary: Improve performance of PojoInnerJoin accum by using PojoUtils Key: APEXMALHAR-2414 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2414

[jira] [Created] (APEXMALHAR-2415) Enable PojoInnerJoin accum to allow multiple keys for join purpose

Chinmay Kolhatkar created APEXMALHAR-2415: - Summary: Enable PojoInnerJoin accum to allow multiple keys for join purpose Key: APEXMALHAR-2415 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2415

[jira] [Updated] (APEXMALHAR-2409) Improve PojoInnerJoin accumulation to emit a POJO instead of Map

[ https://issues.apache.org/jira/browse/APEXMALHAR-2409?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chinmay Kolhatkar updated APEXMALHAR-2409: -- Issue Type: Sub-task (was: Improvement) Parent: APEXMALHAR-2413 >

[jira] [Created] (APEXMALHAR-2413) Improve PojoInnerJoin Accumulation

Chinmay Kolhatkar created APEXMALHAR-2413: - Summary: Improve PojoInnerJoin Accumulation Key: APEXMALHAR-2413 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2413 Project: Apache Apex

[jira] [Updated] (APEXMALHAR-2411) Avoid isreplaystate variable, incorporate logic in activate() and replay() for Kinesis Input Operator

[ https://issues.apache.org/jira/browse/APEXMALHAR-2411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Deepak Narkhede updated APEXMALHAR-2411: Summary: Avoid isreplaystate variable, incorporate logic in activate() and

[jira] [Created] (APEXMALHAR-2412) Provide emitTuple overriding functionality for user in kinesis Input operator

Deepak Narkhede created APEXMALHAR-2412: --- Summary: Provide emitTuple overriding functionality for user in kinesis Input operator Key: APEXMALHAR-2412 URL:

[jira] [Created] (APEXMALHAR-2411) Avoid consumer start while replay state in KinesisInputOperator

Deepak Narkhede created APEXMALHAR-2411: --- Summary: Avoid consumer start while replay state in KinesisInputOperator Key: APEXMALHAR-2411 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2411

[jira] [Commented] (APEXCORE-624) Shutdown does not work because of incorrect logic in the AppMaster

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

[GitHub] apex-core pull request #458: APEXCORE-624 decrement unallocated containers a...

Github user asfgit closed the pull request at: https://github.com/apache/apex-core/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] [Created] (APEXMALHAR-2410) KafkaSinglePortExactlyOnceOutputOperator fails if an operator crashes in the very first window

Oliver Winke created APEXMALHAR-2410: Summary: KafkaSinglePortExactlyOnceOutputOperator fails if an operator crashes in the very first window Key: APEXMALHAR-2410 URL:

[jira] [Commented] (APEXCORE-604) Extend DAG API to allow accessing DAG objects.

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

[GitHub] apex-core pull request #447: APEXCORE-604 extend DAG API to get operators an...

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

Re: PojoInnerJoin Accumulation emitting Map

APEXMALHAR-2409 Created. I'll create a PR soon. On Wed, Feb 15, 2017 at 10:31 PM, Chinmay Kolhatkar wrote: > Thanks guys. I'll create a jira and create a PR for it soon. > > Ajay, btw this is not much related to Schema discovery design... This is > for windowed

[jira] [Created] (APEXMALHAR-2409) Improve PojoInnerJoin accumulation to emit a POJO instead of Map

Chinmay Kolhatkar created APEXMALHAR-2409: - Summary: Improve PojoInnerJoin accumulation to emit a POJO instead of Map Key: APEXMALHAR-2409 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2409