This is an automated email from the ASF dual-hosted git repository. yihua pushed a commit to branch release-0.11.1-rc2-prep in repository https://gitbox.apache.org/repos/asf/hudi.git
commit c68f22aeb818da44c93d0d899873a03b97ffc31b Author: sandyfog <[email protected]> AuthorDate: Thu Jun 9 15:13:27 2022 +0800 [MINOR] FlinkStateBackendConverter add more exception message (#5809) * [MINOR] FlinkStateBackendConverter add more exception message --- .../src/main/java/org/apache/hudi/util/FlinkStateBackendConverter.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkStateBackendConverter.java b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkStateBackendConverter.java index a6b15ffb74..0e4797973e 100644 --- a/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkStateBackendConverter.java +++ b/hudi-flink-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkStateBackendConverter.java @@ -36,7 +36,7 @@ public class FlinkStateBackendConverter implements IStringConverter<StateBackend case "hashmap" : return new HashMapStateBackend(); case "rocksdb" : return new EmbeddedRocksDBStateBackend(); 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)); } } }
