[ https://issues.apache.org/jira/browse/FLINK-24335?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Nicholas Jiang closed FLINK-24335. ---------------------------------- Resolution: Duplicate > Get java.net.MalformedURLException when submit job from python by pyflink > table api. > ------------------------------------------------------------------------------------ > > Key: FLINK-24335 > URL: https://issues.apache.org/jira/browse/FLINK-24335 > Project: Flink > Issue Type: Bug > Components: API / Python, Client / Job Submission, Table SQL / API > Affects Versions: 1.11.2 > Environment: Liunx, Flink 1.11.2 > Reporter: Xin Yu > Priority: Major > > When I run flink client to submit a python based workflow, I got the > MalformedURLException like this: > [https://gist.github.com/is/faabafc7f8750f3f3161fbb6517ed6ff] > After some debug work, I found the problem is related with > TableEvneriontment.execute_sql. The root cause is > TableEvenriontment._add_jars_to_j_env_config in > pyflink/table/TableEnverionment.py. > {{if j_configuration.containsKey(config_key):}} > {{ for url in j_configuration.getString(config_key, "").split(";"):}} > {{ jar_urls_set.add(url)}} > In our case, pipeline.classpaths was set by empty list value > from FromProgramOption, so the upper code block will > introduce a empty string ("") into pipeline.classpaths, for example > "a.jar;b.jar;;c.jar", and it will cause the according exception. > Another problem, the order of string set in python is not > determinate, so ";".join(jar_urls_set) does NOT keep the > classpaths order. The list is more suiteable in this case. -- This message was sent by Atlassian Jira (v8.3.4#803005)