to see if the JM failed after the initial akka message, or if
there's any kind of hiccup ?
On Thu, May 11, 2017 at 5:07 PM, Rami Al-Isawi
<rami.al-is...@comptel.com<mailto:rami.al-is...@comptel.com>> wrote:
Hi,
The same exact jar on the same machine is being deployed just fine in cou
Hi,
The same exact jar on the same machine is being deployed just fine in couple of
seconds using the web interface. On the other hand, if I used the command line,
I get:
org.apache.flink.client.program.ProgramInvocationException: The program
execution failed: Couldn't retrieve the
tions?
On 03.05.2017 12:59, Rami Al-Isawi wrote:
Hi,
I am trying to set uids. I keep getting this (Flink.1.2):
Exception in thread "main" java.lang.IllegalArgumentException: Hash collision
on user-specified ID. Most likely cause is a non-unique ID. Please check that
all IDs sp
Hi,
I am trying to set uids. I keep getting this (Flink.1.2):
Exception in thread "main" java.lang.IllegalArgumentException: Hash collision
on user-specified ID. Most likely cause is a non-unique ID. Please check that
all IDs specified via `uid(String)` are unique.
Here is the code snippet.
Hi Stephan,
I have not change the parallelism nor the names or anything in my program. It
is the same exact jar file unmodified.
I have tried uid. but I faced this "UnsupportedOperationException: Cannot
assign user-specified hash to intermediate node in chain. This will be
supported in future
