Added attempt number to profiling counter
git-svn-id: https://hyracks.googlecode.com/svn/branches/hyracks_dev_next@745 123451ca-8445-de46-9d55-352943316053
diff --git a/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/profiling/ConnectorSenderProfilingFrameWriter.java b/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/profiling/ConnectorSenderProfilingFrameWriter.java
index 5d592be..be7b319 100644
--- a/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/profiling/ConnectorSenderProfilingFrameWriter.java
+++ b/hyracks-control-nc/src/main/java/edu/uci/ics/hyracks/control/nc/profiling/ConnectorSenderProfilingFrameWriter.java
@@ -31,12 +31,13 @@
public ConnectorSenderProfilingFrameWriter(IHyracksTaskContext ctx, IFrameWriter writer,
ConnectorDescriptorId cdId, int senderIndex, int receiverIndex) {
this.writer = writer;
+ int attempt = ctx.getTaskAttemptId().getAttempt();
this.openCounter = ctx.getCounterContext().getCounter(
- cdId + ".sender." + senderIndex + "." + receiverIndex + ".open", true);
+ cdId + ".sender." + attempt + "." + senderIndex + "." + receiverIndex + ".open", true);
this.closeCounter = ctx.getCounterContext().getCounter(
- cdId + ".sender." + senderIndex + "." + receiverIndex + ".close", true);
+ cdId + ".sender." + attempt + "." + senderIndex + "." + receiverIndex + ".close", true);
this.frameCounter = ctx.getCounterContext().getCounter(
- cdId + ".sender." + senderIndex + "." + receiverIndex + ".nextFrame", true);
+ cdId + ".sender." + attempt + "." + senderIndex + "." + receiverIndex + ".nextFrame", true);
}
@Override