[jira] [Updated] (APEXMALHAR-2139) UniqueCounter changes

[ https://issues.apache.org/jira/browse/APEXMALHAR-2139?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXMALHAR-2139: - Assignee: Aayushi Acharya > UniqueCounter changes > - > >

Re: Malhar 3.5.0 release

https://github.com/apache/apex-malhar/pull/372 is open for APEXMALHAR-2195. I have incorporated the review comments from @gauravgopi123, @tweise I have updated fix version to 3.5.0 to reflect this ticket in the query. Can someone please review and merge this for 3.5.0? ~ Yogi On 25 August 2016

[jira] [Updated] (APEXMALHAR-2195) LineReaderContext gives incorrect results for files not ending with the newline

[ https://issues.apache.org/jira/browse/APEXMALHAR-2195?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Yogi Devendra updated APEXMALHAR-2195: -- Fix Version/s: 3.5.0 > LineReaderContext gives incorrect results for files not

[jira] [Updated] (APEXMALHAR-2204) Implement managed state delete

[ https://issues.apache.org/jira/browse/APEXMALHAR-2204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXMALHAR-2204: - Description: We need a delete operation that actually removes the entry. Currently

[jira] [Commented] (APEXMALHAR-2200) Enable checkstyle for demos

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

[GitHub] apex-malhar pull request #382: APEXMALHAR-2200 Enabled checkstyle for demos....

GitHub user ShunxinLu opened a pull request: https://github.com/apache/apex-malhar/pull/382 APEXMALHAR-2200 Enabled checkstyle for demos. Fixed checkstyle errors. You can merge this pull request into a Git repository by running: $ git pull

[jira] [Updated] (APEXMALHAR-2191) Implement a way to get all keys with or without prefix from SpillableByteMapImpl

[ https://issues.apache.org/jira/browse/APEXMALHAR-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan updated APEXMALHAR-2191: -- Description: WindowedKeyedStorage is basically a Map>, and we need the

[jira] [Updated] (APEXMALHAR-2191) Implement a way to get all keys with or without prefix from SpillableByteMapImpl

[ https://issues.apache.org/jira/browse/APEXMALHAR-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan updated APEXMALHAR-2191: -- Summary: Implement a way to get all keys with or without prefix from SpillableByteMapImpl

[jira] [Updated] (APEXMALHAR-2191) Implement a way to get all keys from SpillableByteMapImpl

[ https://issues.apache.org/jira/browse/APEXMALHAR-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] David Yan updated APEXMALHAR-2191: -- Priority: Critical (was: Major) > Implement a way to get all keys from

[jira] [Resolved] (APEXMALHAR-2202) Move accumulations to correct package

[ https://issues.apache.org/jira/browse/APEXMALHAR-2202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved APEXMALHAR-2202. -- Resolution: Fixed Fix Version/s: 3.5.0 > Move accumulations to correct

[jira] [Updated] (APEXMALHAR-2204) Implement managed state delete

[ https://issues.apache.org/jira/browse/APEXMALHAR-2204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXMALHAR-2204: - Priority: Critical (was: Major) > Implement managed state delete >

[jira] [Updated] (APEXMALHAR-2204) Implement managed state delete

[ https://issues.apache.org/jira/browse/APEXMALHAR-2204?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXMALHAR-2204: - Assignee: Siyuan Hua (was: Thomas Weise) > Implement managed state delete >

[jira] [Created] (APEXMALHAR-2204) Implement managed state delete

Thomas Weise created APEXMALHAR-2204: Summary: Implement managed state delete Key: APEXMALHAR-2204 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2204 Project: Apache Apex Malhar

[jira] [Updated] (APEXMALHAR-2193) Implement SpillableByteArrayListMultimapImpl.remove(@Nullable Object key, @Nullable Object value)

[ https://issues.apache.org/jira/browse/APEXMALHAR-2193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXMALHAR-2193: - Assignee: (was: David Yan) > Implement

[jira] [Updated] (APEXMALHAR-2188) Implement SpillableByteArrayListMultimapImpl.containsEntry

[ https://issues.apache.org/jira/browse/APEXMALHAR-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXMALHAR-2188: - Assignee: (was: David Yan) > Implement

[jira] [Commented] (APEXMALHAR-2189) Implement SpillableArrayListImpl.iterator

[ https://issues.apache.org/jira/browse/APEXMALHAR-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1543#comment-1543 ] Thomas Weise commented on APEXMALHAR-2189: -- If we support key prefix scan in spillable map,

[jira] [Updated] (APEXMALHAR-2189) Implement SpillableArrayListImpl.iterator

[ https://issues.apache.org/jira/browse/APEXMALHAR-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXMALHAR-2189: - Assignee: (was: David Yan) > Implement SpillableArrayListImpl.iterator >

[jira] [Commented] (APEXMALHAR-2191) Implement a way to get all keys from SpillableByteMapImpl

[ https://issues.apache.org/jira/browse/APEXMALHAR-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15437772#comment-15437772 ] Thomas Weise commented on APEXMALHAR-2191: -- We need ability to iterate over keys with or

[jira] [Commented] (APEXMALHAR-2193) Implement SpillableByteArrayListMultimapImpl.remove(@Nullable Object key, @Nullable Object value)

[ https://issues.apache.org/jira/browse/APEXMALHAR-2193?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15437766#comment-15437766 ] Thomas Weise commented on APEXMALHAR-2193: -- @timothyfarkas can you please comment on this

[jira] [Assigned] (APEXMALHAR-2201) Suppress console output in Stream API tests

[ https://issues.apache.org/jira/browse/APEXMALHAR-2201?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shunxin Lu reassigned APEXMALHAR-2201: -- Assignee: Shunxin Lu > Suppress console output in Stream API tests >

[jira] [Assigned] (APEXMALHAR-2200) Enable checkstyle for demos

[ https://issues.apache.org/jira/browse/APEXMALHAR-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shunxin Lu reassigned APEXMALHAR-2200: -- Assignee: Shunxin Lu > Enable checkstyle for demos > ---

[jira] [Commented] (APEXMALHAR-2202) Move accumulations to correct package

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

[GitHub] apex-malhar pull request #380: APEXMALHAR-2199 Added the support chroot zook...

GitHub user chaithu14 opened a pull request: https://github.com/apache/apex-malhar/pull/380 APEXMALHAR-2199 Added the support chroot zookeeper path in Kafka Input Operator You can merge this pull request into a Git repository by running: $ git pull

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

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

[jira] [Assigned] (APEXMALHAR-2202) Move accumulations to correct package

[ https://issues.apache.org/jira/browse/APEXMALHAR-2202?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Shunxin Lu reassigned APEXMALHAR-2202: -- Assignee: Shunxin Lu > Move accumulations to correct package >

[jira] [Created] (APEXMALHAR-2202) Move accumulations to correct package

Thomas Weise created APEXMALHAR-2202: Summary: Move accumulations to correct package Key: APEXMALHAR-2202 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2202 Project: Apache Apex Malhar

[jira] [Commented] (APEXMALHAR-2201) Suppress console output in Stream API tests

[ https://issues.apache.org/jira/browse/APEXMALHAR-2201?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15437356#comment-15437356 ] Thomas Weise commented on APEXMALHAR-2201: -- See

[jira] [Created] (APEXMALHAR-2201) Suppress console output in Stream API tests

Thomas Weise created APEXMALHAR-2201: Summary: Suppress console output in Stream API tests Key: APEXMALHAR-2201 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2201 Project: Apache Apex

[jira] [Commented] (APEXMALHAR-2200) Enable checkstyle for demos

[ https://issues.apache.org/jira/browse/APEXMALHAR-2200?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15437357#comment-15437357 ] Thomas Weise commented on APEXMALHAR-2200: -- See

[jira] [Commented] (APEXMALHAR-2134) Catch NullPointerException if some Kafka partition has no leader broker

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

[GitHub] apex-malhar pull request #379: APEXMALHAR-2134 Fix the NullPointerException,...

GitHub user chaithu14 opened a pull request: https://github.com/apache/apex-malhar/pull/379 APEXMALHAR-2134 Fix the NullPointerException, if the kafka partition has no leader broker You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (APEXMALHAR-2183) Add user document for CsvFormatter operator

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

[GitHub] apex-malhar pull request #378: APEXMALHAR-2183 Documentation for CsvFormatte...

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

[jira] [Resolved] (APEXMALHAR-2142) High-level API window support

[ https://issues.apache.org/jira/browse/APEXMALHAR-2142?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved APEXMALHAR-2142. -- Resolution: Fixed > High-level API window support > -

[jira] [Commented] (APEXMALHAR-2142) High-level API window support

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

[GitHub] apex-malhar pull request #339: APEXMALHAR-2142 Windowed Stream First Impleme...

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

Hi Thomas, I will fix APEXMALHAR-2134. Regards, Chaitanya On Thu, Aug 25, 2016 at 9:13 PM, Thomas Weise wrote: > We are almost ready to get the RC out. > > Can someone fix APEXMALHAR-2134 for the release? > > > On Wed, Aug 17, 2016 at 12:56 PM, Thomas Weise

[jira] [Created] (APEXMALHAR-2200) Enable checkstyle for demos

Thomas Weise created APEXMALHAR-2200: Summary: Enable checkstyle for demos Key: APEXMALHAR-2200 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2200 Project: Apache Apex Malhar

[jira] [Commented] (APEXMALHAR-2154) Update kafka 0.9 input operator to use new CheckpointNotificationListener

[ https://issues.apache.org/jira/browse/APEXMALHAR-2154?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15437102#comment-15437102 ] Siyuan Hua commented on APEXMALHAR-2154: I don't think so > Update kafka 0.9 input

Re: Malhar 3.5.0 release

We are almost ready to get the RC out. Can someone fix APEXMALHAR-2134 for the release? On Wed, Aug 17, 2016 at 12:56 PM, Thomas Weise wrote: > Friendly reminder.. There are still a few unresolved tickets for 3.5: > >

[jira] [Resolved] (APEXMALHAR-2154) Update kafka 0.9 input operator to use new CheckpointNotificationListener

[ https://issues.apache.org/jira/browse/APEXMALHAR-2154?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise resolved APEXMALHAR-2154. -- Resolution: Fixed > Update kafka 0.9 input operator to use new