[ 
https://issues.apache.org/jira/browse/FLINK-32961?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
 ]

Martijn Visser updated FLINK-32961:
-----------------------------------
    Fix Version/s:     (was: 1.18.0)

> A new FileSystemFactory that support two high available hdfs
> ------------------------------------------------------------
>
>                 Key: FLINK-32961
>                 URL: https://issues.apache.org/jira/browse/FLINK-32961
>             Project: Flink
>          Issue Type: Improvement
>          Components: FileSystems
>            Reporter: 王茂军
>            Priority: Major
>   Original Estimate: 168h
>  Remaining Estimate: 168h
>
> I run realtime ETL program by flink on yarn. The ETL program sink user log to 
> master hdfs, and sink checkpoint to anather micro hdfs.The master hdfs and 
> micro hdfs are both high available.
> By default, the ETL program can not understand the dfs.nameservices of the 
> micro hdfs.
> I prepare to write a custom org.apache.flink.core.fs.FileSystemFactory that 
> support two or more ha hdfs.So that , i can sink user log to master hdfs, and 
> save checkpoint data to micro hdfs



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to