cannot catch flink runtime exception

classic Classic list List threaded Threaded
5 messages Options
Reply | Threaded
Open this post in threaded view
|

cannot catch flink runtime exception

孙森
Hi all:
        I am using flink sql ,when I encountered an error ,I cannot  catch the runtime exception on the CLUSTER. But , when I used the same code and sql on my local test ,I can find the exception. I hava no idea where to debug and what should I do . I need you help. Thank you very much.

sensun


The local exception:

Reply | Threaded
Open this post in threaded view
|

Re: cannot catch flink runtime exception

Chesnay Schepler
Please include
* the entire exception as text, half of the exception message is cut off
* your SQL program

By the looks of it you're trying to access a column "name1" but it appears to not exist.

On 05.09.2018 05:56, 孙森 wrote:
Hi all:
        I am using flink sql ,when I encountered an error ,I cannot  catch the runtime exception on the CLUSTER. But , when I used the same code and sql on my local test ,I can find the exception. I hava no idea where to debug and what should I do . I need you help. Thank you very much.

sensun


The local exception:


Reply | Threaded
Open this post in threaded view
|

Re: cannot catch flink runtime exception

Rong Rong
In reply to this post by 孙森
Based on what you provided. Seems like your SQL did not pass validation phase, which means it cannot be compiled into an execution job graph, hence I do not think it is possible to even deploy anything meaningful.
Can you describe how you submit the job using Flink SQL? where are you submitting it to?

Like Chesnay mentioned, please also include your SQL program, aka your Starter file.

--
Rong



On Wed, Sep 5, 2018 at 1:57 AM 孙森 <[hidden email]> wrote:
Hi all:
        I am using flink sql ,when I encountered an error ,I cannot  catch the runtime exception on the CLUSTER. But , when I used the same code and sql on my local test ,I can find the exception. I hava no idea where to debug and what should I do . I need you help. Thank you very much.

sensun


The local exception:


=?UTF-8?B?5bGP5bmV5b+r54WnIDIwMTgtMDktMDUg5LiK5Y2IMTEuNTUuMjAucG5n?= (719K) Download Attachment
=?UTF-8?B?5bGP5bmV5b+r54WnIDIwMTgtMDktMDUg5LiK5Y2IMTEuNTUuMjAucG5n?= (719K) Download Attachment
Reply | Threaded
Open this post in threaded view
|

Re: cannot catch flink runtime exception

孙森
In reply to this post by Chesnay Schepler
I don't understand what you mean. I have two transformation on the flink dataStream.One is the map operator, and the other is the flink sql .The same code “run  on my Idea I got the exception I wanted .But I got nothing when it “run” on the cluster mode. I cannot find the exception on the TaskManager.

My code :


在 2018年9月5日,下午7:22,Chesnay Schepler <[hidden email]> 写道:

Because when your code is "run" on the cluster nothing is actually executed; instead a JobGraph is generated that is later executed by the JobManager.

On 05.09.2018 12:59, 孙森 wrote:
Yes, that is sql I used to test if I can catch the exception on the cluster mode . The exception appeared on my Idea ,but did not appear on the cluster. My question is why I cannot catch the exception on the cluster mode.

在 2018年9月5日,下午3:43,Chesnay Schepler <[hidden email]> 写道:

Please include
* the entire exception as text, half of the exception message is cut off
* your SQL program

By the looks of it you're trying to access a column "name1" but it appears to not exist.

On 05.09.2018 05:56, 孙森 wrote:
Hi all:
        I am using flink sql ,when I encountered an error ,I cannot  catch the runtime exception on the CLUSTER. But , when I used the same code and sql on my local test ,I can find the exception. I hava no idea where to debug and what should I do . I need you help. Thank you very much.

sensun


The local exception:

<屏幕快照 2018-09-05 上午11.55.20.png>





Reply | Threaded
Open this post in threaded view
|

Re: cannot catch flink runtime exception

孙森
In reply to this post by Rong Rong
Hi Rong:

   I submit the job to the flink yarn cluster. The code is :

在 2018年9月6日,上午7:12,Rong Rong <[hidden email]> 写道:

Based on what you provided. Seems like your SQL did not pass validation phase, which means it cannot be compiled into an execution job graph, hence I do not think it is possible to even deploy anything meaningful.
Can you describe how you submit the job using Flink SQL? where are you submitting it to?

Like Chesnay mentioned, please also include your SQL program, aka your Starter file.

--
Rong



On Wed, Sep 5, 2018 at 1:57 AM 孙森 <[hidden email]> wrote:
Hi all:
        I am using flink sql ,when I encountered an error ,I cannot  catch the runtime exception on the CLUSTER. But , when I used the same code and sql on my local test ,I can find the exception. I hava no idea where to debug and what should I do . I need you help. Thank you very much.

sensun


The local exception:

<屏幕快照 2018-09-05 上午11.55.20.png><屏幕快照 2018-09-05 上午11.55.20.png>