Actually, I realized my mistake that JarRunHandler is being used in the
jar/run API call.
And the changes are done in RestClusterClient.
The problem I was facing was that It always gives me "The main method
caused an error"
without any more details.
I am thinking when we throw ProgramInvocationException in PackagedProgram.
callMainMethod()
we should add exceptionInMethod.getMessage() too.
*---
a/flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java*
*+++
b/flink-clients/src/main/java/org/apache/flink/client/program/PackagedProgram.java*
@@ -543,7 +543,7 @@ public class PackagedProgram {
} else if (exceptionInMethod instanceof
ProgramInvocationException) {
throw (ProgramInvocationException)
exceptionInMethod;
} else {
- throw new ProgramInvocationException("The
main method caused an error.", exceptionInMethod);
+ throw new ProgramInvocationException("The
main method caused an error.: " + exceptionInMethod.getMessage(),
exceptionInMethod);
}
}
catch (Throwable t) {
What will you suggest?
On Wed, Jan 23, 2019 at 7:01 PM Chesnay Schepler <ches...@apache.org> wrote:
> Which version are you using?
>
> On 23.01.2019 08:00, Lavkesh Lahngir wrote:
> > Or maybe I am missing something? It looks like the JIRA is trying to
> solve
> > the same issues I stated 🤔
> > In the main method, I just threw a simple new Exception("Some message")
> and
> > I got the response I mentioned from the rest API.
> >
> > Thanks.
> >
> > On Wed, Jan 23, 2019 at 2:50 PM Lavkesh Lahngir <lavk...@linux.com>
> wrote:
> >
> >> Hello,
> >> The change in FLINK-10312
> >> <https://issues.apache.org/jira/browse/FLINK-10312> makes REST response
> >> of the API
> >> <
> https://ci.apache.org/projects/flink/flink-docs-stable/monitoring/rest_api.html#jars-jarid-run>
> not
> >> very informative. It strips the stack trace and returns a generic
> message.
> >> People using flink-cluster deployment who do not have access to job
> manager
> >> logs, will not be able to figure out the root cause.
> >> In the case of when the job submission fails,
> >> In 1.6.2, I get
> >> {
> >> "errors": [
> >> "org.apache.flink.client.program.ProgramInvocationException:
> The
> >> main method caused an error."
> >> ]
> >> }
> >>
> >> Is there a plan to improve error messages sent to the client?
> >> Is somebody working on this already?
> >>
> >> Thanks in advance.
> >> ~Lavkesh
> >>
>
>
