[GitHub] apex-malhar pull request #404: APEXMALHAR-2190 #resolve #comment Use reusabl...

GitHub user brightchen opened a pull request: https://github.com/apache/apex-malhar/pull/404 APEXMALHAR-2190 #resolve #comment Use reusable buffer to serial spill… …able data structure You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (APEXCORE-522) Promote singleton usage pattern for String2String, Long2String and other StringCodecs

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

[GitHub] apex-core pull request #385: APEXCORE-522 - Promote singleton usage pattern ...

GitHub user vrozov opened a pull request: https://github.com/apache/apex-core/pull/385 APEXCORE-522 - Promote singleton usage pattern for String2String, Long2String and other StringCodecs You can merge this pull request into a Git repository by running: $ git pull

[jira] [Commented] (APEXMALHAR-2230) Intermittent test failure in Kafka module

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

[jira] [Created] (APEXMALHAR-2230) Intermittent test failure in Kafka module

Thomas Weise created APEXMALHAR-2230: Summary: Intermittent test failure in Kafka module Key: APEXMALHAR-2230 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2230 Project: Apache Apex Malhar

Apex Core PR

Please note that I added Apex Core PR validation to the Apache Jenkins: https://builds.apache.org/job/Apex_Core_PR/. I'll add Apex Malhar later unless somebody volunteers to pick this item. Vlad

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471715#comment-15471715 ] Thomas Weise commented on APEXMALHAR-2227: -- [~smartrchauhan] the change is merged and there

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

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

[GitHub] apex-malhar pull request #402: APEXMALHAR-2227 Index out of Bound Exception ...

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

[jira] [Commented] (APEXMALHAR-2229) Add support for peek on com.datatorrent.lib.fileaccess.FileAccess.FileReader

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

[GitHub] apex-malhar pull request #403: APEXMALHAR-2229 #resolve Added peek and hasNe...

GitHub user davidyan74 opened a pull request: https://github.com/apache/apex-malhar/pull/403 APEXMALHAR-2229 #resolve Added peek and hasNext methods to FileAccess interface @tweise please review You can merge this pull request into a Git repository by running: $ git pull

[jira] [Created] (APEXMALHAR-2229) Add support for peek on com.datatorrent.lib.fileaccess.FileAccess.FileReader

David Yan created APEXMALHAR-2229: - Summary: Add support for peek on com.datatorrent.lib.fileaccess.FileAccess.FileReader Key: APEXMALHAR-2229 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2229

[jira] [Created] (APEXMALHAR-2228) Implement SpillableByteLinkedListMultimap<K, V>

David Yan created APEXMALHAR-2228: - Summary: Implement SpillableByteLinkedListMultimap Key: APEXMALHAR-2228 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2228 Project: Apache Apex Malhar

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471393#comment-15471393 ] Thomas Weise commented on APEXMALHAR-2130: -- Which keys belong to which window can be seen as

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471327#comment-15471327 ] Thomas Weise commented on APEXMALHAR-2227: -- Once the fix is merged, we will add instructions

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXMALHAR-2227: - Affects Version/s: 3.5.0 > Error while connecting with Kafka using Apache Apex >

[jira] [Resolved] (APEXCORE-521) Upgrade Apex core pom.xml to the latest Apache pom parent

[ https://issues.apache.org/jira/browse/APEXCORE-521?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Vlad Rozov resolved APEXCORE-521. - Resolution: Done Fix Version/s: 3.5.0 > Upgrade Apex core pom.xml to the latest Apache

[GitHub] apex-core pull request #380: APEXCORE-521 upate parent pom references.

Github user asfgit closed the pull request at: https://github.com/apache/apex-core/pull/380 --- 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] [Commented] (APEXCORE-521) Upgrade Apex core pom.xml to the latest Apache pom parent

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

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

[ 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] [Commented] (APEXMALHAR-2227) Error while connecting with Kafka using Apache Apex

[ 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] (APEXCORE-521) Upgrade Apex core pom.xml to the latest Apache pom parent

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

[GitHub] apex-core pull request #384: APEXCORE-521 upate parent pom references.

GitHub user vrozov opened a pull request: https://github.com/apache/apex-core/pull/384 APEXCORE-521 upate parent pom references. test Apache Jenkins PR build. Please don't merge. You can merge this pull request into a Git repository by running: $ git pull

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

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

[GitHub] apex-malhar pull request #402: APEXMALHAR-2227 Index out of Bound Exception ...

GitHub user chandnisingh opened a pull request: https://github.com/apache/apex-malhar/pull/402 APEXMALHAR-2227 Index out of Bound Exception fix in Kafka input @siyuanh @tweise You can merge this pull request into a Git repository by running: $ git pull

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15471005#comment-15471005 ] Rambrij Chauhan commented on APEXMALHAR-2227: - Hi Chandni, It will be great help, Just

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

[ 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

[ 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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470942#comment-15470942 ] Rambrij Chauhan commented on APEXMALHAR-2227: - Hi Thomas, Thanks for the quick reply, I

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470908#comment-15470908 ] Thomas Weise commented on APEXMALHAR-2227: -- This looks like a question appropriate for the

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

[ https://issues.apache.org/jira/browse/APEXMALHAR-2227?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise moved APEXCORE-523 to APEXMALHAR-2227: --- Affects Version/s: (was: 3.4.0)

[jira] [Commented] (APEXCORE-523) Error while connecting with Kafka using Apache Apex

[ https://issues.apache.org/jira/browse/APEXCORE-523?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470861#comment-15470861 ] Rambrij Chauhan commented on APEXCORE-523: -- Also for your information here are the api version

[jira] [Updated] (APEXCORE-523) Error while connecting with Kafka using Apache Apex

[ https://issues.apache.org/jira/browse/APEXCORE-523?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Rambrij Chauhan updated APEXCORE-523: - Affects Version/s: 3.4.0 > Error while connecting with Kafka using Apache Apex >

[jira] [Created] (APEXCORE-523) Error while connecting with Kafka using Apache Apex

Rambrij Chauhan created APEXCORE-523: Summary: Error while connecting with Kafka using Apache Apex Key: APEXCORE-523 URL: https://issues.apache.org/jira/browse/APEXCORE-523 Project: Apache Apex

Fixed Width Record Parser

Hi All, An operator for parsing fixed width records has to be implemented. This operator shall be used to parse fixed width byte array/tuples based on a JSON Schema and emit the parsed bytearray on one port; converted POJO object on another port and the failed bytearray/tuples on an error port.

[GitHub] apex-malhar pull request #401: APEXMALHAR-2226 Fixed the Not supported excep...

GitHub user chaithu14 opened a pull request: https://github.com/apache/apex-malhar/pull/401 APEXMALHAR-2226 Fixed the Not supported exception while re-deploying the AbstractFileOutput Operator You can merge this pull request into a Git repository by running: $ git pull

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

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

[jira] [Comment Edited] (APEXMALHAR-2224) GenericFileOutputOperator rotateCall fails if no data is written to the file

[ https://issues.apache.org/jira/browse/APEXMALHAR-2224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470073#comment-15470073 ] Yogi Devendra edited comment on APEXMALHAR-2224 at 9/7/16 8:59 AM: ---

[jira] [Commented] (APEXMALHAR-2224) GenericFileOutputOperator rotateCall fails if no data is written to the file

[ https://issues.apache.org/jira/browse/APEXMALHAR-2224?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15470073#comment-15470073 ] Yogi Devendra commented on APEXMALHAR-2224: --- One possible solution could be: check for

[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