From 8ff17b047091b4b90e6e972d8b43d416714a0613 Mon Sep 17 00:00:00 2001
From: sandyfog <154525105@qq.com>
Date: Thu, 9 Jun 2022 15:13:27 +0800
Subject: [PATCH] [MINOR] FlinkStateBackendConverter add more  exception
 message (#5809)

* [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 a6b15ffb7..0e4797973 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));
     }
   }
 }