Hi Clay, If you do env.setParallelism(1), the query won't be executed in parallel. However, looking at your screenshot the message order does not seem to be the problem here (given that you printed the content of the topic).
Are you sure that it is not possible that the result decreases if some rows are added to one of the input tables? I don't have time to dig into your query, but the HAVING clause or the left join and (u.id is null) predicate look a bit suspicious to me. Would it be possible to create a minimal example that reproduces the issue? Best, Fabian Am Mo., 1. Okt. 2018 um 15:11 Uhr schrieb clay4444 <clay4me...@gmail.com>: > hi,Timo > > I use env.setParallelism(1) in my code, I set the overall degree of > parallelism of the program to 1, so that some calculations will still be > parallelized? > > clay, > > > > > -- > Sent from: > http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/ >
