METHOD_0 ( ) { java . util . concurrent . IDENT_0 executor = java . util . concurrent . IDENT_1 . METHOD_1 ( 1 ) ; org . apache . flink . configuration . Configuration IDENT_2 = new org . apache . flink . configuration . Configuration ( ) ; IDENT_2 . METHOD_2 ( IDENT_3 . IDENT_4 , STRING_0 ) ; try ( com . IDENT_5 . IDENT_6 . backend . server . IDENT_7 cluster = new com . IDENT_5 . IDENT_6 . backend . server . METHOD_3 ( com . IDENT_5 . IDENT_6 . backend . server . yarn . IDENT_8 . class . METHOD_4 ( ) ) ) { cluster . start ( ) ; org . apache . hadoop . yarn . conf . IDENT_9 conf = cluster . METHOD_5 ( ) ; com . IDENT_5 . IDENT_6 . backend . server . yarn . IDENT_10 IDENT_11 = cluster . METHOD_6 ( ) ; final org . apache . hadoop . yarn . api . records . IDENT_12 IDENT_13 ; try ( org . apache . hadoop . yarn . client . api . IDENT_14 client = org . apache . hadoop . yarn . client . api . IDENT_14 . METHOD_7 ( ) ) { client . init ( conf ) ; client . start ( ) ; com . IDENT_5 . IDENT_6 . backend . server . yarn . IDENT_15 IDENT_16 = new com . IDENT_5 . IDENT_6 . backend . server . yarn . METHOD_8 ( IDENT_11 , client , executor , IDENT_2 ) ; IDENT_13 = IDENT_16 . METHOD_9 ( ) ; com . IDENT_5 . IDENT_6 . backend . server . yarn . IDENT_17 IDENT_18 = new com . IDENT_5 . IDENT_6 . backend . server . yarn . METHOD_10 ( java . util . UUID . METHOD_11 ( ) , java . util . UUID . METHOD_11 ( ) ) ; com . IDENT_5 . IDENT_6 . backend . api . IDENT_19 resource = new com . IDENT_5 . IDENT_6 . backend . api . METHOD_12 ( ) . queue ( null ) . METHOD_13 ( 1L ) . METHOD_14 ( 1L ) . METHOD_15 ( INT_0 ) ; com . IDENT_5 . IDENT_6 . backend . server . yarn . IDENT_20 IDENT_21 = new com . IDENT_5 . IDENT_6 . backend . server . yarn . METHOD_16 ( IDENT_13 , "test" , java . util . Collections . emptyList ( ) , resource , IDENT_18 ) ; IDENT_16 . start ( com . IDENT_5 . IDENT_6 . backend . server . yarn . IDENT_22 . METHOD_17 ( ) , IDENT_21 ) ; org . apache . hadoop . yarn . api . records . IDENT_23 state = com . IDENT_5 . IDENT_6 . backend . server . METHOD_3 . METHOD_18 ( client , IDENT_13 ) ; "<AssertPlaceHolder>" ; } } } METHOD_18 ( org . apache . hadoop . yarn . client . api . IDENT_14 , org . apache . hadoop . yarn . api . records . IDENT_12 ) { java . util . IDENT_24 < org . apache . hadoop . yarn . api . records . IDENT_23 > IDENT_25 = java . util . IDENT_24 . of ( com . IDENT_5 . IDENT_6 . backend . server . IDENT_26 , com . IDENT_5 . IDENT_6 . backend . server . IDENT_27 , com . IDENT_5 . IDENT_6 . backend . server . IDENT_28 ) ; while ( true ) { org . apache . hadoop . yarn . api . records . IDENT_29 report = client . METHOD_19 ( IDENT_13 ) ; org . apache . hadoop . yarn . api . records . IDENT_23 state = report . METHOD_20 ( ) ; if ( IDENT_25 . contains ( state ) ) { return state ; } else { java . lang . Thread . sleep ( INT_1 ) ; } } }
org . junit . Assert . assertEquals ( com . IDENT_5 . IDENT_6 . backend . server . yarn . IDENT_26 , state )