I tried this before without success.
Same exception the named class was not found.
-Michael
Am 06.08.2015 um 14:07 schrieb Matthias J. Sax :
> Never mind. Just saw that this in not the problem...
>
> Sounds weird to me. Maybe you can try to name the class. Anonymous
> classes should not be a p
Hi Michael!
Can you try the following:
1) Check whether the class is actually in the jar file (unzip / grep)
2) Can you check in the logs what is the path of the BLOB server temp
directory (JobManager and TaskManager). Are there any strange characters /
spaces in the path?
3) Can you check in t
Hey Stephan
the error disappeared after restarting the computer.
now I got another one but this is also strange because the program ran once
successful and is now failing again without me knowingly changing something.
- Michael
An error occurred while invoking the program:
The program caused
I can now reproduce this error and the successful run.
When load the jar in the web interface and start the plan the
org.apache.flink.client.program.Client$ProgramAbortException
happens when I reload the page with the error the plan is shown correct and the
execution succeeds.
- Michael
Am 1
Actually, the ProgramAbortException is something that the web interface
does in order to run the program to a part where the plan is created (for
visualization), but the program is not executed.
Apparently this logic is a bit broken in the latest version, or you are
catching and re-throwing the ex
I’m not catching the exception and running from shell always works after the
ClassNotFoundExeption disappeared.
Am 11.08.2015 um 16:18 schrieb Stephan Ewen
mailto:se...@apache.org>>:
Actually, the ProgramAbortException is something that the web interface does in
order to run the program to a
Hello,
I have a question about forward partitioning in Flink.
If Operator A and Operator B have the same parallelism set and forward
partitioning is used for events coming from instances of A and going to
instances of B:
Will each instance of A send events to _exactly one_ instance of B?
That i
