[BEAM-11948] Drop support for Flink 1.8 and 1.9

CHANGES.md

@@ -66,6 +66,7 @@
 ## Breaking Changes
 
 * X behavior was changed ([BEAM-X](https://issues.apache.org/jira/browse/BEAM-X)).
+* Drop support for Flink 1.8 and 1.9 ([BEAM-11948](https://issues.apache.org/jira/browse/BEAM-11948)).
 
 ## Deprecations
 

gradle.properties

@@ -32,5 +32,5 @@ javaVersion=1.8
 docker_image_default_repo_root=apache
 docker_image_default_repo_prefix=beam_
 
-flink_versions=1.8,1.9,1.10,1.11,1.12
+flink_versions=1.10,1.11,1.12
 

runners/flink/1.10/build.gradle

@@ -22,8 +22,8 @@ project.ext {
   // Set the version of all Flink-related dependencies here.
   flink_version = '1.10.1'
   // Version specific code overrides.
-  main_source_overrides = ["${basePath}/1.8/src/main/java", "${basePath}/1.9/src/main/java", './src/main/java']
-  test_source_overrides = ["${basePath}/1.8/src/test/java", "${basePath}/1.9/src/test/java", './src/test/java']
+  main_source_overrides = ['./src/main/java']
+  test_source_overrides = ['./src/test/java']
   main_resources_overrides = []
   test_resources_overrides = []
   archives_base_name = 'beam-runners-flink-1.10'

runners/flink/1.11/build.gradle

@@ -22,8 +22,8 @@ project.ext {
   // Set the version of all Flink-related dependencies here.
   flink_version = '1.11.3'
   // Version specific code overrides.
-  main_source_overrides = ["${basePath}/1.8/src/main/java", "${basePath}/1.9/src/main/java", "${basePath}/1.10/src/main/java", './src/main/java']
-  test_source_overrides = ["${basePath}/1.8/src/test/java", "${basePath}/1.9/src/test/java", "${basePath}/1.10/src/test/java", './src/test/java']
+  main_source_overrides = ["${basePath}/1.10/src/main/java", './src/main/java']
+  test_source_overrides = ["${basePath}/1.10/src/test/java", './src/test/java']
   main_resources_overrides = []
   test_resources_overrides = []
   archives_base_name = 'beam-runners-flink-1.11'

runners/flink/1.12/build.gradle

@@ -22,8 +22,8 @@ project.ext {
   // Set the version of all Flink-related dependencies here.
   flink_version = '1.12.2'
   // Version specific code overrides.
-  main_source_overrides = ["${basePath}/1.8/src/main/java", "${basePath}/1.9/src/main/java", "${basePath}/1.10/src/main/java", "${basePath}/1.11/src/main/java", './src/main/java']
-  test_source_overrides = ["${basePath}/1.8/src/test/java", "${basePath}/1.9/src/test/java", "${basePath}/1.10/src/test/java", "${basePath}/1.11/src/test/java", './src/test/java']
+  main_source_overrides = ["${basePath}/1.10/src/main/java", "${basePath}/1.11/src/main/java", './src/main/java']
+  test_source_overrides = ["${basePath}/1.10/src/test/java", "${basePath}/1.11/src/test/java", './src/test/java']
   main_resources_overrides = []
   test_resources_overrides = []
   archives_base_name = 'beam-runners-flink-1.12'