[
https://issues.apache.org/jira/browse/APEXMALHAR-2120?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
bright chen updated APEXMALHAR-2120:
Description:
problems in Unit Test class: KafkaInputOperatorTest
- 'k' not initialized
I think its a good idea to have a scheduling operator when you need to
start a part of the DAG when some trigger happens (for eg. FileSplitter
identifying new files in FS) and otherwise bring it down to save resources.
On Wed, Jun 22, 2016 at 9:54 AM, Timothy Farkas <
[
https://issues.apache.org/jira/browse/APEXCORE-473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345190#comment-15345190
]
Thomas Weise commented on APEXCORE-473:
---
BTW when you have a shuffle (MxN) then the unifier will
[
https://issues.apache.org/jira/browse/APEXCORE-473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345223#comment-15345223
]
Sandesh commented on APEXCORE-473:
--
Yes, that's what limits the benefits of this approach.
> Default
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/279#discussion_r68148125
--- Diff:
library/src/main/java/com/datatorrent/lib/bandwidth/BandwidthPartitioner.java
---
@@ -0,0 +1,78 @@
+/**
+ * Licensed to the Apache
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68178863
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369 @@
+/**
+ *
[
https://issues.apache.org/jira/browse/APEXMALHAR-1957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345773#comment-15345773
]
ASF GitHub Bot commented on APEXMALHAR-1957:
Github user bhupeshchawda commented on a
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/292#discussion_r68177487
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java
---
@@ -37,20 +37,21 @@
import
[
https://issues.apache.org/jira/browse/APEXMALHAR-1957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345767#comment-15345767
]
ASF GitHub Bot commented on APEXMALHAR-1957:
Github user bhupeshchawda commented on a
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/292#discussion_r68177086
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/hbase/HBaseScanOperator.java ---
@@ -79,4 +170,79 @@ public void emitTuples()
*/
[
https://issues.apache.org/jira/browse/APEXMALHAR-1957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345770#comment-15345770
]
ASF GitHub Bot commented on APEXMALHAR-1957:
Github user bhupeshchawda commented on a
[
https://issues.apache.org/jira/browse/APEXMALHAR-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345819#comment-15345819
]
ASF GitHub Bot commented on APEXMALHAR-2086:
Github user siyuanh commented on a diff in
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68179198
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369 @@
+/**
+ *
Github user siyuanh commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/298#discussion_r68179058
--- Diff:
kafka/src/main/java/org/apache/apex/malhar/kafka/KafkaSinglePortExactlyOnceOutputOperator.java
---
@@ -0,0 +1,369 @@
+/**
+ *
[
https://issues.apache.org/jira/browse/APEXMALHAR-2086?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345817#comment-15345817
]
ASF GitHub Bot commented on APEXMALHAR-2086:
Github user siyuanh commented on a diff in
bright chen created APEXMALHAR-2124:
---
Summary: DTFileTest.seekDTFile failed in Travis
Key: APEXMALHAR-2124
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2124
Project: Apache Apex Malhar
GitHub user brightchen reopened a pull request:
https://github.com/apache/apex-malhar/pull/321
APEXMALHAR-2120 #resolve #comment solve problems of KafkaInputOperatoâ¦
â¦rTest and AbstractKafkaInputOperator
You can merge this pull request into a Git repository by running:
$
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/279#discussion_r68147701
--- Diff:
library/src/main/java/com/datatorrent/lib/bandwidth/BandwidthManager.java ---
@@ -0,0 +1,137 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345292#comment-15345292
]
ASF GitHub Bot commented on APEXMALHAR-2045:
Github user vrozov commented on a diff in
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/279#discussion_r68150902
--- Diff:
library/src/main/java/com/datatorrent/lib/bandwidth/BandwidthManager.java ---
@@ -0,0 +1,139 @@
+/**
+ * Licensed to the Apache
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/279#discussion_r68151025
--- Diff:
library/src/main/java/com/datatorrent/lib/bandwidth/BandwidthManager.java ---
@@ -0,0 +1,139 @@
+/**
+ * Licensed to the Apache
[
https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345341#comment-15345341
]
ASF GitHub Bot commented on APEXMALHAR-2045:
Github user vrozov commented on a diff in
[
https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345307#comment-15345307
]
ASF GitHub Bot commented on APEXMALHAR-2045:
Github user vrozov commented on a diff in
[
https://issues.apache.org/jira/browse/APEXCORE-473?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345174#comment-15345174
]
Thomas Weise commented on APEXCORE-473:
---
Since the implementation of that unifier is part of the
[
https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345304#comment-15345304
]
ASF GitHub Bot commented on APEXMALHAR-2045:
Github user vrozov commented on a diff in
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/279#discussion_r68144992
--- Diff:
library/src/main/java/com/datatorrent/lib/bandwidth/BandwidthLimitingOperator.java
---
@@ -0,0 +1,29 @@
+/**
+ * Licensed to the
[
https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345268#comment-15345268
]
ASF GitHub Bot commented on APEXMALHAR-2045:
Github user vrozov commented on a diff in
[
https://issues.apache.org/jira/browse/APEXMALHAR-2048?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345458#comment-15345458
]
Thomas Weise commented on APEXMALHAR-2048:
--
APEXMALHAR-2085 should use this for window state
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r68163971
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -769,7 +769,11 @@ public void
[
https://issues.apache.org/jira/browse/APEXCORE-222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=1534#comment-1534
]
ASF GitHub Bot commented on APEXCORE-222:
-
Github user vrozov commented on a diff in the pull
[
https://issues.apache.org/jira/browse/APEXCORE-222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345573#comment-15345573
]
ASF GitHub Bot commented on APEXCORE-222:
-
Github user vrozov commented on a diff in the pull
[
https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345545#comment-15345545
]
ASF GitHub Bot commented on APEXMALHAR-2045:
Github user vrozov commented on a diff in
[
https://issues.apache.org/jira/browse/APEXMALHAR-1957?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345684#comment-15345684
]
ASF GitHub Bot commented on APEXMALHAR-1957:
Github user bhupeshchawda commented on a
Github user bhupeshchawda commented on a diff in the pull request:
https://github.com/apache/apex-malhar/pull/292#discussion_r68172645
--- Diff:
contrib/src/main/java/com/datatorrent/contrib/hbase/HBasePOJOInputOperator.java
---
@@ -69,116 +70,105 @@ public Object convertValue(
[
https://issues.apache.org/jira/browse/APEXCORE-222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345565#comment-15345565
]
Thomas Weise commented on APEXCORE-222:
---
You need to analyze the exact sequence of events during
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r68164956
--- Diff:
bufferserver/src/main/java/com/datatorrent/bufferserver/internal/DataList.java
---
@@ -178,19 +178,23 @@ public void reset()
public
[
https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345519#comment-15345519
]
ASF GitHub Bot commented on APEXMALHAR-2045:
Github user vrozov commented on a diff in
[
https://issues.apache.org/jira/browse/APEXCORE-222?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel=15345591#comment-15345591
]
ASF GitHub Bot commented on APEXCORE-222:
-
Github user vrozov commented on a diff in the pull
Github user vrozov commented on a diff in the pull request:
https://github.com/apache/apex-core/pull/350#discussion_r68166717
--- Diff:
engine/src/main/java/com/datatorrent/stram/engine/StreamingContainer.java ---
@@ -769,7 +769,11 @@ public void
39 matches
Mail list logo
