Re: About the retract of the calculation result of flink sql

Posted by Fabian Hueske-2 on
URL: http://deprecated-apache-flink-user-mailing-list-archive.369.s1.nabble.com/About-the-retract-of-the-calculation-result-of-flink-sql-tp23503p23546.html

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 <[hidden email]>:

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/