public static void persistUpdatedPackingPlan ( String topologyName , PackingPlan updatedPackingPlan , SchedulerStateManagerAdaptor stateManager ) { LOG . log ( Level . INFO , "Updating scheduled-resource in packing plan: {0}" , topologyName ) ; PackingPlanProtoSerializer serializer = new PackingPlanProtoSerializer ( ) ; if ( ! stateManager . updatePackingPlan ( serializer . toProto ( updatedPackingPlan ) , topologyName ) ) { throw new RuntimeException ( String . format ( "Failed to update packing plan for topology %s" , topologyName ) ) ; } }
Replaces persisted packing plan in state manager .