[hudi] branch master updated: [MINOR] FlinkStateBackendConverter add more exception message (#5809)

[da...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

danny0405 pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/hudi.git


The following commit(s) were added to refs/heads/master by this push:
     new 8ff17b0470 [MINOR] FlinkStateBackendConverter add more  exception message (#5809)
8ff17b0470 is described below

commit 8ff17b047091b4b90e6e972d8b43d416714a0613
Author: sandyfog <15...@qq.com>
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));
     }
   }
 }