Hi, I have been experiencing a strange problem. I have been using table api and toChangelogStream() for the results. At first, even though it was running in the development environment, when I deployed my job onto the production, toChangelogStream() was not generating any results. Strangely, then it started working on the production environment as well. I noticed that the only thing that changed was the Parallelism of the environment. env.setParallelism(). Then I did some tests. It seems table api is sometimes working and sometimes does not work according to the parallelism count.
Any idea why or how? Thanks
