[
https://issues.apache.org/jira/browse/APEXMALHAR-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227851#comment-15227851
]
ASF GitHub Bot commented on APEXMALHAR-2046:
Github user chandnisingh com
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/232#discussion_r58659020
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/spillable/SpillableFactory.java
---
@@ -0,0 +1,171 @@
+/*
+ * Copyrig
[
https://issues.apache.org/jira/browse/APEXMALHAR-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227848#comment-15227848
]
ASF GitHub Bot commented on APEXMALHAR-2046:
Github user chandnisingh com
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/232#discussion_r58658808
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/spillable/Serde.java ---
@@ -0,0 +1,42 @@
+/*
+ * Copyright 2016 Apach
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/232#discussion_r58658309
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/spillable/Serde.java ---
@@ -0,0 +1,42 @@
+/*
+ * Copyright 2016 Apach
[
https://issues.apache.org/jira/browse/APEXMALHAR-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227845#comment-15227845
]
ASF GitHub Bot commented on APEXMALHAR-2046:
Github user chandnisingh com
[
https://issues.apache.org/jira/browse/APEXMALHAR-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227844#comment-15227844
]
ASF GitHub Bot commented on APEXMALHAR-2046:
Github user chandnisingh com
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/232#discussion_r58658226
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/spillable/Serde.java ---
@@ -0,0 +1,42 @@
+/*
+ * Copyright 2016 Apach
[
https://issues.apache.org/jira/browse/APEXMALHAR-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227836#comment-15227836
]
ASF GitHub Bot commented on APEXMALHAR-2046:
Github user chandnisingh com
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/232#discussion_r58657819
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/spillable/SpillableFactory.java
---
@@ -0,0 +1,171 @@
+/*
+ * Copyrig
[
https://issues.apache.org/jira/browse/APEXMALHAR-2014?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chinmay Kolhatkar closed APEXMALHAR-2014.
-
Resolution: Done
Fix Version/s: 3.4.0
Work completed on this task.
Par
[
https://issues.apache.org/jira/browse/APEXMALHAR-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227828#comment-15227828
]
ASF GitHub Bot commented on APEXMALHAR-2046:
Github user chandnisingh com
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/232#discussion_r58657579
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/spillable/SpillableFactory.java
---
@@ -0,0 +1,171 @@
+/*
+ * Copyrig
[
https://issues.apache.org/jira/browse/APEXMALHAR-2014?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227827#comment-15227827
]
ASF GitHub Bot commented on APEXMALHAR-2014:
Github user asfgit closed th
[
https://issues.apache.org/jira/browse/APEXMALHAR-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227831#comment-15227831
]
ASF GitHub Bot commented on APEXMALHAR-2046:
Github user chandnisingh com
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-apex-malhar/pull/230
---
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
Github user chandnisingh commented on a diff in the pull request:
https://github.com/apache/incubator-apex-malhar/pull/232#discussion_r58657541
--- Diff:
library/src/main/java/org/apache/apex/malhar/lib/spillable/SpillableFactory.java
---
@@ -0,0 +1,171 @@
+/*
+ * Copyrig
[
https://issues.apache.org/jira/browse/APEXMALHAR-2046?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227820#comment-15227820
]
ASF GitHub Bot commented on APEXMALHAR-2046:
GitHub user ilooner opened a
GitHub user ilooner opened a pull request:
https://github.com/apache/incubator-apex-malhar/pull/232
APEXMALHAR-2046 #resolve #comment adding spillable data structures faâ¦
â¦ctory interface.
You can merge this pull request into a Git repository by running:
$ git pull https://
Timothy Farkas created APEXMALHAR-2046:
--
Summary: Create SpillableFactory Interface
Key: APEXMALHAR-2046
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2046
Project: Apache Apex Malhar
[
https://issues.apache.org/jira/browse/APEXCORE-340?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Chinmay Kolhatkar reassigned APEXCORE-340:
--
Assignee: Chinmay Kolhatkar
> Rename dtcli script to apex
> -
Thumb rule for import order:
As you go down the import order; you have more and more control over making
changes to that code.
Considering this idea, separation of org.apache.apex makes sense.
+1 for org.apache.apex
+0 separating api imports.
~ Yogi
On 6 April 2016 at 11:19, Thomas Weise wrot
[
https://issues.apache.org/jira/browse/APEXMALHAR-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227780#comment-15227780
]
Thomas Weise commented on APEXMALHAR-2026:
--
Ability to work with byte[] is i
[
https://issues.apache.org/jira/browse/APEXCORE-421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227774#comment-15227774
]
ASF GitHub Bot commented on APEXCORE-421:
-
Github user ilooner commented on the
Github user ilooner commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/296#issuecomment-206129344
@sandeshh I agree, the problem is that this code is quite complex and there
is almost no unit test coverage. I am afraid to do refactoring on code I don't
Just wanted to know why, I have no preference.
On Tue, Apr 5, 2016 at 10:48 PM, Chandni Singh
wrote:
> We treated com.datatorrent in a special way earlier which is why I started
> the discussion.
> If we don't want to have anything special for org.apache.apex then there
> will not be any change.
We treated com.datatorrent in a special way earlier which is why I started
the discussion.
If we don't want to have anything special for org.apache.apex then there
will not be any change.
Chandni
On Tue, Apr 5, 2016 at 10:18 PM, Thomas Weise
wrote:
> Why do we need something special for org.apa
Why do we need something special for org.apache.apex ?
On Tue, Apr 5, 2016 at 10:15 PM, Chandni Singh
wrote:
> +1 for Ram's suggestion :-)
>
> On Tue, Apr 5, 2016 at 5:18 PM, Munagala Ramanath
> wrote:
>
> > I'd suggest keeping all the org.apache imports together and in
> > lexicographic order
+1 for Ram's suggestion :-)
On Tue, Apr 5, 2016 at 5:18 PM, Munagala Ramanath
wrote:
> I'd suggest keeping all the org.apache imports together and in
> lexicographic order.
>
> Ram
>
> On Tue, Apr 5, 2016 at 5:12 PM, Chandni Singh
> wrote:
>
> > Hi,
> >
> > We need to include org.apache.apex in
[
https://issues.apache.org/jira/browse/APEXCORE-421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227736#comment-15227736
]
ASF GitHub Bot commented on APEXCORE-421:
-
Github user sandeshh commented on the
Github user sandeshh commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/296#issuecomment-206120906
If the checkpoint function is not properly used in 3 places, it is time to
fix that as well.
---
If your project is set up for it, you can reply to this
[
https://issues.apache.org/jira/browse/APEXCORE-415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227725#comment-15227725
]
ASF GitHub Bot commented on APEXCORE-415:
-
Github user ilooner closed the pull r
Github user ilooner closed the pull request at:
https://github.com/apache/incubator-apex-core/pull/295
---
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 f
[
https://issues.apache.org/jira/browse/APEXCORE-421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227720#comment-15227720
]
ASF GitHub Bot commented on APEXCORE-421:
-
Github user ilooner commented on the
Github user ilooner commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/296#issuecomment-206118367
@davidyan74 please review. There was another double checkpointing bug in
InputNode which was causing my unit test to fail on travis.
---
If your project i
[
https://issues.apache.org/jira/browse/APEXCORE-421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227717#comment-15227717
]
Timothy Farkas commented on APEXCORE-421:
-
This bug was causing my double checkp
[
https://issues.apache.org/jira/browse/APEXCORE-421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227714#comment-15227714
]
ASF GitHub Bot commented on APEXCORE-421:
-
GitHub user ilooner opened a pull req
GitHub user ilooner opened a pull request:
https://github.com/apache/incubator-apex-core/pull/296
APEXCORE-421 #comment #resolve Fixing double checkpoint bug on InputNâ¦
â¦ode shutdown
You can merge this pull request into a Git repository by running:
$ git pull https://github
Timothy Farkas created APEXCORE-421:
---
Summary: Double Checkpointing May Happen In Input Node On Shutdown
Key: APEXCORE-421
URL: https://issues.apache.org/jira/browse/APEXCORE-421
Project: Apache Apex
[
https://issues.apache.org/jira/browse/APEXCORE-421?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227706#comment-15227706
]
Timothy Farkas commented on APEXCORE-421:
-
this is related to APEXCORE-415
> Do
I'd suggest keeping all the org.apache imports together and in
lexicographic order.
Ram
On Tue, Apr 5, 2016 at 5:12 PM, Chandni Singh
wrote:
> Hi,
>
> We need to include org.apache.apex in the import order that we have right
> now:
>
> *Current order:*
> java
> javax
> org
> org.apache
> io
> c
Also I think it will be a good idea to segregate api imports:
*Proposed order:*
java
javax
org
org.apache
io
com
com.datatorrent.api
com.datatorrent
org.apache.apex.api
org.apache.apex
*
all static imports
On Tue, Apr 5, 2016 at 5:12 PM, Chandni Singh
wrote:
> Hi,
>
> We need to include org.ap
Hi,
We need to include org.apache.apex in the import order that we have right
now:
*Current order:*
java
javax
org
org.apache
io
com
com.datatorrent
*
all static imports
*Proposed order:*
java
javax
org
org.apache
io
com
com.datatorrent
org.apache.apex
*
all static imports
Thanks,
Chandni
[
https://issues.apache.org/jira/browse/APEXCORE-411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227348#comment-15227348
]
ASF GitHub Bot commented on APEXCORE-411:
-
GitHub user davidyan74 reopened a pul
Github user davidyan74 closed the pull request at:
https://github.com/apache/incubator-apex-core/pull/294
---
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 th
[
https://issues.apache.org/jira/browse/APEXCORE-411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227347#comment-15227347
]
ASF GitHub Bot commented on APEXCORE-411:
-
Github user davidyan74 closed the pul
GitHub user davidyan74 reopened a pull request:
https://github.com/apache/incubator-apex-core/pull/294
APEXCORE-411 support restarting app without app package or jar files
@tweise please review
You can merge this pull request into a Git repository by running:
$ git pull https:/
[
https://issues.apache.org/jira/browse/APEXCORE-415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227326#comment-15227326
]
ASF GitHub Bot commented on APEXCORE-415:
-
GitHub user ilooner opened a pull req
GitHub user ilooner opened a pull request:
https://github.com/apache/incubator-apex-core/pull/295
APEXCORE-415 #resolve #comment Fixed double checkpointing bug in Inpuâ¦
â¦tNode.
You can merge this pull request into a Git repository by running:
$ git pull https://github.com/i
[
https://issues.apache.org/jira/browse/APEXMALHAR-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashwin Chandra Putta updated APEXMALHAR-2037:
-
Description:
There are many use cases in which we are writing tuples
This can be done as a pluggable component that can be reused in existing
output operators. The component will have a queue to buffer the regular
flow of tuples and back it using WAL (APEXMALHAR-1965) when external system
is slow or down. Will start a thread on the design soon.
Regards,
Ashwin.
On
[
https://issues.apache.org/jira/browse/APEXMALHAR-2037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Ashwin Chandra Putta updated APEXMALHAR-2037:
-
Summary: Pluggable component to queue tuples with ability to spool to
Github user ishark commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/250#discussion_r58623950
--- Diff: api/src/main/java/com/datatorrent/api/AffinityRule.java ---
@@ -0,0 +1,153 @@
+/**
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/APEXCORE-10?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227257#comment-15227257
]
ASF GitHub Bot commented on APEXCORE-10:
Github user ishark commented on a diff i
[
https://issues.apache.org/jira/browse/APEXCORE-10?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227226#comment-15227226
]
ASF GitHub Bot commented on APEXCORE-10:
Github user tweise commented on a diff i
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/250#discussion_r58622624
--- Diff: api/src/main/java/com/datatorrent/api/DAG.java ---
@@ -250,6 +250,24 @@
public abstract void setAttribute(Operator operator, Attr
[
https://issues.apache.org/jira/browse/APEXCORE-415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227217#comment-15227217
]
David Yan commented on APEXCORE-415:
[~timothyfarkas] we might want to cherry pick t
[
https://issues.apache.org/jira/browse/APEXCORE-415?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan resolved APEXCORE-415.
Resolution: Fixed
Fix Version/s: 3.4.0
> Input Operator Can Double Checkpoint if Operator C
[
https://issues.apache.org/jira/browse/APEXCORE-10?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227206#comment-15227206
]
ASF GitHub Bot commented on APEXCORE-10:
Github user tweise commented on a diff i
Github user tweise commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/250#discussion_r58620829
--- Diff: api/src/main/java/com/datatorrent/api/AffinityRule.java ---
@@ -0,0 +1,153 @@
+/**
+ * Licensed to the Apache Software Foundation
[
https://issues.apache.org/jira/browse/APEXCORE-415?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227180#comment-15227180
]
ASF GitHub Bot commented on APEXCORE-415:
-
Github user asfgit closed the pull re
Github user asfgit closed the pull request at:
https://github.com/apache/incubator-apex-core/pull/292
---
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 fe
Github user tweise commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/250#issuecomment-205987658
Looking at it.
---
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
[
https://issues.apache.org/jira/browse/APEXCORE-10?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227146#comment-15227146
]
ASF GitHub Bot commented on APEXCORE-10:
Github user tweise commented on the pull
[
https://issues.apache.org/jira/browse/APEXCORE-411?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan updated APEXCORE-411:
---
Fix Version/s: 3.4.0
> Restart app without specifying app package
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15227119#comment-15227119
]
Timothy Farkas commented on APEXMALHAR-2026:
After speaking with Chandni
Hi,
I have had questions on how to launch an application using an API. I have
setup a project with test code on how to do this with what is available in
Apex today. Take a look at it here.
https://github.com/PramodSSImmaneni/apex-cluster-launch
For having support directly in Apex to do this a JI
Hi Thomas,
I agree with you that module is a composite operator except its not present
at the execution time. Actually I feel that there should be another
Interface `Node` which specifies a node in the DAG, from which Operator and
Module interfaces are extended. This way we may support transformat
On Tue, Apr 5, 2016 at 12:14 PM, Siyuan Hua wrote:
> I have collected some open topics/questions for discussion already from
> folks who already reviewed the code
>
> 1.The name, name of the Stream and the StreamSource
>
> 2. Build dag in an incremental way vs lazy population. Incremental way is
[
https://issues.apache.org/jira/browse/APEXMALHAR-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226962#comment-15226962
]
Timothy Farkas commented on APEXMALHAR-2026:
An outline of how this would
Github user davidyan74 commented on a diff in the pull request:
https://github.com/apache/incubator-apex-core/pull/294#discussion_r58595340
--- Diff:
engine/src/main/java/com/datatorrent/stram/client/StramAppLauncher.java ---
@@ -210,14 +239,67 @@ public StramAppLauncher(FileSystem
[
https://issues.apache.org/jira/browse/APEXCORE-411?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226920#comment-15226920
]
ASF GitHub Bot commented on APEXCORE-411:
-
Github user davidyan74 commented on a
[
https://issues.apache.org/jira/browse/APEXCORE-10?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226885#comment-15226885
]
ASF GitHub Bot commented on APEXCORE-10:
Github user ishark commented on the pull
Github user ishark commented on the pull request:
https://github.com/apache/incubator-apex-core/pull/250#issuecomment-205941259
Have addressed most of the review comments except convenience APIs in DAG.
Did quick sanity testing on Cloudera after changes.
@tweise Could you please r
[
https://issues.apache.org/jira/browse/APEXMALHAR-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226798#comment-15226798
]
Thomas Weise commented on APEXMALHAR-2026:
--
That's right. Probably good to o
[
https://issues.apache.org/jira/browse/APEXMALHAR-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226730#comment-15226730
]
Timothy Farkas commented on APEXMALHAR-2026:
Also we don't have to worry
[
https://issues.apache.org/jira/browse/APEXMALHAR-2026?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226725#comment-15226725
]
Timothy Farkas commented on APEXMALHAR-2026:
The user could specify a ser
[
https://issues.apache.org/jira/browse/APEXMALHAR-2045?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15226158#comment-15226158
]
Priyanka Gugale commented on APEXMALHAR-2045:
-
high level design we are c
Priyanka Gugale created APEXMALHAR-2045:
---
Summary: Add bandwidth control feature to Apex
Key: APEXMALHAR-2045
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2045
Project: Apache Apex Malha
This would great value addition for other operators.
+1 for making this operator plugin.
~ Yogi
On 4 April 2016 at 12:40, Shubham Pathak wrote:
> +1 for having this as a platform feature.
>
> On Mon, Apr 4, 2016 at 12:27 PM, Bhupesh Chawda
> wrote:
>
> > +1 on making this an Apex feature. It w
80 matches
Mail list logo
