[streaming] uuid update

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/AckEventListener.java

@@ -21,8 +21,9 @@ public class AckEventListener implements EventListener {
 		String ackCID = recordId.split("-", 2)[0];
 		if (ackCID.equals(taskInstanceID)) {
 
-			System.out.println("Ack recieved " + ackEvent.getRecordId());
+			Long nt= System.nanoTime();
 			recordBuffer.ackRecord(ackEvent.getRecordId());
+			System.out.println("Ack recieved " + ackEvent.getRecordId()+"\nAck exec. time(ns): "+(System.nanoTime()-nt));
 			System.out.println("--------------");
 		}
 

flink-addons/flink-streaming/src/main/java/eu/stratosphere/streaming/api/StreamRecord.java

@@ -47,7 +47,7 @@ public class StreamRecord implements IOReadableWritable, Serializable {
 
 	public StreamRecord setId(String channelID) {
 		Random rnd = new Random();
-		uid.setValue(channelID + "-" + rnd.nextInt());
+		uid.setValue(channelID + "-" + rnd.nextInt(1000));
 		return this;
 	}