[FLINK-36336] Remove deprecated dataset API exclude table module

Author: codenohup

flink-architecture-tests/flink-architecture-tests-production/archunit-violations/18509c9e-3250-4c52-91b9-11ccefc85db1

@@ -88,6 +88,10 @@ org.apache.flink.core.fs.FileSystem.initOutPathLocalFS(org.apache.flink.core.fs.
 org.apache.flink.core.fs.FileSystem.initialize(org.apache.flink.configuration.Configuration, org.apache.flink.core.plugin.PluginManager): Argument leaf type org.apache.flink.core.plugin.PluginManager does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
 org.apache.flink.core.fs.FileSystem.initialize(org.apache.flink.configuration.Configuration, org.apache.flink.core.plugin.PluginManager): Exception leaf type org.apache.flink.configuration.IllegalConfigurationException does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
 org.apache.flink.core.io.InputSplitSource.getInputSplitAssigner([Lorg.apache.flink.core.io.InputSplit;): Returned leaf type org.apache.flink.core.io.InputSplitAssigner does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
+org.apache.flink.hadoopcompatibility.mapred.HadoopReduceFunction.apply(java.lang.Object, org.apache.flink.streaming.api.windowing.windows.GlobalWindow, java.lang.Iterable, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.windowing.windows.GlobalWindow does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
+org.apache.flink.hadoopcompatibility.mapred.HadoopReduceFunction.apply(java.lang.Object, org.apache.flink.streaming.api.windowing.windows.Window, java.lang.Iterable, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.windowing.windows.Window does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
+org.apache.flink.hadoopcompatibility.mapred.HadoopReduceFunction.apply(org.apache.flink.streaming.api.windowing.windows.GlobalWindow, java.lang.Iterable, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.windowing.windows.GlobalWindow does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
+org.apache.flink.hadoopcompatibility.mapred.HadoopReduceFunction.apply(org.apache.flink.streaming.api.windowing.windows.Window, java.lang.Iterable, org.apache.flink.util.Collector): Argument leaf type org.apache.flink.streaming.api.windowing.windows.Window does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
 org.apache.flink.runtime.jobgraph.tasks.InputSplitProvider.getNextInputSplit(java.lang.ClassLoader): Exception leaf type org.apache.flink.runtime.jobgraph.tasks.InputSplitProviderException does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
 org.apache.flink.streaming.api.checkpoint.CheckpointedFunction.initializeState(org.apache.flink.runtime.state.FunctionInitializationContext): Argument leaf type org.apache.flink.runtime.state.FunctionInitializationContext does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated
 org.apache.flink.streaming.api.checkpoint.CheckpointedFunction.snapshotState(org.apache.flink.runtime.state.FunctionSnapshotContext): Argument leaf type org.apache.flink.runtime.state.FunctionSnapshotContext does not satisfy: reside outside of package 'org.apache.flink..' or reside in any package ['..shaded..'] or annotated with @Public or annotated with @Deprecated

flink-architecture-tests/flink-architecture-tests-production/archunit-violations/7602816f-5c01-4b7a-9e3e-235dfedec245

@@ -86,10 +86,6 @@ org.apache.flink.api.common.typeutils.base.array.LongPrimitiveArraySerializer$Lo
 org.apache.flink.api.common.typeutils.base.array.ShortPrimitiveArraySerializer$ShortPrimitiveArraySerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
 org.apache.flink.api.common.typeutils.base.array.StringArraySerializer$StringArraySerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
 org.apache.flink.api.connector.source.lib.NumberSequenceSource$NumberSequenceSplit does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
-org.apache.flink.api.java.Utils$ChecksumHashCode does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
-org.apache.flink.api.java.Utils$ChecksumHashCodeHelper does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
-org.apache.flink.api.java.Utils$CollectHelper does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
-org.apache.flink.api.java.Utils$CountHelper does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
 org.apache.flink.api.java.aggregation.MaxAggregationFunction$MaxAggregationFunctionFactory does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
 org.apache.flink.api.java.aggregation.MinAggregationFunction$MinAggregationFunctionFactory does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
 org.apache.flink.api.java.aggregation.SumAggregationFunction$SumAggregationFunctionFactory does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
@@ -143,7 +139,6 @@ org.apache.flink.api.java.typeutils.runtime.RowSerializer$RowSerializerSnapshot
 org.apache.flink.api.java.typeutils.runtime.Tuple0SerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
 org.apache.flink.api.java.typeutils.runtime.ValueSerializer$ValueSerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
 org.apache.flink.api.java.typeutils.runtime.kryo.ChillSerializerRegistrar does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
-org.apache.flink.api.java.typeutils.runtime.kryo.FlinkChillPackageRegistrar does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
 org.apache.flink.api.java.typeutils.runtime.kryo.JavaSerializer does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
 org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializer does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated
 org.apache.flink.api.java.typeutils.runtime.kryo.KryoSerializerSnapshot does not satisfy: annotated with @Internal or annotated with @Experimental or annotated with @PublicEvolving or annotated with @Public or annotated with @Deprecated

flink-clients/pom.xml

@@ -57,18 +57,6 @@ under the License.
 			<version>${project.version}</version>
 		</dependency>
 
-		<dependency>
-			<groupId>org.apache.flink</groupId>
-			<artifactId>flink-optimizer</artifactId>
-			<version>${project.version}</version>
-		</dependency>
-
-		<dependency>
-			<groupId>org.apache.flink</groupId>
-			<artifactId>flink-java</artifactId>
-			<version>${project.version}</version>
-		</dependency>
-
 		<dependency>
 			<groupId>commons-cli</groupId>
 			<artifactId>commons-cli</artifactId>

flink-clients/src/main/java/org/apache/flink/client/ClientUtils.java

@@ -21,7 +21,6 @@
 import org.apache.flink.api.common.JobID;
 import org.apache.flink.api.common.JobStatus;
 import org.apache.flink.client.cli.ClientOptions;
-import org.apache.flink.client.program.ContextEnvironment;
 import org.apache.flink.client.program.PackagedProgram;
 import org.apache.flink.client.program.ProgramInvocationException;
 import org.apache.flink.client.program.StreamContextEnvironment;
@@ -91,13 +90,6 @@ public static void executeProgram(
                     "Starting program (detached: {})",
                     !configuration.get(DeploymentOptions.ATTACHED));
 
-            ContextEnvironment.setAsContext(
-                    executorServiceLoader,
-                    configuration,
-                    userCodeClassLoader,
-                    enforceSingleJobExecution,
-                    suppressSysout);
-
             StreamContextEnvironment.setAsContext(
                     executorServiceLoader,
                     configuration,
@@ -112,7 +104,6 @@ public static void executeProgram(
             try {
                 program.invokeInteractiveModeForExecution();
             } finally {
-                ContextEnvironment.unsetAsContext();
                 StreamContextEnvironment.unsetAsContext();
                 // For DataStream v2.
                 ExecutionContextEnvironment.unsetAsContext();

flink-clients/src/main/java/org/apache/flink/client/FlinkPipelineTranslationUtil.java

@@ -83,11 +83,6 @@ public static String translateToJSONExecutionPlan(
 
     private static FlinkPipelineTranslator getPipelineTranslator(
             ClassLoader userClassloader, Pipeline pipeline) {
-        PlanTranslator planTranslator = new PlanTranslator();
-
-        if (planTranslator.canTranslate(pipeline)) {
-            return planTranslator;
-        }
 
         StreamGraphTranslator streamGraphTranslator = new StreamGraphTranslator(userClassloader);