Flink CDC里flink1.17写doris的代码怎么做？

Flink CDC里flink1.17写doris的代码，hadooo集群节点磁盘满了我在线扩容，扩容后flink写doris报这个错，请教大家。[1] (1/1) (6fae202bcc093b5e54514400ccc297d3_bc764cd8ddf7a0cff126f51c16239658_0_3) switched from DEPLOYING to FAILED on ahadoop12:44283-19913f @ ahadoop12 (dataPort=33437).
org.apache.flink.core.fs.UnsupportedFileSystemSchemeException: Could not find a file system implementation for scheme 'hdfs'. The scheme is not directly supported by Flink and no Hadoop file system to support this scheme could be loaded. For a full list of supported file systems, please see
https://nightlies.apache.org/flink/flink-docs-stable/ops/filesystems/.
at org.apache.flink.core.fs.FileSystem.getUnguardedFileSystem(FileSystem.java:543) ~[flink-dist-1.17.1.jar:1.17.1]
at org.apache.flink.core.fs.FileSystem.get(FileSystem.java:409) ~[flink-dist-1.17.1.jar:1.17.1]
at org.apache.flink.core.fs.Path.getFileSystem(Path.java:274) ~[flink-dist-1.17.1.jar:1.17.1]
at org.apache.flink.runtime.state.filesystem.FsCheckpointStorageAccess.(FsCheckpointStorageAccess.java:67) ~[flink-dist-1.17.1.jar:1.17.1]