Bump Java bytecode compatibility version to Java11

Author: Abacn

CHANGES.md

@@ -82,6 +82,7 @@
 ## Deprecations
 
 * X behavior is deprecated and will be removed in X versions ([#X](https://github.com/apache/beam/issues/X)).
+* Dropped Java 8 support ([#31678](https://github.com/apache/beam/issues/31678)).
 
 ## Bugfixes
 

buildSrc/src/main/groovy/org/apache/beam/gradle/BeamModulePlugin.groovy

@@ -1132,6 +1132,8 @@ class BeamModulePlugin implements Plugin<Project> {
           project.javaVersion = '17'
         } else if (JavaVersion.VERSION_21.equals(configuration.requireJavaVersion)) {
           project.javaVersion = '21'
+        } else if (JavaVersion.VERSION_25.equals(configuration.requireJavaVersion)) {
+          project.javaVersion = '25'
         } else {
           throw new GradleException(
           "requireJavaVersion has to be supported LTS version greater than the default Java version. Actual: " +
@@ -1154,6 +1156,9 @@ class BeamModulePlugin implements Plugin<Project> {
         } else if (requireJavaVersion.compareTo(JavaVersion.VERSION_21) <= 0 &&
         project.hasProperty('java21Home')) {
           forkJavaVersion = '21'
+        } else if (requireJavaVersion.compareTo(JavaVersion.VERSION_25) <= 0 &&
+        project.hasProperty('java25Home')) {
+          forkJavaVersion = '25'
         } else {
           logger.config("Module ${project.name} disabled. To enable, either " +
               "compile on newer Java version or pass java${project.javaVersion}Home project property")
@@ -1582,7 +1587,7 @@ class BeamModulePlugin implements Plugin<Project> {
         options.encoding = "UTF-8"
         // If compiled on newer JDK, set byte code compatibility
         if (requireJavaVersion.compareTo(JavaVersion.current()) < 0) {
-          def compatVersion = project.javaVersion == '1.8' ? '8' : project.javaVersion
+          def compatVersion = project.javaVersion == '11' ? '11' : project.javaVersion
           options.compilerArgs += ['--release', compatVersion]
           // TODO(https://github.com/apache/beam/issues/23901): Fix
           // optimizerOuterThis breakage
@@ -1616,7 +1621,7 @@ class BeamModulePlugin implements Plugin<Project> {
       }
 
       // if specified test java version, modify the compile and runtime versions accordingly
-      if (['8', '11', '17', '21', '25'].contains(project.findProperty('testJavaVersion'))) {
+      if (['11', '17', '21', '25'].contains(project.findProperty('testJavaVersion'))) {
         String ver = project.getProperty('testJavaVersion')
         def testJavaHome = project.getProperty("java${ver}Home")
 

gradle.properties

@@ -33,7 +33,7 @@ signing.gnupg.useLegacyGpg=true
 version=2.74.0-SNAPSHOT
 sdk_version=2.74.0.dev
 
-javaVersion=1.8
+javaVersion=11
 
 docker_image_default_repo_root=apache
 docker_image_default_repo_prefix=beam_

runners/google-cloud-dataflow-java/worker/src/main/java/org/apache/beam/runners/dataflow/worker/streaming/config/StreamingEngineComputationConfigFetcher.java

@@ -171,7 +171,7 @@ private StreamingGlobalConfig createPipelineConfig(StreamingConfigTask config) {
       ImmutableSet<HostAndPort> endpoints =
           StreamSupport.stream(
                   Splitter.on(',').split(config.getWindmillServiceEndpoint()).spliterator(),
-                  /* isParallel= */ false)
+                  /* parallel= */ false)
               .map(endpoint -> HostAndPort.fromString(endpoint).withDefaultPort(windmillPort))
               .collect(toImmutableSet());
 

website/www/site/content/en/documentation/sdks/java.md

@@ -78,6 +78,6 @@ Apache Beam lets you combine transforms written in any supported SDK language an
 </tr>
 <tr>
   <td>8</td>
-  <td>2.x</td>
+  <td>&le; 2.73.0</td>
 </tr>
 </table>