[jira] [Created] (FLINK-22470) The root cause of the exception encountered during compiling the job was not exposed to users in certain cases

[Dian Fu (Jira)]

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)