Jane Chan created FLINK-31956: --------------------------------- Summary: Extend the CompiledPlan to read from/write to Flink's FileSystem Key: FLINK-31956 URL: https://issues.apache.org/jira/browse/FLINK-31956 Project: Flink Issue Type: Sub-task Components: Table SQL / Client, Table SQL / Planner Affects Versions: 1.18.0 Reporter: Jane Chan Fix For: 1.18.0
At present, COMPILE/EXECUTE PLAN FOR '${plan.json}' only supports writing to/reading from a local file without the scheme. We propose to extend the support for Flink's FileSystem. {code:java} -- before COMPILE PLAN FOR '/tmp/foo/bar.json' <insert_query> EXECUTE PLAN FOR '/tmp/foo/bar.json' -- after COMPILE PLAN FOR 'file:///tmp/foo/bar.json' <insert_query> COMPILE PLAN FOR 'hdfs:///tmp/foo/bar.json' <insert_query> COMPILE PLAN FOR 's3:///tmp/foo/bar.json' <insert_query> COMPILE PLAN FOR 'oss:///tmp/foo/bar.json' <insert_query> EXECUTE PLAN FOR 'file:///tmp/foo/bar.json' EXECUTE PLAN FOR 'hdfs:///tmp/foo/bar.json' EXECUTE PLAN FOR 's3:///tmp/foo/bar.json' EXECUTE PLAN FOR 'oss:///tmp/foo/bar.json' {code} -- This message was sent by Atlassian Jira (v8.20.10#820010)