How to write junit testcases for KeyedBroadCastProcess Function

2020-07-15 Thread bujjirahul45
Hi, I am new to flink i am trying write junit test cases to test KeyedBroadCastProcessFunction. Below is my code ,i am currently calling the getDataStreamOutput method in TestUtils class and passing inputdata and patternrules to method once the input data is evaluated against list of pattern rules

Flink Jobs are failing for running testcases when trying to build in Jenkins server

2020-07-16 Thread bujjirahul45
Hi, I am trying to build flink job in Jenkins server and when its running the testcases its giving me below i am doing a simple pattern validation, where i am testing data against a set of patterns its build fine in local with gradle 6.3 but trying to build in Jenkins server its giving below is st