Merge pull request #1012: [beam-core] bump beam to 2.72.0

Author: je-ik

beam/core/src/test/java/cz/o2/proxima/beam/util/state/ExternalStateExpanderTest.java

@@ -30,6 +30,7 @@
 import java.util.PriorityQueue;
 import java.util.UUID;
 import org.apache.beam.runners.direct.DirectRunner;
+import org.apache.beam.runners.flink.FlinkPipelineOptions;
 import org.apache.beam.runners.flink.FlinkRunner;
 import org.apache.beam.sdk.Pipeline;
 import org.apache.beam.sdk.Pipeline.PipelineVisitor.Defaults;
@@ -312,6 +313,10 @@ public void testSimpleExpandWithStateStore() throws IOException {
   @Test
   public void testStateWithElementEarly() throws IOException {
     Pipeline pipeline = createPipeline();
+    if (pipeline.getOptions().getRunner().equals(FlinkRunner.class)) {
+      FlinkPipelineOptions flinkOpts = pipeline.getOptions().as(FlinkPipelineOptions.class);
+      flinkOpts.setParallelism(5);
+    }
     Instant now = new Instant(0);
     PCollection<String> inputs =
         pipeline.apply(
@@ -412,6 +417,11 @@ public void visitPrimitiveTransform(TransformHierarchy.Node node) {
 
   private void testTimestampInject(boolean multiOutput) throws IOException {
     Pipeline pipeline = createPipeline();
+    if (pipeline.getOptions().getRunner().equals(FlinkRunner.class)) {
+      // limit parallelism for Flink, in multi-core CPUs it might run out of network buffers
+      FlinkPipelineOptions flinkOpts = pipeline.getOptions().as(FlinkPipelineOptions.class);
+      flinkOpts.setParallelism(5);
+    }
     Instant now = new Instant(0);
     PCollection<String> inputs =
         pipeline.apply(

buildSrc/src/main/groovy/cz.o2.proxima.java-conventions.gradle

@@ -24,7 +24,7 @@ plugins {
 java.sourceCompatibility = JavaVersion.VERSION_11
 
 def auto_service_version = "1.1.1"
-def beam_version = "2.71.0"
+def beam_version = "2.72.0"
 def errorprone_version = "2.18.0"
 def flink_version = "1.18.0"
 def grpc_version = "1.71.0"