Test harness for CoProcessFunction outputting Protobuf messages

Posted by Alexey Trenikhun on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/Test-harness-for-CoProcessFunction-outputting-Protobuf-messages-tp25889.html

Hello,

I have CoProcessFunction which outputs protobuf messages, and custom TypeInformation implementation to serialize protobuf messages, when I define graph I can set output type using SingleOutputStreamOperator.returns(TypeInformation<T>), for side outputs I can also specify TypeInformation<T> in constructor of OutputTag. However in test when I'm trying to use KeyedTwoInputStreamOperatorTestHarness I can't find way to set output type via explicit TypeInformation, furthermore if I'm trying to use side output, public <X> void AbstractStreamOperatorTestHarness::collect(OutputTag<X> outputTag, StreamRecord<X> record) seems ignore type information in outputTag and instead tries to extract type information from value using TypeExtractor.getForObject(record.getValue()). Is it expected behavior? Is another  way specify type information for test harness?

Thanks,

Alexey