[streaming] StreamRecordTest fixed

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

@@ -318,9 +318,11 @@ public class StreamRecord implements IOReadableWritable, Serializable {
 	}
 
 	private void writeTuple(Tuple tuple, DataOutput out) {
+		
 		Class[] basicTypes = new Class[tuple.getArity()];
 		StringBuilder basicTypeNames = new StringBuilder();
 
+		//TODO: exception for empty record - no getField!
 		for (int i = 0; i < basicTypes.length; i++) {
 			basicTypes[i] = tuple.getField(i).getClass();
 			basicTypeNames.append(basicTypes[i].getName() + ",");

flink-addons/flink-streaming/src/test/java/eu/stratosphere/streaming/api/streamcomponent/StreamComponentTest.java

@@ -47,7 +47,6 @@ import eu.stratosphere.types.IntValue;
 public class StreamComponentTest {
 
 	private static Map<Integer, Integer> data = new HashMap<Integer, Integer>();
-	private static FieldsPartitioner fP = new FieldsPartitioner(0, IntValue.class);
 	private static boolean fPTest = true;
 
 	public static class MySource extends UserSourceInvokable {
@@ -58,7 +57,7 @@ public class StreamComponentTest {
 		public void invoke() throws Exception {
 			StreamRecord record = new StreamRecord(new Tuple1<Integer>(-1));
 			for (int i = 0; i < 1000; i++) {
-				record.setField(0, new IntValue(i));
+				record.setField(0, i);
 				emit(record);
 			}
 		}