Skip to content
Snippets Groups Projects
Commit ae2553f5 authored by Lorenz Boguhn's avatar Lorenz Boguhn
Browse files

Add serialUID to uc1-beam-samza


Co-authored-by: default avatarJan Bensien <stu128012@mail.uni-kiel.de>
parent 644f45fe
No related branches found
No related tags found
1 merge request!187Migrate Beam benchmark implementation
...@@ -59,9 +59,6 @@ public final class Uc1ApplicationBeam { ...@@ -59,9 +59,6 @@ public final class Uc1ApplicationBeam {
@SuppressWarnings({"unchecked", "rawtypes","unused"}) @SuppressWarnings({"unchecked", "rawtypes","unused"})
public static void main(final String[] args) { public static void main(final String[] args) {
// Set Configuration for Kafka // Set Configuration for Kafka
final String bootstrapServer = final String bootstrapServer =
System.getenv(BOOTSTRAP) == null ? "my-confluent-cp-kafka:9092" System.getenv(BOOTSTRAP) == null ? "my-confluent-cp-kafka:9092"
...@@ -137,7 +134,7 @@ public final class Uc1ApplicationBeam { ...@@ -137,7 +134,7 @@ public final class Uc1ApplicationBeam {
*/ */
@SuppressWarnings({"unused"}) @SuppressWarnings({"unused"})
private static class LoggKeys extends DoFn<KV<String, String>,KV<String, String>> { 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 @ProcessElement
public void processElement(@Element final KV<String, String> kv, public void processElement(@Element final KV<String, String> kv,
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment