[
https://issues.apache.org/jira/browse/FLINK-20207?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Dian Fu closed FLINK-20207.
---------------------------
Resolution: Fixed
Merged to
- master(1.12.0) via 63aec82a83b5ff03cd539f7bea5c42841f8ae3d4
- release-1.11 via ca702afcaf7fa873735f916274faa17f6c1ea246
> 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
> Assignee: Wei Zhong
> Priority: Major
> Labels: pull-request-available
>
> 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)
