Okay, thanks! In my case, I tried to run an ITCase test and the environment parallelism is happened to be -1, and an exception was thrown. The other ITCases ran properly, so I figured, the problem is with the windowing. Can you check it out for me? (WindowedDataStream, line 348)
Peter 2015-02-27 10:06 GMT+01:00 Gyula Fóra <gyf...@apache.org>: > They should actually return different values in many cases. > > Datastream.env.getDegreeOfParallelism returns the environment parallelism > (default) > > Datastream.getparallelism() returns the parallelism of the operator. There > is a reason when one or the other is used. > > Please watch out when you try to modify that because you might actually > break functionality there :p > On Feb 27, 2015 8:55 AM, "Szabó Péter" <nemderogator...@gmail.com> wrote: > > > As I know, the time of creation of the execution environment has been > > slightly modified in the streaming API, which caused that > > dataStream.getParallelism() and dataStream.env.getDegreeOfParallelism() > may > > return different values. Usage of the former is recommended. > > In theory, the latter is eliminated from the code, but there might be > some > > more left, hiding. I've recently fixed one in WindowedDataStream. If you > > encounter problems with the parallelism, it may be the cause. > > > > Peter > > >
