Hi Hitesh,
Can you collect all logs including app master logs and send it? Run command
"yarn logs -applicationId " on cluster to get logs for an
application.
Also please collect stderr output logs of appMaster. You can find them
under "/logs/userlogs///"
-Priyanka
On Fri, Sep 23, 2016 at 10:55 A
Hi team,
Trying to access live data from couchbase using input Operators.
It is running fine on my local. The tuples are emitting as Pojo through the
output port of inputOperator.
But when I upload the .apa file on data torrent, it gets launched but soon it
goes into Failed State just after been
[
https://issues.apache.org/jira/browse/APEXMALHAR-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515375#comment-15515375
]
ASF GitHub Bot commented on APEXMALHAR-2265:
Github user asfgit closed th
Github user asfgit closed the pull request at:
https://github.com/apache/apex-malhar/pull/426
---
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
[
https://issues.apache.org/jira/browse/APEXMALHAR-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved APEXMALHAR-2265.
--
Resolution: Fixed
Fix Version/s: 3.6.0
> Add entries to mkdocs.yml for recen
[
https://issues.apache.org/jira/browse/APEXCORE-538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise resolved APEXCORE-538.
---
Resolution: Fixed
> Log raw data when RPC message fails to de-serialize
> -
[
https://issues.apache.org/jira/browse/APEXCORE-538?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated APEXCORE-538:
--
Fix Version/s: (was: 3.4.1)
(was: 3.3.1)
> Log raw data when RPC me
GitHub user amberarrow opened a pull request:
https://github.com/apache/apex-malhar/pull/426
APEXMALHAR-2265 Added entries in mkdocs.yml for 2 newly added docs
@sashadt Please take a look
You can merge this pull request into a Git repository by running:
$ git pull https://githu
[
https://issues.apache.org/jira/browse/APEXMALHAR-2265?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515218#comment-15515218
]
ASF GitHub Bot commented on APEXMALHAR-2265:
GitHub user amberarrow opene
Github user asfgit closed the pull request at:
https://github.com/apache/apex-core/pull/396
---
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 e
[
https://issues.apache.org/jira/browse/APEXCORE-538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515202#comment-15515202
]
ASF GitHub Bot commented on APEXCORE-538:
-
Github user asfgit closed the pull re
Munagala V. Ramanath created APEXMALHAR-2265:
Summary: Add entries to mkdocs.yml for recently added operator docs
Key: APEXMALHAR-2265
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2265
[
https://issues.apache.org/jira/browse/APEXMALHAR-2264?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Munagala V. Ramanath resolved APEXMALHAR-2264.
--
Resolution: Fixed
Fix Version/s: 3.6.0
Merged
> Add documen
[
https://issues.apache.org/jira/browse/APEXMALHAR-2264?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15515182#comment-15515182
]
ASF GitHub Bot commented on APEXMALHAR-2264:
Github user asfgit closed th
Github user asfgit closed the pull request at:
https://github.com/apache/apex-malhar/pull/425
---
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
Sanjay M Pujare created APEXMALHAR-2264:
---
Summary: Add documentation for jmsInputOperator
Key: APEXMALHAR-2264
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2264
Project: Apache Apex Malh
[
https://issues.apache.org/jira/browse/APEXMALHAR-1818?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514919#comment-15514919
]
Julian Hyde commented on APEXMALHAR-1818:
-
[~chinmay], I watched the demo vid
[
https://issues.apache.org/jira/browse/APEXCORE-528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514909#comment-15514909
]
Alex McCullough commented on APEXCORE-528:
--
Yep, that works. My thought was tha
GitHub user sanjaypujare opened a pull request:
https://github.com/apache/apex-malhar/pull/425
add jms input operator doc to malhar docs
@amberarrow closing PR https://github.com/DataTorrent/docs/pull/81 and
opening this one. Contents are the same.
You can merge this pull request
[
https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514690#comment-15514690
]
ASF GitHub Bot commented on APEXMALHAR-2130:
GitHub user davidyan74 opene
[
https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514686#comment-15514686
]
ASF GitHub Bot commented on APEXMALHAR-2130:
Github user davidyan74 close
GitHub user davidyan74 opened a pull request:
https://github.com/apache/apex-malhar/pull/424
APEXMALHAR-2130 Spillable implementation for WindowedOperator
@tweise @brightchen @siyuanh Please review and merge
You can merge this pull request into a Git repository by running:
$ gi
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-malhar/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 featur
[
https://issues.apache.org/jira/browse/APEXMALHAR-2241?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514640#comment-15514640
]
ASF GitHub Bot commented on APEXMALHAR-2241:
GitHub user venkateshkottapa
GitHub user venkateshkottapalli opened a pull request:
https://github.com/apache/apex-malhar/pull/423
APEXMALHAR-2241 - The metadata kafka consumer should also pickup the
properties setting on the kafka input operator
Fixes two issues -
* metadata kafka consumer not picking up
[
https://issues.apache.org/jira/browse/APEXMALHAR-2231?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan closed APEXMALHAR-2231.
-
Assignee: (was: David Yan)
> Implement a Spillable map that takes two keys
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2193?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan closed APEXMALHAR-2193.
-
> Implement SpillableByteArrayListMultimapImpl.remove(@Nullable Object key,
> @Nullable Object v
[
https://issues.apache.org/jira/browse/APEXMALHAR-2249?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan updated APEXMALHAR-2249:
--
Assignee: (was: David Yan)
> Create SpillableSet and SpillableSetMultimap interfaces an
[
https://issues.apache.org/jira/browse/APEXMALHAR-2188?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan closed APEXMALHAR-2188.
-
> Implement SpillableByteArrayListMultimapImpl.containsEntry
> --
[
https://issues.apache.org/jira/browse/APEXMALHAR-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan updated APEXMALHAR-2191:
--
Assignee: (was: David Yan)
> Implement a way to get all keys with or without prefix fro
[
https://issues.apache.org/jira/browse/APEXMALHAR-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan closed APEXMALHAR-2192.
-
> Implement SpillableByteArrayListMultimapImpl.removeAll(Object key)
> --
[
https://issues.apache.org/jira/browse/APEXMALHAR-2189?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan closed APEXMALHAR-2189.
-
> Implement SpillableArrayListImpl.iterator
> -
>
>
[
https://issues.apache.org/jira/browse/APEXMALHAR-2191?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Yan closed APEXMALHAR-2191.
-
> Implement a way to get all keys with or without prefix from
> SpillableByteMapImpl
> -
[
https://issues.apache.org/jira/browse/APEXMALHAR-2192?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514345#comment-15514345
]
ASF GitHub Bot commented on APEXMALHAR-2192:
Github user davidyan74 close
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-malhar/pull/377
---
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 featur
Github user davidyan74 closed the pull request at:
https://github.com/apache/apex-malhar/pull/399
---
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 featur
Check Application master logs and stderr output.
Thank you,
Vlad
On 9/22/16 04:09, Hitesh Goyal wrote:
Hi team,
Trying to access live data from couchbase using input Operators.
It is running fine on my local. The tuples are emitting as Pojo
through the output port of inputOperator.
But w
Munagala V. Ramanath created APEXMALHAR-2263:
Summary: Offsets in AbstractFileInputOperator should be long
rather than int
Key: APEXMALHAR-2263
URL: https://issues.apache.org/jira/browse/APEXMALHAR-226
[
https://issues.apache.org/jira/browse/APEXMALHAR-2262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
bright chen updated APEXMALHAR-2262:
Summary: lock on AbstractManagedStateImpl.getValueFromBucketSync is too
wide (was: loc
[
https://issues.apache.org/jira/browse/APEXCORE-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514117#comment-15514117
]
Tushar Gosavi commented on APEXCORE-532:
If newly added operator is attached t
bright chen created APEXMALHAR-2262:
---
Summary: lock on is too
AbstractManagedStateImpl.getValueFromBucketSync wide
Key: APEXMALHAR-2262
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2262
Pro
[
https://issues.apache.org/jira/browse/APEXCORE-532?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514071#comment-15514071
]
Pramod Immaneni commented on APEXCORE-532:
--
[~tushargosavi] checking why this i
[
https://issues.apache.org/jira/browse/APEXCORE-539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15514021#comment-15514021
]
Vlad Rozov commented on APEXCORE-539:
-
I see the following exception after I changed
[
https://issues.apache.org/jira/browse/APEXCORE-539?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513980#comment-15513980
]
Thomas Weise commented on APEXCORE-539:
---
It wasn't the original intention to modif
Vlad Rozov created APEXCORE-539:
---
Summary: DefaultAttributeMap is not thread safe
Key: APEXCORE-539
URL: https://issues.apache.org/jira/browse/APEXCORE-539
Project: Apache Apex Core
Issue Type:
[
https://issues.apache.org/jira/browse/APEXMALHAR-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513930#comment-15513930
]
ASF GitHub Bot commented on APEXMALHAR-2190:
GitHub user brightchen reope
[
https://issues.apache.org/jira/browse/APEXMALHAR-2190?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513929#comment-15513929
]
ASF GitHub Bot commented on APEXMALHAR-2190:
Github user brightchen close
Github user brightchen closed the pull request at:
https://github.com/apache/apex-malhar/pull/404
---
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 featur
GitHub user brightchen reopened 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 https://gi
[
https://issues.apache.org/jira/browse/APEXMALHAR-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Siyuan Hua resolved APEXMALHAR-2248.
Resolution: Fixed
> Create SpillableSet and SpillableSetMultimap interfaces and impleme
[
https://issues.apache.org/jira/browse/APEXMALHAR-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Siyuan Hua updated APEXMALHAR-2248:
---
Fix Version/s: 3.6.0
> Create SpillableSet and SpillableSetMultimap interfaces and implem
Github user asfgit closed the pull request at:
https://github.com/apache/apex-malhar/pull/408
---
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
[
https://issues.apache.org/jira/browse/APEXMALHAR-2248?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513787#comment-15513787
]
ASF GitHub Bot commented on APEXMALHAR-2248:
Github user asfgit closed th
[
https://issues.apache.org/jira/browse/APEXCORE-538?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513785#comment-15513785
]
ASF GitHub Bot commented on APEXCORE-538:
-
GitHub user vrozov opened a pull requ
GitHub user vrozov opened a pull request:
https://github.com/apache/apex-core/pull/396
APEXCORE-538 - Log raw data when RPC message fails to de-serialize
@tweise Please review and cherry-pick.
You can merge this pull request into a Git repository by running:
$ git pull https:/
[
https://issues.apache.org/jira/browse/APEXMALHAR-2244?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513770#comment-15513770
]
Siyuan Hua commented on APEXMALHAR-2244:
Each spillable DS implementation use
Thomas Weise created APEXMALHAR-2260:
Summary: Python execution for operator logic
Key: APEXMALHAR-2260
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2260
Project: Apache Apex Malhar
[
https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated APEXMALHAR-2130:
-
Summary: Scalable windowed storage (was: implement scalable windowed
storage)
> Sca
[
https://issues.apache.org/jira/browse/APEXMALHAR-2130?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated APEXMALHAR-2130:
-
Labels: roadmap (was: )
> implement scalable windowed storage
>
Thomas Weise created APEXMALHAR-2261:
Summary: Python binding for high level API
Key: APEXMALHAR-2261
URL: https://issues.apache.org/jira/browse/APEXMALHAR-2261
Project: Apache Apex Malhar
[
https://issues.apache.org/jira/browse/APEXCORE-528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513735#comment-15513735
]
Thomas Weise commented on APEXCORE-528:
---
Isn't it just a matter of removing the al
I created the following JIRAs:
https://issues.apache.org/jira/browse/APEXMALHAR-2260
https://issues.apache.org/jira/browse/APEXMALHAR-2261
On Wed, Sep 21, 2016 at 11:10 PM, Chinmay Kolhatkar wrote:
> I would like to help in contributing to this feature.
>
> On Wed, Sep 21, 2016 at 12:26 AM, Sa
[
https://issues.apache.org/jira/browse/APEXMALHAR-2261?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Thomas Weise updated APEXMALHAR-2261:
-
Labels: roadmap (was: )
> Python binding for high level API
> --
Vlad Rozov created APEXCORE-538:
---
Summary: Log raw data when RPC message fails to de-serialize
Key: APEXCORE-538
URL: https://issues.apache.org/jira/browse/APEXCORE-538
Project: Apache Apex Core
[
https://issues.apache.org/jira/browse/APEXCORE-528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513525#comment-15513525
]
Alex McCullough commented on APEXCORE-528:
--
https://github.com/apache/apex-core
[
https://issues.apache.org/jira/browse/APEXCORE-528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513515#comment-15513515
]
Thomas Weise commented on APEXCORE-528:
---
Can you point me to the exact place in th
[
https://issues.apache.org/jira/browse/APEXCORE-528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513507#comment-15513507
]
Alex McCullough commented on APEXCORE-528:
--
Because when no annotations are add
[
https://issues.apache.org/jira/browse/APEXCORE-528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513460#comment-15513460
]
Thomas Weise commented on APEXCORE-528:
---
IMO output ports that don't have an annot
[
https://issues.apache.org/jira/browse/APEXCORE-528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15513421#comment-15513421
]
Alex McCullough commented on APEXCORE-528:
--
Hey Deepak,
I am working on this.
Hi team,
Trying to access live data from couchbase using input Operators.
It is running fine on my local. The tuples are emitting as Pojo through the
output port of inputOperator.
But when I upload the .apa file on data torrent, it gets launched but soon it
goes into Failed State just after been
Definitely worth adding.
Ram
On Wed, Sep 21, 2016 at 1:20 PM, Pramod Immaneni
wrote:
> Candidate to be added here?
>
> https://apex.apache.org/docs/apex/development_best_practices/
>
> On Wed, Sep 21, 2016 at 12:24 PM, Munagala Ramanath
> wrote:
>
> > Some info here:
> > http://docs.datatorren
[
https://issues.apache.org/jira/browse/APEXCORE-528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15512979#comment-15512979
]
Deepak Narkhede commented on APEXCORE-528:
--
Hi Alex,
Are you currently working
[
https://issues.apache.org/jira/browse/APEXCORE-310?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Deepak Narkhede reassigned APEXCORE-310:
Assignee: Deepak Narkhede
> apex cli - support to kill the app by appname
> -
Thanks tushar. I got it working in similar ways:
1. For DAG as JSON String:
Map stringObjectMap =
LogicalPlanSerializer.convertToMap(dag, true);
ObjectMapper mapper = new ObjectMapper();
mapper.enable(SerializationFeature.INDENT_OUTPUT);
String s = mapper.writeValueAsString(stringObjectMap);
Syst
74 matches
Mail list logo
