Merge branch 'upgrade-beam' into upgrade-flink

theodolite-benchmarks/beam-commons/src/main/java/theodolite/commons/beam/AbstractPipeline.java

@@ -12,8 +12,9 @@ import org.apache.kafka.clients.consumer.ConsumerConfig;
  */
 public class AbstractPipeline extends Pipeline {
 
-  private static final String KAFKA_CONFIG_SPECIFIC_AVRO_READER = "specific.avro.reader";
-  private static final String KAFKA_CONFIG_SCHEMA_REGISTRY_URL = "schema.registry.url";
+  private static final String KAFKA_CONFIG_SPECIFIC_AVRO_READER = "specific.avro.reader"; // NOPMD
+  private static final String KAFKA_CONFIG_SCHEMA_REGISTRY_URL = "schema.registry.url"; // NOPMD
+
   protected final String inputTopic;
   protected final String bootstrapServer;
   // Application Configurations

theodolite-benchmarks/uc4-beam/src/main/java/application/DuplicateAsFlatMap.java

@@ -24,7 +24,8 @@ public class DuplicateAsFlatMap
   private static final String STATE_STORE_NAME = "DuplicateParents";
 
   @StateId(STATE_STORE_NAME)
-  private final StateSpec<ValueState<Set<String>>> parents = StateSpecs.value();
+  private final StateSpec<ValueState<Set<String>>> parents = StateSpecs.value(); // NOPMD
+
   private final PCollectionView<Map<String, Set<String>>> childParentPairMap;
 
   public DuplicateAsFlatMap(final PCollectionView<Map<String, Set<String>>> childParentPairMap) {

theodolite-benchmarks/uc4-beam/src/main/java/application/UpdateChildParentPairs.java

@@ -17,7 +17,7 @@ public class UpdateChildParentPairs extends DoFn<KV<String, Set<String>>, KV<Str
   private static final long serialVersionUID = 1L;
 
   @StateId(STATE_STORE_NAME)
-  private final StateSpec<ValueState<Set<String>>> parents = StateSpecs.value();
+  private final StateSpec<ValueState<Set<String>>> parents = StateSpecs.value(); // NOPMD
 
   /**
    * Match the changes accordingly.