From cbe27e6faf65f676ccd463bc331db5977941b299 Mon Sep 17 00:00:00 2001
From: lorenz <stu203404@mail.uni-kiel.de>
Date: Thu, 21 Oct 2021 14:43:26 +0200
Subject: [PATCH] Add serialUID to uc1-beam-samza
Co-authored-by: Jan Bensien <stu128012@mail.uni-kiel.de>
---
.../src/main/java/application/Uc1ApplicationBeam.java | 5 +----
1 file changed, 1 insertion(+), 4 deletions(-)
diff --git a/theodolite-benchmarks/uc1-beam-samza/src/main/java/application/Uc1ApplicationBeam.java b/theodolite-benchmarks/uc1-beam-samza/src/main/java/application/Uc1ApplicationBeam.java
index 237125daa..3b52b18d2 100644
--- a/theodolite-benchmarks/uc1-beam-samza/src/main/java/application/Uc1ApplicationBeam.java
+++ b/theodolite-benchmarks/uc1-beam-samza/src/main/java/application/Uc1ApplicationBeam.java
@@ -59,9 +59,6 @@ public final class Uc1ApplicationBeam {
@SuppressWarnings({"unchecked", "rawtypes","unused"})
public static void main(final String[] args) {
-
-
-
// Set Configuration for Kafka
final String bootstrapServer =
System.getenv(BOOTSTRAP) == null ? "my-confluent-cp-kafka:9092"
@@ -137,7 +134,7 @@ public final class Uc1ApplicationBeam {
*/
@SuppressWarnings({"unused"})
private static class LoggKeys extends DoFn<KV<String, String>,KV<String, String>> {
- public static final long serialVersionUID = 4328743;
+ private static final long serialVersionUID = 4328743;
@ProcessElement
public void processElement(@Element final KV<String, String> kv,
--
GitLab