OperatorInfo info = operator.getInfo();
if (base != null && info != null && base.getClass() == info.getClass()) {
base = mergeInfo(base, info);
}
}
<BUG>return new OperatorStats(
operatorId,</BUG>
planNodeId,
operatorType,
totalDrivers,

OperatorInfo info = operator.getInfo();
if (base != null && info != null && base.getClass() == info.getClass()) {
base = mergeInfo(base, info);
}
}
return new OperatorStats(
pipelineId,
operatorId,
planNodeId,
operatorType,
totalDrivers,
