|
Change Variable Type preferredFQHostNames : HashSet<String> to preferredFQHostNames : Map<String,Integer> in method public findMatchWithLocality(candidates Stream<IN>, contextExtractor Function<IN,SlotContext>, additionalRequirementsFilter Predicate<IN>, resultProducer BiFunction<IN,Locality,OUT>) : OUT in class org.apache.flink.runtime.clusterframework.types.SlotProfile.LocalityAwareRequirementsToSlotMatcher |
From |
To |
|
Change Variable Type preferredResourceIDs : HashSet<ResourceID> to preferredResourceIDs : Map<ResourceID,Integer> in method public findMatchWithLocality(candidates Stream<IN>, contextExtractor Function<IN,SlotContext>, additionalRequirementsFilter Predicate<IN>, resultProducer BiFunction<IN,Locality,OUT>) : OUT in class org.apache.flink.runtime.clusterframework.types.SlotProfile.LocalityAwareRequirementsToSlotMatcher |
From |
To |