[jira] [Created] (FLINK-20207) Improve the error message printed when submitting the pyflink jobs via 'flink run'

[Shang Yuanchun (Jira)]

Wei Zhong created FLINK-20207:
---------------------------------

             Summary: Improve the error message printed when submitting the pyflink jobs via 'flink run'
                 Key: FLINK-20207
                 URL: https://issues.apache.org/jira/browse/FLINK-20207
             Project: Flink
          Issue Type: Improvement
          Components: API / Python
            Reporter: Wei Zhong


Sometimes the Java stack traces were swallowed when submitting the pyflink jobs via "flink run", e.g.:

File "/home/cdh272705/poc/T24_parse.py", line 179, in from_kafka_to_oracle_demo
   main_table.execute_insert("sink")#.get_job_client().get_job_execution_result().result()
 File "/home/cdh272705/.local/lib/python3.6/site-packages/pyflink/table/table.py", line 783, in execute_insert
   return TableResult(self._j_table.executeInsert(table_path, overwrite))
 File "/home/cdh272705/.local/lib/python3.6/site-packages/py4j/java_gateway.py", line 1286, in __call__
   answer, self.gateway_client, self.target_id, self.name)
 File "/home/cdh272705/.local/lib/python3.6/site-packages/pyflink/util/exceptions.py", line 154, in deco
   raise exception_mapping[exception](s.split(': ', 1)[1], stack_trace)
pyflink.util.exceptions.TableException: 'Failed to execute sql'

 

The Java stack traces under the TableException were swallowed, which makes the troubleshooting difficult.

We need to improve the error reporting logic.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)