Re: test windows

Hi Nicos, I think this is what you want. WindowFoldITCase . :-) Flink is a open source project, you can checkout the source code from git and search the tests in

Re: test windows

Hi all, It took me some time to reply. I am focusing on testing my job, not on unit tests and the SourceFunction as in WindowFunctionITCase.scala

Re: test windows

The flink training exercises have a simpler example of using a TwoInputStreamOperatorTestHarness from outside of the Flink code base that you can refer to. The two input test harness is more or less the same as the one input test harness.

Re: test windows

Hi Nicos, Do you want an IT test to test the job, or just a UT to test the window operator? If you want to test the job, there are examples here: 1. WordCountITCase.java

Re: test windows

Can the OneInputStreamOperatorTestHarness be used to test pipelines with time windows? Can someone explain this test harness preferably

Re: test windows

Hi Zhengwen, I have tested my job manually (both by submitting a job and through execute()) and I am trying to write a test. The following project states that it has the feature "Test stream windowing with timestamped input" but I do not want to rely on a project other than flink.

Re: test windows

Hi Nicos, Under the flink-example module, there are many examples, including batch and streaming. You could build the project from the source, this way you could found many jars under the target directory. You can submit these jars to the Flink cluster. Also, you could run these examples directly

test windows

Hi all, How can I test in Java any streaming job that has a time window? best, Nicos