[MINOR] FlinkStateBackendConverter add more exception message

apache · Jun 9, 2022 · e8c48f1 · e8c48f1
1 parent 1e9cc02
commit e8c48f1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...-datasource/hudi-flink/src/main/java/org/apache/hudi/util/FlinkStateBackendConverter.java b/...-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));
     }
   }
 }