zhoulii commented on pull request #83: URL: https://github.com/apache/bahir-flink/pull/83#issuecomment-634461022
> Is there a specific way to reproduce the fails? Just asking as the regular build tests are not failing. the test case did not set the prarllelism of flink task, so the default parallelism depends on the running enviroment. I run those test case on my pc, and the tasks are running with four threads by default, so when one thread is interrupted, the othe threads are still running, that is why method amqTopologyWithQueue and amqTopologyWithTopic will never end. "the regular build tests are not failing": I think maybe the regular build tests run the flink job with single thread. to reproduce the fails, you can set the parallelism of StreamExecutionEnvironment to a value over 1. @lresende ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: [email protected]
