Hi Till,
Thanks for your answer!
I will try the approach you suggested, hope I can make it work.
Best regards
martin
Den ons. 2. dec. 2020 kl. 17.03 skrev Till Rohrmann :
> Hi Martin,
>
> In general, Flink's MiniCluster should be able to run every complete Flink
> JobGraph. However, from what I
Hi Martin,
In general, Flink's MiniCluster should be able to run every complete Flink
JobGraph. However, from what I read you are looking for a test harness for
a processWindowFunction so that you can test this function in a more unit
test style, right? What you can do is to use the
OneInputStream
Hi,
I am trying to make a test-suite for our flink cluster using harness and
minicluster. As we are using processWindowFunctions in our pipeline we need
some good ways of validating these functions. To my surprise
processWindowFunctions are neither supported by test-harness or minicluster
setups,
