fixup! fixup! [BEAM-9295] Add Flink 1.10 build target and Make FlinkR…

…unner compatible with Flink 1.10

runners/flink/src/main/java/org/apache/beam/runners/flink/FlinkExecutionEnvironments.java

@@ -31,9 +31,7 @@
 import org.apache.flink.configuration.Configuration;
 import org.apache.flink.configuration.CoreOptions;
 import org.apache.flink.configuration.GlobalConfiguration;
-import org.apache.flink.configuration.MemorySize;
 import org.apache.flink.configuration.RestOptions;
-import org.apache.flink.configuration.TaskManagerOptions;
 import org.apache.flink.runtime.jobgraph.SavepointRestoreSettings;
 import org.apache.flink.runtime.state.StateBackend;
 import org.apache.flink.streaming.api.CheckpointingMode;
@@ -69,7 +67,7 @@ static ExecutionEnvironment createBatchExecutionEnvironment(
 
     // depending on the master, create the right environment.
     if ("[local]".equals(flinkMasterHostPort)) {
-      flinkConfiguration.set(TaskManagerOptions.MANAGED_MEMORY_SIZE, MemorySize.parse("2048m"));
+      flinkConfiguration.setString("taskmanager.memory.managed.size", "2048m");
       flinkBatchEnv = ExecutionEnvironment.createLocalEnvironment(flinkConfiguration);
     } else if ("[collection]".equals(flinkMasterHostPort)) {
       flinkBatchEnv = new CollectionEnvironment();