[jira] [Created] (FLINK-31956) Extend the CompiledPlan to read from/write to Flink's FileSystem

["Jane Chan (Jira)" <ji...@apache.org>]

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)