[MINOR] FlinkStateBackendConverter add more exception message (#5809)

sandyfog · web-flow · commit 8ff17b047091 · 2022-06-09T15:13:27.000+08:00
* [MINOR] FlinkStateBackendConverter add more  exception message
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
@@ -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));
     }
   }
 }

Original file line number	Diff line number	Diff line change
`@@ -36,7 +36,7 @@ public StateBackend convert(String value) throws ParameterException {`
`36`	`36`	`case "hashmap" : return new HashMapStateBackend();`
`37`	`37`	`case "rocksdb" : return new EmbeddedRocksDBStateBackend();`
`38`	`38`	`default:`
`39`		`- throw new HoodieException(String.format("Unknown flink state backend %s.", value));`
	`39`	`+ throw new HoodieException(String.format("Unknown flink state backend %s. Supports only hashmap and rocksdb by now", value));`
`40`	`40`	`}`
`41`	`41`	`}`
`42`	`42`	`}`