flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Flavio Pompermaier <pomperma...@okkam.it>
Subject Re: Report failed job submission
Date Mon, 12 Nov 2018 15:00:11 GMT
Let's say that my job needs to do some check before running (like existence
of a file or some other condition): at the moment I can only throw an
Exception but on the client side you get only something
like: {"errors":["org.apache.flink.client.program.ProgramInvocationException:
The main method caused an error."]}

I was wondering if there is any better way to handle this kind of problems..

On Mon, Nov 12, 2018 at 3:53 PM Timo Walther <twalthr@apache.org> wrote:

> Hi Flavio,
> I'm not entirely sure if I get your question correct but what you are
> looking for is more information (like categorization) why the submission
> failed right?
> Regards,
> Timo
> Am 06.11.18 um 14:33 schrieb Flavio Pompermaier:
> Any idea about how to address this issue?
> On Tue, Oct 16, 2018 at 11:32 AM Flavio Pompermaier <pompermaier@okkam.it>
> wrote:
>> Hi to all,
>> which is the correct wat to report back to the user a failure from a job
>> submission in FLink?
>> If everything is OK the job run API returns the job id but what if there
>> are error in parameter validation or some other problem?
>> Which is the right way to report back to the user the job error detail
>> (apart from throwing an Exception)?
>> Best,
>> Flavio

View raw message