METHOD_0 ( ) { int IDENT_0 = 3 ; int IDENT_1 = INT_0 ; org . apache . flink . runtime . IDENT_2 . IDENT_3 [ ] IDENT_4 = new org . apache . flink . runtime . IDENT_2 . IDENT_3 [ IDENT_0 ] ; org . apache . flink . runtime . IDENT_2 . IDENT_5 [ ] IDENT_6 = new org . apache . flink . runtime . IDENT_2 . IDENT_5 [ IDENT_0 ] ; org . apache . flink . runtime . IDENT_7 . IDENT_8 IDENT_9 = null ; org . apache . flink . runtime . IDENT_2 . IDENT_10 listener = new org . apache . flink . runtime . IDENT_2 . METHOD_1 ( ) ; try { IDENT_9 = org . apache . flink . runtime . util . IDENT_11 . METHOD_2 ( client , configuration ) ; IDENT_9 . start ( listener ) ; for ( int i = 0 ; i < IDENT_0 ; i ++ ) { IDENT_4 [ i ] = org . apache . flink . runtime . util . IDENT_11 . METHOD_3 ( client , configuration ) ; IDENT_6 [ i ] = new org . apache . flink . runtime . IDENT_2 . METHOD_4 ( ( ( ( ( org . apache . flink . runtime . IDENT_2 . IDENT_12 . IDENT_13 ) + STRING_0 ) + i ) + STRING_1 ) , IDENT_4 [ i ] ) ; IDENT_4 [ i ] . start ( IDENT_6 [ i ] ) ; } java . lang . String pattern = ( ( ( ( org . apache . flink . runtime . IDENT_2 . IDENT_12 . IDENT_13 ) + STRING_0 ) + STRING_2 ) + STRING_0 ) + STRING_2 ; java . util . regex . IDENT_14 regex = java . util . regex . IDENT_14 . METHOD_5 ( pattern ) ; for ( int i = 0 ; i < IDENT_1 ; i ++ ) { listener . METHOD_6 ( org . apache . flink . runtime . IDENT_2 . IDENT_12 . IDENT_15 ) ; java . lang . String address = listener . METHOD_7 ( ) ; java . util . regex . IDENT_16 m = regex . matcher ( address ) ; if ( m . find ( ) ) { int index = java . lang . Integer . METHOD_8 ( m . group ( 1 ) ) ; int IDENT_17 = java . lang . Integer . METHOD_8 ( m . group ( 2 ) ) ; "<AssertPlaceHolder>" ; IDENT_4 [ index ] . METHOD_9 ( ) ; IDENT_4 [ index ] = org . apache . flink . runtime . util . IDENT_11 . METHOD_3 ( client , configuration ) ; IDENT_6 [ index ] = new org . apache . flink . runtime . IDENT_2 . METHOD_4 ( ( ( ( ( ( org . apache . flink . runtime . IDENT_2 . IDENT_12 . IDENT_13 ) + STRING_0 ) + index ) + STRING_0 ) + ( IDENT_17 + 1 ) ) , IDENT_4 [ index ] ) ; IDENT_4 [ index ] . start ( IDENT_6 [ index ] ) ; } else { throw new java . lang . Exception ( STRING_3 ) ; } } } finally { if ( IDENT_9 != null ) { IDENT_9 . METHOD_9 ( ) ; } for ( org . apache . flink . runtime . IDENT_2 . IDENT_3 IDENT_18 : IDENT_4 ) { if ( IDENT_18 != null ) { IDENT_18 . METHOD_9 ( ) ; } } } } METHOD_10 ( ) { return IDENT_19 ; }
org . junit . Assert . assertEquals ( listener . METHOD_10 ( ) , IDENT_6 [ index ] . METHOD_10 ( ) )