| commit | 123e4d2f6126a04f4f55b270b7c4646170cf5862 | [log] [tgz] |
|---|---|---|
| author | sjwiesman <sjwiesman@gmail.com> | Wed Sep 01 09:21:16 2021 -0500 |
| committer | sjwiesman <sjwiesman@gmail.com> | Thu Sep 02 11:49:40 2021 -0500 |
| tree | 19404dbb6f3afef8d0f16ea3f69cda3d5b06a7c4 | |
| parent | 6ae76483bafd1212693b137c3e1f4452a4d2d527 [diff] |
[FLINK-24110] Filter null ComponentJsonObjects This closes #266
diff --git a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/RemoteModule.java b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/RemoteModule.java index db1b07e..5aea97a 100644 --- a/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/RemoteModule.java +++ b/statefun-flink/statefun-flink-core/src/main/java/org/apache/flink/statefun/flink/core/jsonmodule/RemoteModule.java
@@ -48,6 +48,7 @@ private static List<ComponentJsonObject> parseComponentNodes( Iterable<? extends JsonNode> componentNodes) { return StreamSupport.stream(componentNodes.spliterator(), false) + .filter(node -> !node.isNull()) .map(ComponentJsonObject::new) .collect(Collectors.toList()); }
diff --git a/statefun-flink/statefun-flink-core/src/test/resources/remote-module/module.yaml b/statefun-flink/statefun-flink-core/src/test/resources/remote-module/module.yaml index b1e7142..6ebb751 100644 --- a/statefun-flink/statefun-flink-core/src/test/resources/remote-module/module.yaml +++ b/statefun-flink/statefun-flink-core/src/test/resources/remote-module/module.yaml
@@ -24,3 +24,4 @@ kind: com.foo.bar/test.component.3 spec: nonsense: ignored +--- \ No newline at end of file