commit edfcbcb7e908bc7d08d548f24dbec213ca6d4c8a
author Tzu-Li (Gordon) Tai <tzulitai@apache.org> Wed Mar 04 19:57:47 2020 +0800
committer Tzu-Li (Gordon) Tai <tzulitai@apache.org> Fri Mar 06 09:36:49 2020 +0800
tree 97da5b493bcdbf62973a00c8821f7d7162748f2d
parent 8a6b8e1cee25d2950b1090967423d9460321be25

[FLINK-16415] [core] Use JsonModuleFactory in JsonServiceLoader

statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/JsonServiceLoader.java

diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/JsonServiceLoader.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/JsonServiceLoader.java
index e170260..0ac7712 100644
--- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/JsonServiceLoader.java
+++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/JsonServiceLoader.java
@@ -46,8 +46,7 @@
   static StatefulFunctionModule fromUrl(ObjectMapper mapper, URL moduleUrl) {
     try {
       JsonNode root = readAndValidateModuleTree(mapper, moduleUrl);
-      JsonNode spec = root.at(Pointers.MODULE_SPEC);
-      return new JsonModule(spec, moduleUrl);
+      return JsonModuleFactory.create(root, moduleUrl);
     } catch (Throwable t) {
       throw new RuntimeException("Failed loading a module at " + moduleUrl, t);
     }