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