lanyuanxiaoyao/hudi
1
0
Fork 0
Code Activity

[MINOR] FlinkStateBackendConverter add more exception message (#5809)

Browse Source 
* [MINOR] FlinkStateBackendConverter add more  exception message
This commit is contained in:
sandyfog
2022-06-09 15:13:27 +08:00
committed by GitHub
parent f5ab921300
commit 8ff17b0470
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkStateBackendConverter.java
View File

@@ -36,7 +36,7 @@ public class FlinkStateBackendConverter implements IStringConverter<StateBackend
case "hashmap" : return new HashMapStateBackend(); case "hashmap" : return new HashMapStateBackend();
case "rocksdb" : return new EmbeddedRocksDBStateBackend(); case "rocksdb" : return new EmbeddedRocksDBStateBackend();
default: default:
throw new HoodieException(String.format("Unknown flink state backend %s.", value)); throw new HoodieException(String.format("Unknown flink state backend %s. Supports only hashmap and rocksdb by now", value));
} }
} }
} }