flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Juan Rodríguez Hortalá <juan.rodriguez.hort...@gmail.com>
Subject Testing DataStreams
Date Wed, 02 Nov 2016 15:58:09 GMT

I'm new to Flink, and I'm trying to write my first unit test  for a simple
DataStreams job. In
I see several promising classes, but for example I cannot import
org.apache.flink.streaming.util.StreamingMultipleProgramsTestBase from the
artifacts obtained by the following Maven dependencies:


I also see that the page
is empty. Is there any documentation or tutorial about writing simple unit
tests running in local mode? I'm looking for something similar to
where you can specify the expected output as a collection to define an
assertion, but for Flink.

By the way I have also implemented source function similar to
StreamExecutionEnvironment.fromElements but that allows to add time gaps
between the generated elements, that I think could be useful for testing,
in case someone is interested



View raw message