Hello Experts, I have developed a couple of modules where one of the modules is getting data from Kafka, applying the process window function, and getting the required form of data. However, I went through the official documentation and there are no approaches for implementing the unit test cases for Pyflink API.
Therefore, I tried my way of Standard Python Unittest library Mockito. But, I am facing some JAR issues. This is what I am talking about https://stackoverflow.com/questions/77234674/pyflink-unit-tests-unable-to-find-the-jar-file-passed-within-the-tests Also, can somebody redirect me to any documentation/references using which I can check the approach and implement it myself? Any hints are also welcome. I am new but trying my best to learn PyFlink the better way since there is nothing mentioned in the documentation, I am finding it difficult to implement and had to go the Mockito way since I only know that as of now. Thanks.
