get all the output from the task . this contains streamrecords and events interleaved . use org.apache.flink.streaming.util.testharnessutil #getstreamrecordsfromoutput java.util.list to extract only the streamrecords . concode_field_sep ConcurrentLinkedQueue<Object> outputList concode_elem_sep ExecutionConfig executionConfig concode_elem_sep TypeSerializer<OUT> outputSerializer concode_elem_sep Object checkpointLock concode_elem_sep TwoInputStreamOperator<IN1,IN2,OUT> operator concode_field_sep void processElement1 concode_elem_sep void emitWatermark concode_elem_sep void processElement2 concode_elem_sep void processWatermark1 concode_elem_sep void close concode_elem_sep void close concode_elem_sep void processWatermark2 concode_elem_sep void collect concode_elem_sep void open
ConcurrentLinkedQueue < Object > function ( ) { return outputList ; }