[streaming] Fixed AtLeastOnceBufferTest

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);
+	}
 }

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));