I just realized on second glance that I do have a naming conflict! Thanks!
Sent with Good (www.good.com)
From: Tushar Gosavi
Sent: Thursday, March 10, 2016 12:07:33 AM
To: dev@apex.incubator.apache.org
Subject: Re: Operator ID Overlap
Hi,
>From the st
Hi,
>From the stack trace it seems that you are adding two or more operator in
the DAG using same name (Records_HDHT). Adding multiple operators to
logical DAG using same name is not allowed. Can you check
if this is the case, else there might be the problem in the platform.
- Tushar.
On Thu, M
Additional note: I am extracting operatorId from the context in setup:
@Override
public void setup(Context.OperatorContext context) {
super.setup(context);
operatorId = context.getId();
operatorUniquePath = new Path(getOutputFileName() + idDelim +
operatorId + ".txt").toSt
Hi all – I’ve created some helper functions to efficiently create HDFS Output
operators (which require common configurations). However, I run into a
duplicate operator ID error when attempting to run this, error and code are
below:
Why would the DAG be assigning a duplicate operator ID? For the
