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
mailto:rami.al-is...@comptel.com>> wrote:
Hi,
The same exact jar on the same machine is being deployed just fine in couple of
seconds using the web interface
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 JobExecutio
(value.type);
return output;
}
}
Any ideas how to get better debug messages?
Regards,
-Rami
On 3 May 2017, at 14:12, Chesnay Schepler
mailto:ches...@apache.org>> wrote:
Hello,
was a uid set on "userRawDataStream", or any of it's parent transformations?
On 03.05.201
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.
p
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
