diff --git a/theodolite-benchmarks/beam-commons/build.gradle b/theodolite-benchmarks/beam-commons/build.gradle index 66ec44ad715d64458584e71fdd4f49abb9c458f4..23ae16e7e63ae195c1faeb2f78c8157497a1ad76 100644 --- a/theodolite-benchmarks/beam-commons/build.gradle +++ b/theodolite-benchmarks/beam-commons/build.gradle @@ -19,11 +19,11 @@ dependencies { implementation 'com.google.code.gson:gson:2.8.2' implementation 'com.google.guava:guava:24.1-jre' - implementation('org.apache.beam:beam-sdks-java-io-kafka:2.22.0'){ + implementation('org.apache.beam:beam-sdks-java-io-kafka:2.35.0'){ exclude group: 'org.apache.kafka', module: 'kafka-clients' } implementation group: 'org.slf4j', name: 'slf4j-simple', version: '1.7.30' - implementation group: 'org.apache.beam', name: 'beam-sdks-java-core', version: '2.22.0' + implementation group: 'org.apache.beam', name: 'beam-sdks-java-core', version: '2.35.0' runtimeOnly 'org.slf4j:slf4j-api:1.7.32' runtimeOnly 'org.slf4j:slf4j-jdk14:1.7.32' diff --git a/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.flink.gradle b/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.flink.gradle index eb9bda1f84c4f20568fca1498462dff9082ea1fa..02bf925f8dc29456f9eeaddeef800d2edcf837f8 100644 --- a/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.flink.gradle +++ b/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.flink.gradle @@ -3,6 +3,6 @@ plugins { } dependencies { - implementation group: 'org.apache.beam', name: 'beam-runners-flink-1.12', version: '2.27.0' - implementation group: 'org.apache.flink', name: 'flink-statebackend-rocksdb_2.11', version: '1.12.0' + implementation group: 'org.apache.beam', name: 'beam-runners-flink-1.13', version: '2.35.0' + implementation group: 'org.apache.flink', name: 'flink-statebackend-rocksdb_2.11', version: '1.13.0' } \ No newline at end of file diff --git a/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.gradle b/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.gradle index 09e36d52171699c61b212b1f64c827933679b6fa..df14f0b4a42afcf036963d3d6467c6d45b327ad5 100644 --- a/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.gradle +++ b/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.gradle @@ -18,7 +18,7 @@ repositories { } } -def apacheBeamVersion = '2.22.0' //'2.27.0' // '2.34.0' +def apacheBeamVersion = '2.35.0' dependencies { // These dependencies are used internally, and not exposed to consumers on their own compile classpath. diff --git a/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.samza.gradle b/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.samza.gradle index 73e916ccc867b9b3316776192f0dab56fa0710f0..419d244ddb48790cb55efab2207231d6f5691114 100644 --- a/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.samza.gradle +++ b/theodolite-benchmarks/buildSrc/src/main/groovy/theodolite.beam.samza.gradle @@ -3,7 +3,7 @@ plugins { } dependencies { - implementation('org.apache.beam:beam-runners-samza:2.22.0') { + implementation('org.apache.beam:beam-runners-samza:2.35.0') { exclude group: 'org.apache.samza', module: 'samza-yarn_2.11' } } \ No newline at end of file diff --git a/theodolite-benchmarks/uc4-beam/src/main/java/serialization/AggregatedActivePowerRecordCoder.java b/theodolite-benchmarks/uc4-beam/src/main/java/serialization/AggregatedActivePowerRecordCoder.java index d2b484f5ab30be63f311d6dbcf495baebbd5e2b4..1d539c0d0d777c47c95e2b594e5e952fb4ab6c0a 100644 --- a/theodolite-benchmarks/uc4-beam/src/main/java/serialization/AggregatedActivePowerRecordCoder.java +++ b/theodolite-benchmarks/uc4-beam/src/main/java/serialization/AggregatedActivePowerRecordCoder.java @@ -45,7 +45,7 @@ public class AggregatedActivePowerRecordCoder extends Coder<AggregatedActivePowe @Override public List<? extends Coder<?>> getCoderArguments() { - return null; + return List.of(); } @Override