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

Add serialUID to uc1-beam-samza


Co-authored-by: default avatarJan Bensien <stu128012@mail.uni-kiel.de>
parent 4fa74e1f
No related branches found
No related tags found
1 merge request!187Migrate Beam benchmark implementation
......@@ -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,
......
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