apex-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Pramod Immaneni <pra...@datatorrent.com>
Subject Re: [jira] [Commented] (APEXCORE-759) Operators connected using THREAD_LOCAL stream locality should enforce parallel partition scheme
Date Fri, 14 Jul 2017 02:04:30 GMT
Will double check and see whether it was already implemented and we need to
add the appropriate consistency checks or if 1xN configuration will have to
be supported anew.

Vlad to answer your question, yes it will be one thread for all.

On Thu, Jul 13, 2017 at 6:47 PM Thomas Weise (JIRA) <jira@apache.org> wrote:

>
>     [
> https://issues.apache.org/jira/browse/APEXCORE-759?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16086716#comment-16086716
> ]
>
> Thomas Weise commented on APEXCORE-759:
> ---------------------------------------
>
> There is no restriction for CONTAINER_LOCAL. THREAD_LOCAL requires a
> common root, hence 4 x 5 won't work, but 1 x N should, but please double
> check...
>
> > Operators connected using THREAD_LOCAL stream locality should enforce
> parallel partition scheme
> >
> -----------------------------------------------------------------------------------------------
> >
> >                 Key: APEXCORE-759
> >                 URL: https://issues.apache.org/jira/browse/APEXCORE-759
> >             Project: Apache Apex Core
> >          Issue Type: Bug
> >            Reporter: Vinay Bangalore Srikanth
> >         Attachments: apex (1).log, apex.log
> >
> >
> > In my application -
> http://node0.morado.com:9090/static/#/ops/apps/application_1499808956620_0190
> , I have set the locality to be THREAD_LOCAL.
> > Upstream operator - Random string generator (with 4 partitions)
> > Downstream operator - Custom console operator (with 5 partitions)
> > The containers are getting killed. Exceptions from container-launch are
> seen.
> > Logical message has to be displayed by handling exceptions.
> > Logs are attached for one of the containers - Id: 01_000126  that was
> killed.
>
>
>
> --
> This message was sent by Atlassian JIRA
> (v6.4.14#64029)
>

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message