from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/FilterDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CrossStreamOuterFirstDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/ReduceProperties.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/NoOpDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashLeftOuterJoinBuildFirstDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashRightOuterJoinBuildFirstDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceProperties.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/SortMergeLeftOuterJoinDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashFullOuterJoinBuildFirstDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CoGroupRawDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CoGroupDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashRightOuterJoinBuildSecondDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupCombineProperties.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AllReduceProperties.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/SortMergeInnerJoinDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashJoinBuildFirstProperties.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AllGroupReduceProperties.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/BinaryUnionOpDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CoGroupWithSolutionSetFirstDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CrossStreamOuterSecondDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashFullOuterJoinBuildSecondDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/MapDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AllGroupWithPartialPreGroupProperties.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/SortMergeRightOuterJoinDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashLeftOuterJoinBuildSecondDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/FlatMapDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/HashJoinBuildSecondProperties.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/MapPartitionDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/UtilSinkJoinOpDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AllGroupCombineProperties.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CrossBlockOuterFirstDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/SolutionSetDeltaOperator.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/GroupReduceWithCombineProperties.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/SortMergeFullOuterJoinDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/PartialGroupProperties.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/AbstractOperatorDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/operators/CrossBlockOuterSecondDescriptor.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/RangePartitionRewriter.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/PlanFinalizer.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/BinaryUnionReplacer.java" contains "import org.apache.flink.runtime.operators.util.LocalStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/traversals/UnionParallelismAndForwardEnforcer.java" contains "import org.apache.flink.runtime.operators.shipping.ShipStrategyType;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/BulkPartialSolutionPlanNode.java" contains "import org.apache.flink.runtime.operators.DamBehavior;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/SingleInputPlanNode.java" contains "import org.apache.flink.runtime.operators.DamBehavior;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/BinaryUnionPlanNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/DualInputPlanNode.java" contains "import org.apache.flink.runtime.operators.DamBehavior;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/WorksetPlanNode.java" contains "import org.apache.flink.runtime.operators.DamBehavior;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/SinkPlanNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/NAryUnionPlanNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/PlanNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/SolutionSetPlanNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/BulkIterationPlanNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/WorksetIterationPlanNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/SourcePlanNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/SinkJoinerPlanNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plan/Channel.java" contains "import org.apache.flink.runtime.operators.util.LocalStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/BulkIterationNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/WorksetIterationNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/PartitionNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/SortPartitionNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/TwoInputNode.java" contains "import org.apache.flink.runtime.operators.DamBehavior;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/ReduceNode.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/DagConnection.java" contains "import org.apache.flink.runtime.operators.shipping.ShipStrategyType;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/OptimizerNode.java" contains "import org.apache.flink.runtime.operators.shipping.ShipStrategyType;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/BinaryUnionNode.java" contains "import org.apache.flink.runtime.operators.shipping.ShipStrategyType;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dag/SingleInputNode.java" contains "import org.apache.flink.runtime.operators.shipping.ShipStrategyType;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/postpass/JavaApiPostPass.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JobGraphGenerator.java" contains "import org.apache.flink.runtime.jobgraph.DistributionPattern;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plantranslate/JsonMapper.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/RequestedLocalProperties.java" contains "import org.apache.flink.runtime.operators.util.LocalStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/GlobalProperties.java" contains "import org.apache.flink.runtime.operators.shipping.ShipStrategyType;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/dataproperties/RequestedGlobalProperties.java" contains "import org.apache.flink.runtime.operators.shipping.ShipStrategyType;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/PlanJSONDumpGenerator.java" contains "import org.apache.flink.runtime.operators.DriverStrategy;" from: flink-optimizer to: flink-runtime evidence: - file: "flink-optimizer/src/main/java/org/apache/flink/optimizer/plandump/DumpableConnection.java" contains "import org.apache.flink.runtime.operators.shipping.ShipStrategyType;"