diff --git a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/ArrayStreamRecordTest.java b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/ArrayStreamRecordTest.java
index 6edd5682d226033a65433b9fdabbb3c23c16e63c..e81fce48e680b1db1e5454019247f1cf05349fab 100755
--- a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/ArrayStreamRecordTest.java
+++ b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamrecord/ArrayStreamRecordTest.java
@@ -110,4 +110,15 @@ public class ArrayStreamRecordTest {
 		assertEquals(0, truncatedRecord.getTuple(0).getField(0));
 		assertEquals(1, truncatedRecord.getTuple(1).getField(0));
 	}
+	
+	@Test
+	public void copyTupleTest() {
+		Tuple1<String> t1 = new Tuple1<String>("T1");
+		Tuple1<String> t2 = (Tuple1<String>) StreamRecord.copyTuple(t1);
+		assertEquals("T1", t2.f0);
+		
+		t2.f0 = "T2";
+		assertEquals("T1", t1.f0);
+		assertEquals("T2", t2.f0);
+	}
 }
diff --git a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/faulttolerance/AtLeastOnceBufferTest.java b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/faulttolerance/AtLeastOnceBufferTest.java
index d6b27dcacb2e22a26b38063b8abb59eb99ec3c64..6162977c781e0c23a0639b0a309c4549ebff9c52 100755
--- a/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/faulttolerance/AtLeastOnceBufferTest.java
+++ b/flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/faulttolerance/AtLeastOnceBufferTest.java
@@ -110,7 +110,8 @@ public class AtLeastOnceBufferTest {
 	public void testAdd() {
 
 		StreamRecord record1 = new ArrayStreamRecord(1).setId(1);
-
+		record1.setTuple(0, new Tuple1<String>("R1"));
+		
 		UID id1 = record1.getId().copy();
 
 		Long nt = System.nanoTime();
@@ -132,7 +133,8 @@ public class AtLeastOnceBufferTest {
 		buffer.add(record1);
 		System.out.println(id1);
 		System.out.println(buffer.ackCounter);
-		
+		System.out.println(buffer.recordBuffer);
+
 		assertEquals((Integer) 3, buffer.ackCounter.get(id1));
 		assertEquals((Integer) 3, buffer.ackCounter.get(id2));