Mailing-List: contact dev-help@apex.apache.org; run by ezmlm
Precedence: bulk
Reply-To: dev@apex.apache.org
MIME-Version: 1.0
In-Reply-To: <CANiZcWCr8eQ0i9XnRR4qPTTNN-atSmj_h8vE=XcMH6dSVTRg4A@mail.gmail.com>
References: <CANiZcWCr8eQ0i9XnRR4qPTTNN-atSmj_h8vE=XcMH6dSVTRg4A@mail.gmail.com>
From: Ambarish Pande <ambarish.pande2011@gmail.com>
Date: Wed, 1 Mar 2017 23:20:34 +0530
Message-ID: <CANiZcWA_8qkMwtNVHdczoZeXdb0FnU0T1fZdBT__C9Gh2zpZcg@mail.gmail.com>
Subject: Fwd: No Checkpointing when partitioning is used in the loop with
 Delay Operator.
To: dev@apex.apache.org
Content-Type: multipart/alternative; boundary=94eb2c04f74e18b8230549aef35f
archived-at: Wed, 01 Mar 2017 17:50:49 -0000

--94eb2c04f74e18b8230549aef35f
Content-Type: text/plain; charset=UTF-8

Hello All,

I have created an app in which I am using Delay Operator for adding a
feedback loop in the DAG. Also I am doing static partitioning of some
operator in the loop. When I run the app, the operators in the loop are not
being check-pointed.

To narrow down the cause of this, I experimented a bit with the app.

App without Partitioning of Operators and with Delay Operator -
Checkpointing OK
App with partitioning of Operators and Without Delay Operator -
Checkpointing OK
App with partitioning of Operators with Delay Operator - NO Checkpointing


I have reported an issue on APEX-CORE. Here is the link :
https://issues.apache.org/jira/browse/APEXCORE-654

Any help would be greatly appreciated. I really need loop in my application.

Thank You.

--94eb2c04f74e18b8230549aef35f--