[jira] [Updated] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-02 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2063: -- Description: FS Window Data Manager is used to save meta-data that helps in

[jira] [Commented] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15314680#comment-15314680 ] Chandni Singh commented on APEXMALHAR-2063: --- I am looking into the possibility of writing

[jira] [Commented] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15314820#comment-15314820 ] Chandni Singh commented on APEXMALHAR-2063: --- Embedding the window id into the WAL was not

[jira] [Comment Edited] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-08 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320164#comment-15320164 ] Chandni Singh edited comment on APEXMALHAR-2063 at 6/8/16 3:39 PM: ---

[jira] [Commented] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-08 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15321102#comment-15321102 ] Chandni Singh commented on APEXMALHAR-2063: --- [~sandesh] WindowDataManager is used for

[jira] [Commented] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-08 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15321082#comment-15321082 ] Chandni Singh commented on APEXMALHAR-2063: --- [~sandesh] There is already a deleteUpTo(...).

[jira] [Updated] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-08 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2063: -- Description: FS Window Data Manager is used to save meta-data that helps in

[jira] [Comment Edited] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-08 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320164#comment-15320164 ] Chandni Singh edited comment on APEXMALHAR-2063 at 6/8/16 7:22 AM: ---

[jira] [Commented] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-08 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320102#comment-15320102 ] Chandni Singh commented on APEXMALHAR-2063: --- I am close to completing the implementation of

[jira] [Comment Edited] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-08 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320164#comment-15320164 ] Chandni Singh edited comment on APEXMALHAR-2063 at 6/8/16 7:21 AM: ---

[jira] [Comment Edited] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-08 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320164#comment-15320164 ] Chandni Singh edited comment on APEXMALHAR-2063 at 6/8/16 7:31 AM: ---

[jira] [Commented] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-08 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320103#comment-15320103 ] Chandni Singh commented on APEXMALHAR-2063: --- I am close to completing the implementation of

[jira] [Issue Comment Deleted] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-08 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2063: -- Comment: was deleted (was: I am close to completing the implementation of all the

[jira] [Comment Edited] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-08 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15320164#comment-15320164 ] Chandni Singh edited comment on APEXMALHAR-2063 at 6/8/16 7:12 AM: ---

[jira] [Commented] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-09 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15323383#comment-15323383 ] Chandni Singh commented on APEXMALHAR-2063: --- [~sandesh] Window Data Manager purges data

[jira] [Comment Edited] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15313606#comment-15313606 ] Chandni Singh edited comment on APEXMALHAR-2063 at 6/3/16 6:24 AM: ---

[jira] [Commented] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-06-02 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15313600#comment-15313600 ] Chandni Singh commented on APEXMALHAR-2063: --- Yes. Managed State flushes data only at

[jira] [Resolved] (APEXMALHAR-2096) Add blockThreshold parameter to FSInputModule

2016-05-31 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2096?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh resolved APEXMALHAR-2096. --- Resolution: Fixed Fix Version/s: 3.5.0 > Add blockThreshold parameter to

[jira] [Commented] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-05-26 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15301685#comment-15301685 ] Chandni Singh commented on APEXMALHAR-2063: --- Window Data Manager supports dynamic

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

2016-06-23 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15347405#comment-15347405 ] Chandni Singh commented on APEXMALHAR-2068: --- This change needs to be made to

[jira] [Commented] (APEXMALHAR-2129) Introduce option to advance time through Expiry task in TimeBucketAssigner

2016-06-29 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15354726#comment-15354726 ] Chandni Singh commented on APEXMALHAR-2129: --- [~bhupesh] Purging is tied at the level of

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

2016-05-24 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh reassigned APEXMALHAR-2101: - Assignee: Chandni Singh > RuntimeException from Default Bucket which is

[jira] [Commented] (APEXCORE-448) Make operator name available in OperatorContext

2016-07-26 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15394293#comment-15394293 ] Chandni Singh commented on APEXCORE-448: Thanks Pramod! I will propose it and create a pull

[jira] [Commented] (APEXCORE-448) Make operator name available in OperatorContext

2016-07-21 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15388379#comment-15388379 ] Chandni Singh commented on APEXCORE-448: Operator name is specified while adding an operator to

[jira] [Updated] (APEXMALHAR-2044) Exception in AbstractFileOutputOperator during write.

2016-08-01 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2044?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2044: -- Assignee: (was: Chandni Singh) > Exception in AbstractFileOutputOperator

[jira] [Assigned] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-08-09 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh reassigned APEXMALHAR-2129: - Assignee: Chandni Singh > ManagedState: Add a disable purging option >

[jira] [Commented] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-08-10 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15415717#comment-15415717 ] Chandni Singh commented on APEXMALHAR-2129: --- [~bhup...@apache.org] In TimeBucketAssigner,

[jira] [Comment Edited] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-08-10 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15415717#comment-15415717 ] Chandni Singh edited comment on APEXMALHAR-2129 at 8/10/16 6:47 PM:

[jira] [Updated] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-08-10 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2129: -- Description: Have an option that can disable purging of data. Currently the

[jira] [Updated] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-08-10 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2129: -- Description: Have an option that can disable purging of data. Currently the

[jira] [Updated] (APEXCORE-169) instantiating DTLoggerFactory during test causes incorrect logging behavior

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-169?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXCORE-169: --- Assignee: (was: Chandni Singh) > instantiating DTLoggerFactory during test causes

[jira] [Updated] (APEXMALHAR-2005) FileSplitterInput: `paths` field in TimeBasedDirectoryScanner is not validated unless scanner is marked as @Valid

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2005?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2005: -- Assignee: (was: Chandni Singh) > FileSplitterInput: `paths` field in

[jira] [Updated] (APEXMALHAR-1967) JDBC Store setting connection properties from config file is broken

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1967?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-1967: -- Assignee: (was: Chandni Singh) > JDBC Store setting connection properties from

[jira] [Updated] (APEXMALHAR-2035) ManagedState use case- Add a deduper to Malhar which is backed by ManagedState

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2035?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2035: -- Assignee: (was: Chandni Singh) > ManagedState use case- Add a deduper to

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

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

[jira] [Updated] (APEXCORE-448) Make operator name available in OperatorContext

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXCORE-448: --- Assignee: (was: Chandni Singh) > Make operator name available in OperatorContext >

[jira] [Updated] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2063: -- Assignee: (was: Chandni Singh) > Integrate WAL to FS WindowDataManager >

[jira] [Updated] (APEXMALHAR-2071) Add the ability to remove a key to ManagedState

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2071?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2071: -- Assignee: (was: Chandni Singh) > Add the ability to remove a key to

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

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2101?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2101: -- Assignee: (was: Chandni Singh) > RuntimeException from Default Bucket which is

[jira] [Updated] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2129: -- Assignee: (was: Chandni Singh) > ManagedState: Add a disable purging option >

[jira] [Updated] (APEXMALHAR-1848) Block Reader doesn't honor value for minReaders

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1848?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-1848: -- Assignee: (was: Chandni Singh) > Block Reader doesn't honor value for

[jira] [Updated] (APEXMALHAR-1773) Organize the plugins in Malhar lib and contrib

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1773?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-1773: -- Assignee: (was: Chandni Singh) > Organize the plugins in Malhar lib and

[jira] [Updated] (APEXMALHAR-1600) Investigate if we can seek efficiently to the correct location when we restart after failure for ftp and fs scan operators

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1600?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-1600: -- Assignee: (was: Chandni Singh) > Investigate if we can seek efficiently to the

[jira] [Updated] (APEXCORE-21) Add capability to specify collection phase of AutoMetric

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-21?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXCORE-21: -- Assignee: (was: Chandni Singh) > Add capability to specify collection phase of AutoMetric

[jira] [Updated] (APEXCORE-69) Improve StatsListener api so that using it with multiple logical operators is straightforward

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-69?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXCORE-69: -- Assignee: (was: Chandni Singh) > Improve StatsListener api so that using it with multiple

[jira] [Updated] (APEXMALHAR-1852) File Splitter Test Failing On My Machine

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-1852: -- Assignee: (was: Chandni Singh) > File Splitter Test Failing On My Machine >

[jira] [Assigned] (APEXMALHAR-2063) Integrate WAL to FS WindowDataManager

2016-08-04 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2063?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh reassigned APEXMALHAR-2063: - Assignee: Chandni Singh > Integrate WAL to FS WindowDataManager >

[jira] [Commented] (APEXMALHAR-2129) Introduce option to advance time through Expiry task in TimeBucketAssigner

2016-06-29 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15354658#comment-15354658 ] Chandni Singh commented on APEXMALHAR-2129: --- Please explain the requirement and why is it

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

2016-07-06 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2068?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15365308#comment-15365308 ] Chandni Singh commented on APEXMALHAR-2068: --- It uses OperatorContext.getId() >

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

2016-07-07 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2136?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh resolved APEXMALHAR-2136. --- Resolution: Fixed Fix Version/s: 3.5.0 > Null pointer exception in

[jira] [Commented] (APEXMALHAR-2129) Introduce option to advance time through Expiry task in TimeBucketAssigner

2016-06-29 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15355324#comment-15355324 ] Chandni Singh commented on APEXMALHAR-2129: --- I am not disagreeing with your use case.

[jira] [Reopened] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-06-29 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh reopened APEXMALHAR-2129: --- Assignee: Chandni Singh (was: Bhupesh Chawda) > ManagedState: Add a disable

[jira] [Updated] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-06-29 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2129: -- Summary: ManagedState: Add a disable purging option (was: Introduce option to

[jira] [Updated] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-06-29 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2129: -- Priority: Major (was: Minor) > ManagedState: Add a disable purging option >

[jira] [Updated] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-06-29 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2129: -- Description: Have an option that can disable purging of data. (was:

[jira] [Commented] (APEXMALHAR-2129) ManagedState: Add a disable purging option

2016-06-29 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2129?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15355507#comment-15355507 ] Chandni Singh commented on APEXMALHAR-2129: --- [~bhupesh] I re-opened the ticket and will

[jira] [Assigned] (APEXCORE-448) Make operator name available in OperatorContext

2016-08-15 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-448?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh reassigned APEXCORE-448: -- Assignee: Chandni Singh > Make operator name available in OperatorContext >

[jira] [Updated] (APEXMALHAR-722) Investigate re-partitioning of transactional database output adaptor

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-722?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-722: - Assignee: (was: Chandni Singh) > Investigate re-partitioning of transactional

[jira] [Updated] (APEXMALHAR-1843) Split Malhar Library and Malhar Contrib package into baby packages

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1843?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-1843: -- Assignee: (was: Chandni Singh) > Split Malhar Library and Malhar Contrib

[jira] [Updated] (APEXMALHAR-1701) Deduper : create a deduper backed by Managed State

2016-08-03 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1701?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-1701: -- Assignee: (was: Chandni Singh) > Deduper : create a deduper backed by Managed

[jira] [Assigned] (APEXMALHAR-2223) Managed state should parallelize WAL writes

2016-09-02 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh reassigned APEXMALHAR-2223: - Assignee: Chandni Singh > Managed state should parallelize WAL writes >

[jira] [Commented] (APEXMALHAR-2223) Managed state should parallelize WAL writes

2016-09-06 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15468563#comment-15468563 ] Chandni Singh commented on APEXMALHAR-2223: --- A possible approach to address this: - Have a

[jira] [Commented] (APEXMALHAR-2227) Error while connecting with Kafka using Apache Apex

2016-09-07 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470994#comment-15470994 ] Chandni Singh commented on APEXMALHAR-2227: --- This was caused by recent changes to

[jira] [Assigned] (APEXMALHAR-2227) Error while connecting with Kafka using Apache Apex

2016-09-07 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh reassigned APEXMALHAR-2227: - Assignee: Chandni Singh > Error while connecting with Kafka using Apache

[jira] [Commented] (APEXMALHAR-2227) Error while connecting with Kafka using Apache Apex

2016-09-07 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471182#comment-15471182 ] Chandni Singh commented on APEXMALHAR-2227: --- Hi, We will need to make the fix in the

[jira] [Commented] (APEXMALHAR-2227) Error while connecting with Kafka using Apache Apex

2016-09-07 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471179#comment-15471179 ] Chandni Singh commented on APEXMALHAR-2227: --- Hi, We will need to make the fix in the

[jira] [Commented] (APEXMALHAR-2130) implement scalable windowed storage

2016-08-29 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15447840#comment-15447840 ] Chandni Singh commented on APEXMALHAR-2130: --- Note: The main change in ManagedState which is

[jira] [Comment Edited] (APEXMALHAR-2130) implement scalable windowed storage

2016-08-29 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15447840#comment-15447840 ] Chandni Singh edited comment on APEXMALHAR-2130 at 8/30/16 3:04 AM:

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

2016-10-05 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15550649#comment-15550649 ] Chandni Singh commented on APEXMALHAR-2276: --- I agree with [~thw] too. This creates

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

2016-10-04 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546592#comment-15546592 ] Chandni Singh commented on APEXMALHAR-2276: --- As [~chaithu] pointed out, we need to compare

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

2016-10-04 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546623#comment-15546623 ] Chandni Singh commented on APEXMALHAR-2276: --- Yes time gets mapped to a time bucket, however

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

2016-10-04 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2276: -- Comment: was deleted (was: Yes time gets mapped to a time bucket, however the

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

2016-10-04 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15546624#comment-15546624 ] Chandni Singh commented on APEXMALHAR-2276: --- Yes time gets mapped to a time bucket, however

[jira] [Assigned] (APEXMALHAR-1852) File Splitter Test Failing On My Machine

2016-10-07 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1852?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh reassigned APEXMALHAR-1852: - Assignee: Chandni Singh > File Splitter Test Failing On My Machine >

[jira] [Created] (APEXMALHAR-2281) ManagedState: race condition with put & asyncGet and bucket size doesn't account for entries in file cache

2016-10-06 Thread Chandni Singh (JIRA)
Chandni Singh created APEXMALHAR-2281: - Summary: ManagedState: race condition with put & asyncGet and bucket size doesn't account for entries in file cache Key: APEXMALHAR-2281 URL:

[jira] [Updated] (APEXMALHAR-2281) ManagedState: race condition with put & asyncGet and bucket size doesn't account for entries in file cache

2016-10-06 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2281: -- Description: There are 2 bugs: 1. Race condition with put and asyncGet. put(...)

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

2016-10-06 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15552532#comment-15552532 ] Chandni Singh commented on APEXMALHAR-2276: --- I don't see a problem. In Scenario A, it is

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

2016-10-06 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15552532#comment-15552532 ] Chandni Singh edited comment on APEXMALHAR-2276 at 10/6/16 5:28 PM:

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

2016-10-06 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh resolved APEXMALHAR-2276. --- Resolution: Fixed > ManagedState: value of a key does not get over-written in

[jira] [Updated] (APEXMALHAR-2281) ManagedState: race condition with put & asyncGet

2016-10-06 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2281: -- Description: Race condition with put and asyncGet. put(...) inserts a

[jira] [Updated] (APEXMALHAR-2281) ManagedState: race condition with put & asyncGet

2016-10-06 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2281?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2281: -- Summary: ManagedState: race condition with put & asyncGet (was: ManagedState:

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

2016-10-04 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh reopened APEXMALHAR-2276: --- > ManagedState: value of a key does not get over-written in the same time bucket >

[jira] [Assigned] (APEXMALHAR-2252) Document AbstractManagedStateImpl subclasses

2016-09-20 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2252?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh reassigned APEXMALHAR-2252: - Assignee: Chandni Singh > Document AbstractManagedStateImpl subclasses >

[jira] [Commented] (APEXMALHAR-2223) Managed state should parallelize WAL writes

2016-09-16 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496811#comment-15496811 ] Chandni Singh commented on APEXMALHAR-2223: --- The reason to delay to endWindow is that with

[jira] [Comment Edited] (APEXMALHAR-2223) Managed state should parallelize WAL writes

2016-09-16 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15496811#comment-15496811 ] Chandni Singh edited comment on APEXMALHAR-2223 at 9/16/16 4:59 PM:

[jira] [Issue Comment Deleted] (APEXMALHAR-2227) Error while connecting with Kafka using Apache Apex

2016-09-07 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2227: -- Comment: was deleted (was: Hi, We will need to make the fix in the Malhar 3.5.0

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

2016-09-30 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2276: -- Summary: ManagedTimeUnifiedStateImpl: value of a key does not get over-written in

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

2016-09-30 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2276?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXMALHAR-2276: -- Summary: ManagedState: value of a key does not get over-written in the same time

[jira] [Commented] (APEXMALHAR-2223) Managed state should parallelize WAL writes

2016-09-30 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2223?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15537595#comment-15537595 ] Chandni Singh commented on APEXMALHAR-2223: --- IncrementalCheckpointManager used to extend

[jira] [Commented] (APEXMALHAR-1852) File Splitter Test Failing On My Machine

2016-10-09 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-1852?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15560419#comment-15560419 ] Chandni Singh commented on APEXMALHAR-1852: --- Found the problem with the test. There are 12

[jira] [Created] (APEXMALHAR-2285) Add a property to TimeBasedDirectoryScanner in FileSplitterInput that ignores missing directories instead of propagating exception

2016-10-09 Thread Chandni Singh (JIRA)
Chandni Singh created APEXMALHAR-2285: - Summary: Add a property to TimeBasedDirectoryScanner in FileSplitterInput that ignores missing directories instead of propagating exception Key: APEXMALHAR-2285 URL:

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

2016-10-19 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15588941#comment-15588941 ] Chandni Singh commented on APEXMALHAR-2284: --- [~bhup...@apache.org], [~chaithu] I disagree.

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

2016-10-19 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15588941#comment-15588941 ] Chandni Singh edited comment on APEXMALHAR-2284 at 10/19/16 2:36 PM:

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

2016-10-18 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585751#comment-15585751 ] Chandni Singh edited comment on APEXMALHAR-2284 at 10/18/16 3:40 PM:

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

2016-10-18 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15585751#comment-15585751 ] Chandni Singh commented on APEXMALHAR-2284: --- One concept that I think I should point is

[jira] [Resolved] (APEXMALHAR-2299) TimeBasedDedupOperator throws exception during time bucket assignment in certain edge cases

2016-10-18 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2299?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh resolved APEXMALHAR-2299. --- Resolution: Fixed > TimeBasedDedupOperator throws exception during time bucket

[jira] [Updated] (APEXCORE-148) Auto metric: metric aggregations test is failing

2016-11-23 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXCORE-148?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Chandni Singh updated APEXCORE-148: --- Priority: Major (was: Critical) > Auto metric: metric aggregations test is failing >

[jira] [Commented] (APEXMALHAR-2321) Improve Buckets memory management

2016-11-01 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2321?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15626117#comment-15626117 ] Chandni Singh commented on APEXMALHAR-2321: --- >>AbstractManagedStateImpl.maxMemorySize

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

2016-10-13 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572169#comment-15572169 ] Chandni Singh commented on APEXMALHAR-2284: --- 1. put needs to done only after you retrieve

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

2016-10-13 Thread Chandni Singh (JIRA)
[ https://issues.apache.org/jira/browse/APEXMALHAR-2284?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15572183#comment-15572183 ] Chandni Singh commented on APEXMALHAR-2284: --- I think the proper fix for this may take time.

  1   2   >