Dian Fu created FLINK-22470:
-------------------------------
Summary: The root cause of the exception encountered during compiling the job was not exposed to users in certain cases
Key: FLINK-22470
URL:
https://issues.apache.org/jira/browse/FLINK-22470 Project: Flink
Issue Type: Improvement
Components: API / Python
Reporter: Dian Fu
Assignee: Dian Fu
Fix For: 1.13.0, 1.12.4
For the following job:
{code}
def test():
from pyflink.table import DataTypes, BatchTableEnvironment, EnvironmentSettings
env_settings = EnvironmentSettings.new_instance().in_batch_mode().use_blink_planner().build()
table_env = BatchTableEnvironment.create(environment_settings=env_settings)
table_env \
.get_config() \
.get_configuration() \
.set_string(
"pipeline.jars",
"file:///Users/dianfu/code/src/alibaba/ververica-connectors/flink-sql-avro-1.12.0.jar"
)
table = table_env.from_elements(
[('111', '222')],
schema=DataTypes.ROW([
DataTypes.FIELD('text', DataTypes.STRING()),
DataTypes.FIELD('text1', DataTypes.STRING())
])
)
sink_ddl = f"""
create table Results(
a STRING,
b STRING
) with (
'connector' = 'filesystem',
'path' = '/Users/dianfu/tmp/',
'format' = 'avro'
)
"""
table_env.execute_sql(sink_ddl)
table.execute_insert("Results").wait()
if __name__ == "__main__":
test()
{code}
It throws the following exception:
{code}
pyflink.util.exceptions.TableException: Failed to execute sql
at org.apache.flink.table.api.internal.TableEnvironmentImpl.executeInternal(TableEnvironmentImpl.java:699)
at org.apache.flink.table.api.internal.TableImpl.executeInsert(TableImpl.java:572)
at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:62)
at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
at java.lang.reflect.Method.invoke(Method.java:498)
at org.apache.flink.api.python.shaded.py4j.reflection.MethodInvoker.invoke(MethodInvoker.java:244)
at org.apache.flink.api.python.shaded.py4j.reflection.ReflectionEngine.invoke(ReflectionEngine.java:357)
at org.apache.flink.api.python.shaded.py4j.Gateway.invoke(Gateway.java:282)
at org.apache.flink.api.python.shaded.py4j.commands.AbstractCommand.invokeMethod(AbstractCommand.java:132)
at org.apache.flink.api.python.shaded.py4j.commands.CallCommand.execute(CallCommand.java:79)
at org.apache.flink.api.python.shaded.py4j.GatewayConnection.run(GatewayConnection.java:238)
at java.lang.Thread.run(Thread.java:748)
Process finished with exit code 1
{code}
The root cause isn't exposed and it's difficult for users to figure out what happens.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
Locked
