Re: Flink with parallelism 3 is running locally but not on cluster

Hey, Dominik, tnx for getting back. i've posted also by stackoverflow and David Anderson gave a good tipp where to look. https://stackoverflow.com/questions/53282967/run-flink-with-parallelism-more-than-1/53289840 issues is resolved, everything is running. thx. again -- Sent from: http://apache

Flink with parallelism 3 is running locally but not on cluster

Hi, may be i just missing smth, but i just have no more ideas where to look. here is an screen of the failed state i read messages from 2 sources, make a join based on a common k

Re: flink-1.6.2 in standalone-job mode | Cluster initialization failed.

jepp, that was the Issue. tnx a lot. -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

flink-1.6.2 in standalone-job mode | Cluster initialization failed.

://gist.github.com/zavalit/4dba49cdea45c6f56f947a7dcec1a666 job manager is started with: ./bin/standalone-job.sh start-foreground --configDir conf --job-classname MyEntryClass the same app runs as it is in flink-1.6.1, the only thing that have changed is a flink version thx in advance, for any insides

Intergrations Test in Scala

hi, Flinkers i've already posted by stackoverflow, but there are still no that match feedback about the problem https://stackoverflow.com/questions/49155762/failing-to-trigger-streamingmultipleprogramstestbase-test-in-scala/49258997#49258997 Problem: i cannot start any test extending *StreamingMul