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 a6b15ffb74e3..0e4797973e98 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. Supports only hashmap and rocksdb by now", value)); } } }