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:
|
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:
|
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:
=?UTF-8?B?5bGP5bmV5b+r54WnIDIwMTgtMDktMDUg5LiK5Y2IMTEuNTUuMjAucG5n?= (719K) Download Attachment =?UTF-8?B?5bGP5bmV5b+r54WnIDIwMTgtMDktMDUg5LiK5Y2IMTEuNTUuMjAucG5n?= (719K) Download Attachment |
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 :
|
In reply to this post by Rong Rong
Hi Rong:
I submit the job to the flink yarn cluster. The code is :
|
Free forum by Nabble | Edit this page |