public static YarnHighAvailabilityServices forYarnTaskManager ( Configuration flinkConfig , org . apache . hadoop . conf . Configuration hadoopConfig ) throws IOException { checkNotNull ( flinkConfig , "flinkConfig" ) ; checkNotNull ( hadoopConfig , "hadoopConfig" ) ; final HighAvailabilityMode mode = HighAvailabilityMode . fromConfig ( flinkConfig ) ; switch ( mode ) { case NONE : return new YarnPreConfiguredMasterNonHaServices ( flinkConfig , hadoopConfig , HighAvailabilityServicesUtils . AddressResolution . TRY_ADDRESS_RESOLUTION ) ; case ZOOKEEPER : throw new UnsupportedOperationException ( "to be implemented" ) ; default : throw new IllegalConfigurationException ( "Unrecognized high availability mode: " + mode ) ; } }
Creates the high - availability services for the TaskManagers participating in a Flink YARN application .