[jira] [Commented] (APEXCORE-332) Support Even Distribution Of Tuples To A Non Power Of 2 Number Of Partitions

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

[jira] [Commented] (APEXCORE-332) Support Even Distribution Of Tuples To A Non Power Of 2 Number Of Partitions

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

[GitHub] incubator-apex-core pull request: [APEXCORE-332][WIP] Improve part...

Github user amberarrow commented on a diff in the pull request: https://github.com/apache/incubator-apex-core/pull/347#discussion_r64847617 --- Diff: .idea/codeStyleSettings.xml --- @@ -104,5 +104,6 @@ + --- End diff --

[GitHub] incubator-apex-core pull request: [APEXCORE-332][WIP] Improve part...

Github user vrozov commented on a diff in the pull request: https://github.com/apache/incubator-apex-core/pull/347#discussion_r64846471 --- Diff: .idea/codeStyleSettings.xml --- @@ -104,5 +104,6 @@ + --- End diff -- Please keep

[jira] [Updated] (APEXMALHAR-2086) Kafka Output Operator with Kafka 0.9 API

[ https://issues.apache.org/jira/browse/APEXMALHAR-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Sandesh updated APEXMALHAR-2086: Description: Goal : 2 Operartors for Kafka Output 1. Simple Kafka Output Operator

Re: Kafka Exactly once output operator

Current design: Window Data Manager - Stores the Kafka partitions offsets. Kafka Key - Used by the operator = AppID#OperatorId During recovery. Partially written window is re-created using the following approach: Tuples between the largest recovery offsets and the current offset are checked.

[GitHub] incubator-apex-malhar pull request: *For review only* [APEXMALHAR-...

GitHub user sandeshh opened a pull request: https://github.com/apache/incubator-apex-malhar/pull/298 *For review only* [APEXMALHAR-2086] Kafka output: 0.9.1 first cut Kafka output exactly once operator and the regular output operator. You can merge this pull request into a

[jira] [Commented] (APEXCORE-208) StreamingContainer.java Contains Violations of Style Guide

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

[GitHub] incubator-apex-core pull request: [APEXCORE-208] Fixed checkstyle ...

Github user davidyan74 commented on the pull request: https://github.com/apache/incubator-apex-core/pull/346#issuecomment-222028058 @ilganeli I see that you're changing the code by wrapping the long lines. We some time ago decided on the Apex dev mailing list that we are not

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-2096: Add property ...

Github user gauravgopi123 commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/287#discussion_r64840077 --- Diff: library/src/main/java/com/datatorrent/lib/io/fs/FSInputModule.java --- @@ -59,6 +58,9 @@ private long blockSize;

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

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

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

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

[jira] [Commented] (APEXCORE-208) StreamingContainer.java Contains Violations of Style Guide

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

[GitHub] incubator-apex-core pull request: [APEXCORE-208] Fixed checkstyle ...

GitHub user ilganeli opened a pull request: https://github.com/apache/incubator-apex-core/pull/346 [APEXCORE-208] Fixed checkstyle violations in StreamingContainer.java - Fixed checkstyle violations in StreamingContainer.java. - Updated apex-style configuration in .idea to be

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-2096: Add property ...

Github user chandnisingh commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/287#discussion_r64835548 --- Diff: library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java --- @@ -53,6 +53,7 @@ * This is a threshold

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

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

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-2096: Add property ...

Github user DT-Priyanka commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/287#discussion_r64835068 --- Diff: library/src/main/java/com/datatorrent/lib/io/fs/AbstractFileSplitter.java --- @@ -53,6 +53,7 @@ * This is a threshold

[jira] [Updated] (APEXCORE-172) Fix License Header In StatefulStreamCodec

[ https://issues.apache.org/jira/browse/APEXCORE-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXCORE-172: -- Assignee: Ilya Ganelin (was: Timothy Farkas) > Fix License Header In StatefulStreamCodec >

[jira] [Closed] (APEXCORE-172) Fix License Header In StatefulStreamCodec

[ https://issues.apache.org/jira/browse/APEXCORE-172?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise closed APEXCORE-172. - Resolution: Fixed > Fix License Header In StatefulStreamCodec >

[GitHub] incubator-apex-core pull request: [APEXCORE-172] Fixed license hea...

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

[jira] [Commented] (APEXCORE-172) Fix License Header In StatefulStreamCodec

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

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-2096: Add property ...

Github user gauravgopi123 commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/287#discussion_r64828487 --- Diff: library/src/main/java/com/datatorrent/lib/io/fs/FSInputModule.java --- @@ -59,6 +58,9 @@ private long blockSize;

[jira] [Commented] (APEXMALHAR-2066) Add jdbc poller input operator

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

[jira] [Commented] (APEXMALHAR-2066) Add jdbc poller input operator

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

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-2066 JdbcPolling,id...

Github user gauravgopi123 commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/282#discussion_r64825894 --- Diff: library/src/main/java/com/datatorrent/lib/db/jdbc/AbstractJdbcPollInputOperator.java --- @@ -0,0 +1,652 @@ +/** + *

[jira] [Commented] (APEXMALHAR-2094) Quantiles sketch operator

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

[jira] [Commented] (APEXMALHAR-2094) Quantiles sketch operator

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

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-2094 Quantiles Oper...

Github user sandeep-n commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/296#discussion_r64818557 --- Diff: sketches/src/main/java/org/apache/apex/malhar/sketches/QuantilesEstimator.java --- @@ -0,0 +1,188 @@ +/** + * Licensed

Re: IntelliJ and Netbeans code styles are missing

Another question - are CheckStyle settings packaged anywhere? There is obviously a CheckStyle run by Jenkins - is this CheckStyle published for Apex or Malhar? On 5/24/16, 2:19 PM, "Ganelin, Ilya" wrote: >I just realized that these were moved to subdirectories

[jira] [Commented] (APEXMALHAR-2094) Quantiles sketch operator

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

[jira] [Commented] (APEXMALHAR-2094) Quantiles sketch operator

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

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-2094 Quantiles Oper...

Github user ilganeli commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/296#discussion_r64810211 --- Diff: sketches/src/main/java/org/apache/apex/malhar/sketches/QuantilesEstimator.java --- @@ -0,0 +1,188 @@ +/** + * Licensed to

[GitHub] incubator-apex-malhar pull request: APEXMALHAR-2094 Quantiles Oper...

Github user ilganeli commented on a diff in the pull request: https://github.com/apache/incubator-apex-malhar/pull/296#discussion_r64810147 --- Diff: sketches/src/main/java/org/apache/apex/malhar/sketches/QuantilesEstimator.java --- @@ -0,0 +1,188 @@ +/** + * Licensed to

[jira] [Updated] (APEXMALHAR-2102) Add A Clone Partitioner Which Sends The Same Data To Each Partition

[ https://issues.apache.org/jira/browse/APEXMALHAR-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise updated APEXMALHAR-2102: - Assignee: Ilya Ganelin > Add A Clone Partitioner Which Sends The Same Data To Each

[jira] [Moved] (APEXMALHAR-2102) Add A Clone Partitioner Which Sends The Same Data To Each Partition

[ https://issues.apache.org/jira/browse/APEXMALHAR-2102?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Thomas Weise moved APEXCORE-146 to APEXMALHAR-2102: --- Assignee: (was: Ilya Ganelin) Workflow: Default

[jira] [Commented] (APEXCORE-146) Add A Clone Partitioner Which Sends The Same Data To Each Partition

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

[jira] [Commented] (APEXCORE-146) Add A Clone Partitioner Which Sends The Same Data To Each Partition

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

[jira] [Commented] (APEXCORE-146) Add A Clone Partitioner Which Sends The Same Data To Each Partition

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

[GitHub] incubator-apex-malhar pull request: [APEXCORE-146] Add ClonePartit...

GitHub user ilganeli opened a pull request: https://github.com/apache/incubator-apex-malhar/pull/297 [APEXCORE-146] Add ClonePartitioner **Note:** This is still marked as an Apex issue even though it should live in Malhar. Once the JIRA is updated I'll update title and reference.

[GitHub] incubator-apex-core pull request: [APEXCORE-146] Add ClonePartitio...

Github user ilganeli commented on the pull request: https://github.com/apache/incubator-apex-core/pull/344#issuecomment-221973428 Moved to https://github.com/apache/incubator-apex-malhar/pull/297 --- If your project is set up for it, you can reply to this email and have your reply

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

[ 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