From 1e9cc026666f7dbbb506775f9375eafb3d6d836a Mon Sep 17 00:00:00 2001 From: sandyfog <154525105@qq.com> Date: Thu, 9 Jun 2022 11:10:55 +0800 Subject: [PATCH 1/2] [MINOR] FlinkStateBackendConverter add more exception message --- .../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 a6b15ffb74e32..70b741eb95656 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 StateBackend convert(String value) throws ParameterException { 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. support only hashmap and rocksdb by now", value)); } } } From e8c48f110232ec8c43b66736218ddcbc6de744b2 Mon Sep 17 00:00:00 2001 From: sandyfog <154525105@qq.com> Date: Thu, 9 Jun 2022 13:13:40 +0800 Subject: [PATCH 2/2] [MINOR] FlinkStateBackendConverter add more exception message --- .../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 70b741eb95656..0e4797973e985 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 StateBackend convert(String value) throws ParameterException { case "hashmap" : return new HashMapStateBackend(); case "rocksdb" : return new EmbeddedRocksDBStateBackend(); default: - throw new HoodieException(String.format("Unknown flink state backend %s. support only hashmap and rocksdb by now", value)); + throw new HoodieException(String.format("Unknown flink state backend %s. Supports only hashmap and rocksdb by now", value)); } } }