[jira] [Created] (APEXCORE-781) Autometric values of an operator is showing wrongly in App master

Chaitanya created APEXCORE-781: -- Summary: Autometric values of an operator is showing wrongly in App master Key: APEXCORE-781 URL: https://issues.apache.org/jira/browse/APEXCORE-781 Project: Apache Apex

[jira] [Commented] (APEXMALHAR-2518) Kafka input operator stops reading tuples when there is a UNKNOWN_MEMBER_ID error during committed offset processing

[ https://issues.apache.org/jira/browse/APEXMALHAR-2518?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16079967#comment-16079967 ] Chaitanya commented on APEXMALHAR-2518: --- [~pramod.immaneni] Could you please sh

[jira] [Commented] (APEXMALHAR-2162) Enable unit tests of 0.9.0 Kafka Output operator

[ https://issues.apache.org/jira/browse/APEXMALHAR-2162?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16030699#comment-16030699 ] Chaitanya commented on APEXMALHAR-2162: --- [~thomasWeise] We can use this in Kafk

[jira] [Assigned] (APEXMALHAR-2162) Enable unit tests of 0.9.0 Kafka Output operator

[ https://issues.apache.org/jira/browse/APEXMALHAR-2162?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya reassigned APEXMALHAR-2162: - Assignee: Chaitanya > Enable unit tests of 0.9.0 Kafka Output operator > ---

[jira] [Created] (APEXMALHAR-2497) Refactor the Kafka Output Operator and add the support for 0.10.* Kafka version.

Chaitanya created APEXMALHAR-2497: - Summary: Refactor the Kafka Output Operator and add the support for 0.10.* Kafka version. Key: APEXMALHAR-2497 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2497

[jira] [Created] (APEXMALHAR-2496) Update the Kafka input operator documentation

Chaitanya created APEXMALHAR-2496: - Summary: Update the Kafka input operator documentation Key: APEXMALHAR-2496 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2496 Project: Apache Apex Malhar

[jira] [Created] (APEXMALHAR-2494) Update demo apps with description

Chaitanya created APEXMALHAR-2494: - Summary: Update demo apps with description Key: APEXMALHAR-2494 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2494 Project: Apache Apex Malhar Issu

[jira] [Created] (APEXMALHAR-2493) KafkaSinglePortExactlyOnceOutputOperator going to the blocked state during recovery

Chaitanya created APEXMALHAR-2493: - Summary: KafkaSinglePortExactlyOnceOutputOperator going to the blocked state during recovery Key: APEXMALHAR-2493 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2493

[jira] [Created] (APEXMALHAR-2486) kinesisInputOperator is creating the partitions for the closed shards

Chaitanya created APEXMALHAR-2486: - Summary: kinesisInputOperator is creating the partitions for the closed shards Key: APEXMALHAR-2486 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2486 Proje

[jira] [Created] (APEXMALHAR-2484) BlockWriter for writing the part files into the specified directory

Chaitanya created APEXMALHAR-2484: - Summary: BlockWriter for writing the part files into the specified directory Key: APEXMALHAR-2484 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2484 Project

[jira] [Resolved] (APEXMALHAR-2101) RuntimeException from Default Bucket which is under managed state.

[ https://issues.apache.org/jira/browse/APEXMALHAR-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2101. --- Resolution: Duplicate Assignee: Chaitanya > RuntimeException from Default Bucket wh

[jira] [Commented] (APEXMALHAR-2101) RuntimeException from Default Bucket which is under managed state.

[ https://issues.apache.org/jira/browse/APEXMALHAR-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15972135#comment-15972135 ] Chaitanya commented on APEXMALHAR-2101: --- This issue is part of issues defined i

[jira] [Resolved] (APEXMALHAR-2431) Create Kinesis Input operator which emits byte array as tuple

[ https://issues.apache.org/jira/browse/APEXMALHAR-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2431. --- Resolution: Fixed Fix Version/s: 3.8.0 > Create Kinesis Input operator which emits

[jira] [Updated] (APEXMALHAR-2431) Create Kinesis Input operator which emits byte array as tuple

[ https://issues.apache.org/jira/browse/APEXMALHAR-2431?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXMALHAR-2431: -- Issue Type: Task (was: Improvement) > Create Kinesis Input operator which emits byte array

[jira] [Resolved] (APEXMALHAR-2460) Redshift output module tuples unable to emit tuples

[ https://issues.apache.org/jira/browse/APEXMALHAR-2460?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2460. --- Resolution: Fixed Fix Version/s: 3.8.0 > Redshift output module tuples unable to e

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperator is broken

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15953029#comment-15953029 ] Chaitanya commented on APEXMALHAR-2284: --- [~thomasWeise] Operator is still broke

[jira] [Commented] (APEXMALHAR-2459) KafkaInputoperator using 0.10.* Kafka consumer API

[ https://issues.apache.org/jira/browse/APEXMALHAR-2459?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15948044#comment-15948044 ] Chaitanya commented on APEXMALHAR-2459: --- [~thw] Difference between 0.9 and 0.10

[jira] [Created] (APEXMALHAR-2459) KafkaInputoperator using 0.10.* Kafka consumer API

Chaitanya created APEXMALHAR-2459: - Summary: KafkaInputoperator using 0.10.* Kafka consumer API Key: APEXMALHAR-2459 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2459 Project: Apache Apex Malh

[jira] [Commented] (APEXMALHAR-2406) ManagedState incorrect results for get()

[ https://issues.apache.org/jira/browse/APEXMALHAR-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15932231#comment-15932231 ] Chaitanya commented on APEXMALHAR-2406: --- Total results for the below benchmark

[jira] [Created] (APEXMALHAR-2448) Throwing IOException from getValueFromBucketSync() method which is in AbstractManagedStateImpl

Chaitanya created APEXMALHAR-2448: - Summary: Throwing IOException from getValueFromBucketSync() method which is in AbstractManagedStateImpl Key: APEXMALHAR-2448 URL: https://issues.apache.org/jira/browse/APEXMALHA

[jira] [Commented] (APEXMALHAR-2406) ManagedState Issues

[ https://issues.apache.org/jira/browse/APEXMALHAR-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15923717#comment-15923717 ] Chaitanya commented on APEXMALHAR-2406: --- By mistake, I added it under comment.

[jira] [Issue Comment Deleted] (APEXMALHAR-2408) Validate correctness of get() for key search in ManagedTimeStateImpl

[ https://issues.apache.org/jira/browse/APEXMALHAR-2408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXMALHAR-2408: -- Comment: was deleted (was: Below are the issues: 1) When the key searches all time buckets,

[jira] [Updated] (APEXMALHAR-2408) Validate correctness of get() for key search in ManagedTimeStateImpl

[ https://issues.apache.org/jira/browse/APEXMALHAR-2408?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXMALHAR-2408: -- Description: Below are the issues: 1) When the key searches all time buckets, not checking

[jira] [Updated] (APEXMALHAR-2407) Time buckets are not purging after expiry

[ https://issues.apache.org/jira/browse/APEXMALHAR-2407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXMALHAR-2407: -- Description: Below are the observations: 1) purgeListner is not triggering purgeTimeBuckets

[jira] [Issue Comment Deleted] (APEXMALHAR-2407) Time buckets are not purging after expiry

[ https://issues.apache.org/jira/browse/APEXMALHAR-2407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXMALHAR-2407: -- Comment: was deleted (was: Below are the observations: 1) purgeListner is not triggering p

[jira] [Commented] (APEXMALHAR-2366) Apply BloomFilter to Bucket

[ https://issues.apache.org/jira/browse/APEXMALHAR-2366?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15892121#comment-15892121 ] Chaitanya commented on APEXMALHAR-2366: --- [~brightchen] The implementation which

[jira] [Resolved] (APEXMALHAR-2369) S3 output module for tuple based output

[ https://issues.apache.org/jira/browse/APEXMALHAR-2369?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2369. --- Resolution: Fixed Fix Version/s: 3.7.0 > S3 output module for tuple based output >

[jira] [Resolved] (APEXMALHAR-2380) Add MutablePair for Kinensis Operator for Recovery State

[ https://issues.apache.org/jira/browse/APEXMALHAR-2380?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2380. --- Resolution: Fixed Fix Version/s: 3.7.0 > Add MutablePair for Kinensis Operator for

[jira] [Resolved] (APEXMALHAR-2381) Change FSWindowManager for performance issues in Kinesis Input Operator

[ https://issues.apache.org/jira/browse/APEXMALHAR-2381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2381. --- Resolution: Fixed Fix Version/s: 3.7.0 > Change FSWindowManager for performance is

[jira] [Updated] (APEXMALHAR-2381) Change FSWindowManager for performance issues in Kinesis Input Operator

[ https://issues.apache.org/jira/browse/APEXMALHAR-2381?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXMALHAR-2381: -- Issue Type: Improvement (was: Bug) > Change FSWindowManager for performance issues in Kine

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya reassigned APEXMALHAR-2412: - Assignee: Deepak Narkhede > Provide emitTuple overriding functionality for user in k

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2412?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2412. --- Resolution: Fixed Fix Version/s: 3.7.0 > Provide emitTuple overriding functionalit

[jira] [Created] (APEXMALHAR-2416) Development of Redshift Output Module

Chaitanya created APEXMALHAR-2416: - Summary: Development of Redshift Output Module Key: APEXMALHAR-2416 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2416 Project: Apache Apex Malhar

[jira] [Resolved] (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 ] Chaitanya resolved APEXMALHAR-2411. --- Resolution: Fixed Fix Version/s: 3.7.0 > Avoid isreplaystate variable, incorporate

[jira] [Commented] (APEXMALHAR-2408) Validate correctness of get() for key search in ManagedTimeStateImpl

[ https://issues.apache.org/jira/browse/APEXMALHAR-2408?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15865496#comment-15865496 ] Chaitanya commented on APEXMALHAR-2408: --- Below are the issues: 1) When the key

[jira] [Commented] (APEXMALHAR-2406) ManagedState Issues

[ https://issues.apache.org/jira/browse/APEXMALHAR-2406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15865207#comment-15865207 ] Chaitanya commented on APEXMALHAR-2406: --- [~brightchen] [~dtram] Added comments

[jira] [Commented] (APEXMALHAR-2407) Time buckets are not purging after expiry

[ https://issues.apache.org/jira/browse/APEXMALHAR-2407?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15865201#comment-15865201 ] Chaitanya commented on APEXMALHAR-2407: --- Below are the observations: 1) purgeL

[jira] [Created] (APEXMALHAR-2406) ManagedState Issues

Chaitanya created APEXMALHAR-2406: - Summary: ManagedState Issues Key: APEXMALHAR-2406 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2406 Project: Apache Apex Malhar Issue Type: Bug

[jira] [Created] (APEXMALHAR-2407) Time buckets are not purging after expiry

Chaitanya created APEXMALHAR-2407: - Summary: Time buckets are not purging after expiry Key: APEXMALHAR-2407 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2407 Project: Apache Apex Malhar

[jira] [Created] (APEXMALHAR-2408) Validate correctness of get() for key search in ManagedTimeStateImpl

Chaitanya created APEXMALHAR-2408: - Summary: Validate correctness of get() for key search in ManagedTimeStateImpl Key: APEXMALHAR-2408 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2408 Projec

[jira] [Resolved] (APEXMALHAR-2379) AbstractFileInputOperator bug fixes for regex, negative values

[ https://issues.apache.org/jira/browse/APEXMALHAR-2379?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2379. --- Resolution: Fixed Fix Version/s: 3.7.0 > AbstractFileInputOperator bug fixes for r

[jira] [Updated] (APEXMALHAR-2298) Kafka ExactlyOnce (0.9) output operator fixes

[ https://issues.apache.org/jira/browse/APEXMALHAR-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXMALHAR-2298: -- Fix Version/s: 3.7.0 > Kafka ExactlyOnce (0.9) output operator fixes >

[jira] [Resolved] (APEXMALHAR-2298) Kafka ExactlyOnce (0.9) output operator fixes

[ https://issues.apache.org/jira/browse/APEXMALHAR-2298?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2298. --- Resolution: Fixed > Kafka ExactlyOnce (0.9) output operator fixes > -

[jira] [Resolved] (APEXMALHAR-2303) S3 Line By Line Module

[ https://issues.apache.org/jira/browse/APEXMALHAR-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2303. --- Resolution: Fixed > S3 Line By Line Module > -- > > K

[jira] [Updated] (APEXMALHAR-2303) S3 Line By Line Module

[ https://issues.apache.org/jira/browse/APEXMALHAR-2303?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXMALHAR-2303: -- Fix Version/s: 3.7.0 > S3 Line By Line Module > -- > >

[jira] [Updated] (APEXMALHAR-2372) Change the order of checks of table name in populateColumnDataTypes

[ https://issues.apache.org/jira/browse/APEXMALHAR-2372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXMALHAR-2372: -- Fix Version/s: 3.7.0 > Change the order of checks of table name in populateColumnDataTypes

[jira] [Resolved] (APEXMALHAR-2372) Change the order of checks of table name in populateColumnDataTypes

[ https://issues.apache.org/jira/browse/APEXMALHAR-2372?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2372. --- Resolution: Fixed > Change the order of checks of table name in populateColumnDataTypes >

[jira] [Created] (APEXMALHAR-2364) Add user documentation for S3OutputModule

Chaitanya created APEXMALHAR-2364: - Summary: Add user documentation for S3OutputModule Key: APEXMALHAR-2364 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2364 Project: Apache Apex Malhar

[jira] [Created] (APEXMALHAR-2360) Make properties consistent for S3InputModule with S3OutputModule.

Chaitanya created APEXMALHAR-2360: - Summary: Make properties consistent for S3InputModule with S3OutputModule. Key: APEXMALHAR-2360 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2360 Project:

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15654057#comment-15654057 ] Chaitanya commented on APEXMALHAR-2284: --- I have implemented the Spillable data

[jira] [Created] (APEXMALHAR-2325) Same block id is emitting from FSInputModule

Chaitanya created APEXMALHAR-2325: - Summary: Same block id is emitting from FSInputModule Key: APEXMALHAR-2325 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2325 Project: Apache Apex Malhar

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15601145#comment-15601145 ] Chaitanya commented on APEXMALHAR-2284: --- I looked into the PR #434. This uses M

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15588040#comment-15588040 ] Chaitanya commented on APEXMALHAR-2284: --- Join operator uses: 1) put(Slice key,

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581444#comment-15581444 ] Chaitanya commented on APEXMALHAR-2284: --- During development of Inner Join opera

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15581381#comment-15581381 ] Chaitanya commented on APEXMALHAR-2284: --- [~csingh] I am proposing the below app

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15574274#comment-15574274 ] Chaitanya commented on APEXMALHAR-2284: --- Right now the operator is broken. > P

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15574235#comment-15574235 ] Chaitanya commented on APEXMALHAR-2284: --- [~thw] I am disabling POJOInnerJoinOpe

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571291#comment-15571291 ] Chaitanya commented on APEXMALHAR-2284: --- [~csingh] If you feel that adding the

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571181#comment-15571181 ] Chaitanya commented on APEXMALHAR-2284: --- Changes which are reverted in PR(#444)

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571170#comment-15571170 ] Chaitanya commented on APEXMALHAR-2284: --- getAsync() method has two parts. First

[jira] [Comment Edited] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571020#comment-15571020 ] Chaitanya edited comment on APEXMALHAR-2284 at 10/13/16 6:46 AM: --

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15571020#comment-15571020 ] Chaitanya commented on APEXMALHAR-2284: --- This was failing due to the below merg

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15568537#comment-15568537 ] Chaitanya commented on APEXMALHAR-2284: --- Able to reproduce the issue. It's happ

[jira] [Commented] (APEXMALHAR-2284) POJOInnerJoinOperatorTest fails in Travis CI

[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15567659#comment-15567659 ] Chaitanya commented on APEXMALHAR-2284: --- I am looking into it. But, these tests

[jira] [Commented] (APEXMALHAR-2276) ManagedState: value of a key does not get over-written in the same time bucket

[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15552495#comment-15552495 ] Chaitanya commented on APEXMALHAR-2276: --- [~csingh] My query is on insertion. I

[jira] [Commented] (APEXMALHAR-2276) ManagedState: value of a key does not get over-written in the same time bucket

[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15550997#comment-15550997 ] Chaitanya commented on APEXMALHAR-2276: --- I too agree But, I have a query relat

[jira] [Updated] (APEXMALHAR-2022) S3 Output Module for file copy

[ https://issues.apache.org/jira/browse/APEXMALHAR-2022?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXMALHAR-2022: -- Assignee: Hitesh Kapoor (was: Chaitanya) > S3 Output Module for file copy > --

[jira] [Created] (APEXMALHAR-2257) Add documentation for Transform operator

Chaitanya created APEXMALHAR-2257: - Summary: Add documentation for Transform operator Key: APEXMALHAR-2257 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2257 Project: Apache Apex Malhar

[jira] [Created] (APEXMALHAR-2242) Add documentation for 0.9 version of Kafka Input Operator.

Chaitanya created APEXMALHAR-2242: - Summary: Add documentation for 0.9 version of Kafka Input Operator. Key: APEXMALHAR-2242 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2242 Project: Apache A

[jira] [Created] (APEXMALHAR-2226) Not suppported Exception in AbstractFileOutput Operator.

Chaitanya created APEXMALHAR-2226: - Summary: Not suppported Exception in AbstractFileOutput Operator. Key: APEXMALHAR-2226 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2226 Project: Apache Ape

[jira] [Resolved] (APEXMALHAR-2158) Duplication of data emitted when the Kafka Input Operator(0.8 version) redeploys

[ https://issues.apache.org/jira/browse/APEXMALHAR-2158?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXMALHAR-2158. --- Resolution: Fixed > Duplication of data emitted when the Kafka Input Operator(0.8 version

[jira] [Updated] (APEXCORE-494) Window id of downstream operator is not moving after dynamic partition of upstream operator.

[ https://issues.apache.org/jira/browse/APEXCORE-494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXCORE-494: --- Fix Version/s: 3.5.0 > Window id of downstream operator is not moving after dynamic partition of >

[jira] [Resolved] (APEXCORE-494) Window id of downstream operator is not moving after dynamic partition of upstream operator.

[ https://issues.apache.org/jira/browse/APEXCORE-494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya resolved APEXCORE-494. Resolution: Fixed > Window id of downstream operator is not moving after dynamic partition of > u

[jira] [Updated] (APEXMALHAR-2169) KafkaInputoperator: Remove the stuff related to Partition Based on throughput.

[ https://issues.apache.org/jira/browse/APEXMALHAR-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXMALHAR-2169: -- Summary: KafkaInputoperator: Remove the stuff related to Partition Based on throughput. (w

[jira] [Commented] (APEXMALHAR-2169) KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy

[ https://issues.apache.org/jira/browse/APEXMALHAR-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15414802#comment-15414802 ] Chaitanya commented on APEXMALHAR-2169: --- Based on comments, Changing the title

[jira] [Created] (APEXMALHAR-2180) KafkaInput Operator partitions has to be unchanged in case of dynamic scaling of ONE_TO_MANY strategy.

Chaitanya created APEXMALHAR-2180: - Summary: KafkaInput Operator partitions has to be unchanged in case of dynamic scaling of ONE_TO_MANY strategy. Key: APEXMALHAR-2180 URL: https://issues.apache.org/jira/browse/A

[jira] [Commented] (APEXMALHAR-2169) KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy

[ https://issues.apache.org/jira/browse/APEXMALHAR-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15411681#comment-15411681 ] Chaitanya commented on APEXMALHAR-2169: --- Sure. I updated the changes regarding

[jira] [Created] (APEXMALHAR-2174) S3 File Reader reading more data than expected

Chaitanya created APEXMALHAR-2174: - Summary: S3 File Reader reading more data than expected Key: APEXMALHAR-2174 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2174 Project: Apache Apex Malhar

[jira] [Commented] (APEXMALHAR-2169) KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy

[ https://issues.apache.org/jira/browse/APEXMALHAR-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15396882#comment-15396882 ] Chaitanya commented on APEXMALHAR-2169: --- Siyuan, I am looking for dynamic p

[jira] [Commented] (APEXCORE-494) Window id of downstream operator is not moving after dynamic partition of upstream operator.

[ https://issues.apache.org/jira/browse/APEXCORE-494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395823#comment-15395823 ] Chaitanya commented on APEXCORE-494: Bug is not in the redeploying dependencies. Bug

[jira] [Commented] (APEXMALHAR-2169) KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy

[ https://issues.apache.org/jira/browse/APEXMALHAR-2169?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15395512#comment-15395512 ] Chaitanya commented on APEXMALHAR-2169: --- Issue is in partitioning based on thro

[jira] [Created] (APEXMALHAR-2169) KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy

Chaitanya created APEXMALHAR-2169: - Summary: KafkaInputOperator: Dynamic partition is not working in case of ONE_TO_MANY partition strategy Key: APEXMALHAR-2169 URL: https://issues.apache.org/jira/browse/APEXMALHA

[jira] [Commented] (APEXCORE-494) Window id of downstream operator is not moving after dynamic partition of upstream operator.

[ https://issues.apache.org/jira/browse/APEXCORE-494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15389318#comment-15389318 ] Chaitanya commented on APEXCORE-494: Application to reproduce this issue is in below

[jira] [Commented] (APEXCORE-494) Window id of downstream operator is not moving after dynamic partition of upstream operator.

[ https://issues.apache.org/jira/browse/APEXCORE-494?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15384004#comment-15384004 ] Chaitanya commented on APEXCORE-494: Observation: This was happening only when there

[jira] [Assigned] (APEXCORE-494) Window id of downstream operator is not moving after dynamic partition of upstream operator.

[ https://issues.apache.org/jira/browse/APEXCORE-494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya reassigned APEXCORE-494: -- Assignee: Chaitanya > Window id of downstream operator is not moving after dynamic partition

[jira] [Updated] (APEXCORE-494) Window id of downstream operator is not moving after dynamic partition of upstream operator.

[ https://issues.apache.org/jira/browse/APEXCORE-494?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chaitanya updated APEXCORE-494: --- Attachment: PhysicalDAGBeforeKafkaRepartition.png PhysicalDAGAfterKafkaRepartition.pn

[jira] [Created] (APEXCORE-494) Window id of downstream operator is not moving after dynamic partition of upstream operator.

Chaitanya created APEXCORE-494: -- Summary: Window id of downstream operator is not moving after dynamic partition of upstream operator. Key: APEXCORE-494 URL: https://issues.apache.org/jira/browse/APEXCORE-494

[jira] [Created] (APEXMALHAR-2158) Duplication of data emitted when the Kafka Input Operator(0.8 version) redeploys

Chaitanya created APEXMALHAR-2158: - Summary: Duplication of data emitted when the Kafka Input Operator(0.8 version) redeploys Key: APEXMALHAR-2158 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2158

[jira] [Created] (APEXMALHAR-2136) Null pointer exception in AbstractManagedStateImpl

Chaitanya created APEXMALHAR-2136: - Summary: Null pointer exception in AbstractManagedStateImpl Key: APEXMALHAR-2136 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2136 Project: Apache Apex Malh

[jira] [Created] (APEXMALHAR-2103) scanner issues in FileSplitterInput class

Chaitanya created APEXMALHAR-2103: - Summary: scanner issues in FileSplitterInput class Key: APEXMALHAR-2103 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2103 Project: Apache Apex Malhar

[jira] [Created] (APEXMALHAR-2101) RuntimeException from Default Bucket which is under managed state.

Chaitanya created APEXMALHAR-2101: - Summary: RuntimeException from Default Bucket which is under managed state. Key: APEXMALHAR-2101 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2101 Project:

[jira] [Created] (APEXMALHAR-2100) Development of Inner Join Operator using Spillable Datastructures

Chaitanya created APEXMALHAR-2100: - Summary: Development of Inner Join Operator using Spillable Datastructures Key: APEXMALHAR-2100 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2100 Project: