[beam-tools] skip missing groovy classes when submitting job

Author: je-ik

beam/tools/src/main/java/cz/o2/proxima/beam/tools/groovy/BeamStreamProvider.java

@@ -47,6 +47,7 @@
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.Optional;
 import java.util.function.Supplier;
 import java.util.stream.Collectors;
@@ -274,7 +275,17 @@ private Collection<URI> getAddedJars() {
             .map(
                 l ->
                     l.getDefinedClasses().stream()
-                        .map(name -> ExceptionUtils.uncheckedFactory(() -> loader.loadClass(name)))
+                        .map(
+                            name -> {
+                              try {
+                                return ExceptionUtils.uncheckedFactory(
+                                    () -> loader.loadClass(name));
+                              } catch (Exception ex) {
+                                log.warn("Failed to find class {}. Skipping.", name, ex);
+                                return null;
+                              }
+                            })
+                        .filter(Objects::nonNull)
                         .map(cls -> Pair.of(cls, loader.getClassByteCode(cls.getName())))
                         .collect(Collectors.toMap(Pair::getFirst, Pair::getSecond)))
             .orElse(Collections.emptyMap());