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. https://github.com/ottogroup/flink-spector The following folder doesn't seam to demonstrate such capability for testing. https://github.com/apache/flink/tree/master/flink-examples/flink-examples-streaming/src/test/java/org/apache/flink/streaming/test On Tue, Aug 28, 2018 at 2:55 PM ZhengWen ZHU <ahua...@gmail.com> wrote: > 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 from your > IDE by standalone mode. > > best, > Zhengwen > > On Tue, Aug 28, 2018 at 7:35 PM Nicos Maris <nicos.ma...@gmail.com> wrote: > >> Hi all, >> >> >> How can I test in Java any streaming job that has a time window? >> >> >> best, >> Nicos >> > > > -- > > > > > *_________________________________________Zhu ZhengwenState Key Laboratory > For Novel Software TechnologyDept. of Computer Sci. & Tech., Nanjing > University* > *9, Hankou Road, Nanjing, China.* >
