Re: [ANNOUNCE] New Apache Apex PMC Member: Siyuan Hua

Congratulations Siyuan. Ashish > On 16-Jun-2016, at 10:49 AM, Aniruddha Thombare > wrote: > > Congratulations!!! > > Thanks, > > A > > _ > Sent with difficulty, I mean handheld ;) > On 16 Jun 2016 10:47 am, "Devendra Tagare"

Re: [ANNOUNCE] New Apache Apex PMC Member: Siyuan Hua

Congratulations Siyuan!! ~ Bhupesh On Wed, Jun 15, 2016 at 10:19 PM, Sandeep Deshmukh wrote: > Congrats Siyuan !!! > > Regards, > Sandeep > > On Thu, Jun 16, 2016 at 10:49 AM, Aniruddha Thombare < > anirud...@datatorrent.com> wrote: > > > Congratulations!!! > > > >

Re: [ANNOUNCE] New Apache Apex PMC Member: Siyuan Hua

Congrats Siyuan !!! Regards, Sandeep On Thu, Jun 16, 2016 at 10:49 AM, Aniruddha Thombare < anirud...@datatorrent.com> wrote: > Congratulations!!! > > Thanks, > > A > > _ > Sent with difficulty, I mean handheld ;) > On 16 Jun 2016 10:47 am, "Devendra Tagare"

Re: [ANNOUNCE] New Apache Apex PMC Member: Siyuan Hua

Congratulations!!! Thanks, A _ Sent with difficulty, I mean handheld ;) On 16 Jun 2016 10:47 am, "Devendra Tagare" wrote: > Congratulations Siyuan > > Cheers, > Dev > On Jun 15, 2016 10:13 PM, "Chinmay Kolhatkar"

Re: [ANNOUNCE] New Apache Apex PMC Member: Siyuan Hua

Congratulations Siyuan Cheers, Dev On Jun 15, 2016 10:13 PM, "Chinmay Kolhatkar" wrote: > Congrats Siyuan :) > > On Wed, Jun 15, 2016 at 10:05 PM, Priyanka Gugale > wrote: > > > Congrats Siyuan :) > > > > -Priyanka > > > > On Thu, Jun 16, 2016 at

[jira] [Commented] (APEXMALHAR-2120) Fix bugs on KafkaInputOperatorTest AbstractKafkaInputOperator

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

[jira] [Commented] (APEXMALHAR-2120) Fix bugs on KafkaInputOperatorTest AbstractKafkaInputOperator

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

[GitHub] apex-malhar pull request #320: APEXMALHAR-2120 #resolve #comment solve probl...

GitHub user brightchen reopened a pull request: https://github.com/apache/apex-malhar/pull/320 APEXMALHAR-2120 #resolve #comment solve problems of KafkaInputOperato… …rTest and AbstractKafkaInputOperator You can merge this pull request into a Git repository by running: $

[GitHub] apex-malhar pull request #320: APEXMALHAR-2120 #resolve #comment solve probl...

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

Re: [ANNOUNCE] New Apache Apex PMC Member: Siyuan Hua

Congrats Siyuan :) -Priyanka On Thu, Jun 16, 2016 at 10:19 AM, Pradeep Kumbhar wrote: > Congratulations Siyuan!! > > On Thu, Jun 16, 2016 at 10:17 AM, Teddy Rusli > wrote: > > > Congrats Siyuan! > > > > On Wed, Jun 15, 2016 at 9:28 PM, Ashwin

Re: [ANNOUNCE] New Apache Apex PMC Member: Siyuan Hua

Congratulations Siyuan!! On Thu, Jun 16, 2016 at 10:17 AM, Teddy Rusli wrote: > Congrats Siyuan! > > On Wed, Jun 15, 2016 at 9:28 PM, Ashwin Chandra Putta < > ashwinchand...@gmail.com> wrote: > > > Congratulations Siyuan!! > > On Jun 15, 2016 9:26 PM, "Thomas Weise"

Re: [ANNOUNCE] New Apache Apex PMC Member: Siyuan Hua

Congrats Siyuan! On Wed, Jun 15, 2016 at 9:28 PM, Ashwin Chandra Putta < ashwinchand...@gmail.com> wrote: > Congratulations Siyuan!! > On Jun 15, 2016 9:26 PM, "Thomas Weise" wrote: > > > The Apache Apex PMC is pleased to announce that Siyuan Hua is now a PMC > > member.

Re: [ANNOUNCE] New Apache Apex PMC Member: Siyuan Hua

Congratulations Siyuan!! On Jun 15, 2016 9:26 PM, "Thomas Weise" wrote: > The Apache Apex PMC is pleased to announce that Siyuan Hua is now a PMC > member. We appreciate all his contributions to the project so far, and are > looking forward to more. > > Welcome, Siyuan,

[ANNOUNCE] New Apache Apex PMC Member: Siyuan Hua

The Apache Apex PMC is pleased to announce that Siyuan Hua is now a PMC member. We appreciate all his contributions to the project so far, and are looking forward to more. Welcome, Siyuan, and congratulations! Thomas, for the Apache Apex PMC.

Purging the checkpoints from the StreamingContainers

Hello Team, Purging of the Checkpoints is done in Stram. Why not do that from the StreamingContainers? Committed window information is already available in StreamingContainers and it will also distribute the computation across the containers. Corner cases can still be handled in Stram. Example:

[GitHub] apex-malhar pull request #320: APEXMALHAR-2120 #resolve #comment solve probl...

Github user amberarrow commented on a diff in the pull request: https://github.com/apache/apex-malhar/pull/320#discussion_r67269717 --- Diff: kafka/src/test/java/org/apache/apex/malhar/kafka/KafkaInputOperatorTest.java --- @@ -120,8 +127,14 @@ public KafkaInputOperatorTest(boolean

Re: Parquet Writer Operator

Hi Dev, Can you not use the existing WAL implementation (via WindowDataManager or directly)? Thomas On Wed, Jun 15, 2016 at 3:47 PM, Devendra Tagare wrote: > Hi, > > Initial thoughts were to go for a WAL based approach where the operator > would first write POJO's

[GitHub] apex-malhar pull request #320: APEXMALHAR-2120 #resolve #comment solve probl...

GitHub user brightchen opened a pull request: https://github.com/apache/apex-malhar/pull/320 APEXMALHAR-2120 #resolve #comment solve problems of KafkaInputOperato… …rTest and AbstractKafkaInputOperator You can merge this pull request into a Git repository by running: $ git

[jira] [Created] (APEXMALHAR-2120) Fix bugs on KafkaInputOperatorTest AbstractKafkaInputOperator

bright chen created APEXMALHAR-2120: --- Summary: Fix bugs on KafkaInputOperatorTest AbstractKafkaInputOperator Key: APEXMALHAR-2120 URL: https://issues.apache.org/jira/browse/APEXMALHAR-2120 Project:

[GitHub] apex-malhar pull request #319: REVIEW ONLY: Operator supporting the Beam con...

GitHub user davidyan74 opened a pull request: https://github.com/apache/apex-malhar/pull/319 REVIEW ONLY: Operator supporting the Beam concepts of windowing, watermarks, triggering and accumulation This review-only PR contains the interfaces and a first rough draft of the

[jira] [Commented] (APEXCORE-386) Upgrade to Jackson 1.9.13

[ https://issues.apache.org/jira/browse/APEXCORE-386?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15332484#comment-15332484 ] Tatu Saloranta commented on APEXCORE-386: - I run the existing test suite, as no new

[jira] [Commented] (APEXCORE-470) New Api for setting the attribute on the operator ( setOperatorAttribute )

[ https://issues.apache.org/jira/browse/APEXCORE-470?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15332479#comment-15332479 ] ASF GitHub Bot commented on APEXCORE-470: - Github user sandeshh commented on a diff in the pull

[GitHub] apex-core pull request #349: APEXCORE-470 New API in DAG - setOperatorAttrib...

Github user sandeshh commented on a diff in the pull request: https://github.com/apache/apex-core/pull/349#discussion_r67238893 --- Diff: api/src/main/java/com/datatorrent/api/DAG.java --- @@ -236,11 +236,22 @@ public abstract void setAttribute(Attribute key, T value);

[jira] [Commented] (APEXMALHAR-2119) Make DirectoryScanner in AbstractFileInputOperator inheritance friendly.

[ https://issues.apache.org/jira/browse/APEXMALHAR-2119?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15331848#comment-15331848 ] ASF GitHub Bot commented on APEXMALHAR-2119: Github user amberarrow commented on a diff

[jira] [Commented] (APEXMALHAR-2119) Make DirectoryScanner in AbstractFileInputOperator inheritance friendly.

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

[GitHub] apex-malhar pull request #318: APEXMALHAR-2119 add setters for partition cou...

GitHub user tushargosavi opened a pull request: https://github.com/apache/apex-malhar/pull/318 APEXMALHAR-2119 add setters for partition count and index. You can merge this pull request into a Git repository by running: $ git pull