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

["Shuai Xu (Jira)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/FLINK-31956?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17717082#comment-17717082 ] 

Shuai Xu commented on FLINK-31956:
----------------------------------

Hi Jane, I have taken the FLINK-31952 which is similar to the task. I think it could be achieved by modifying the streamplanner and tableEnvironmentImpl.Could I take the task?

> 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
>            Priority: Major
>             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:sql}
> -- 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)