[
https://issues.apache.org/jira/browse/APEXCORE-405?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15271356#comment-15271356
]
Pramod Immaneni commented on APEXCORE-405:
------------------------------------------
I noticed that the individual containers are sending a JSON serialized string
of the stack trace information to STRAM. The serialization is typically handled
by RPC and the containers just send objects. Could you convert the Map<Thread,
StackTraceElement[]> into an object that can be serialized, maybe into a
Map<ThreadInfo, StackTraceElement[]>.
Secondly the web service call results in a request flag to be set in the
container agent which gets reset immediately after initiating a request to the
container to send the stack trace. I believe this flag should be reset after
receiving the stack trace from the container as there is a chance the request
may not make it to the container if there are any intermittent network errors
and the web service call is anyway waiting for a timeout period of 10s for the
stack trace which is several heartbeats.
I apologize I was not able to give these comments during the pull request
review.
> Provide an API to launch DAG on the cluster
> -------------------------------------------
>
> Key: APEXCORE-405
> URL: https://issues.apache.org/jira/browse/APEXCORE-405
> Project: Apache Apex Core
> Issue Type: Improvement
> Reporter: Pramod Immaneni
> Assignee: Pramod Immaneni
>
> Today API exists to launch a DAG in local mode but such an API is not
> available to launch the app on the cluster, only a CLI tool is available.
> Provide an API to be able to do this.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
