METHOD_0 ( ) { final java . net . IDENT_0 server = new java . net . METHOD_1 ( 0 ) ; final int port = server . METHOD_2 ( ) ; final java . util . concurrent . atomic . IDENT_1 < java . lang . Throwable > error = new java . util . concurrent . atomic . IDENT_1 < java . lang . Throwable > ( ) ; java . lang . Thread IDENT_2 = new java . lang . Thread ( STRING_0 ) { @ org . apache . flink . streaming . api . IDENT_3 . IDENT_4 . Override public void run ( ) { try { org . apache . flink . streaming . api . IDENT_3 . IDENT_4 . IDENT_5 < java . lang . String > IDENT_6 = new org . apache . flink . streaming . api . IDENT_3 . IDENT_4 . METHOD_3 ( org . apache . flink . streaming . api . IDENT_3 . IDENT_4 . IDENT_7 . host , port , IDENT_8 , 0 ) ; IDENT_6 . METHOD_4 ( new org . apache . flink . configuration . Configuration ( ) ) ; IDENT_6 . invoke ( ( ( org . apache . flink . streaming . api . IDENT_3 . IDENT_4 . IDENT_7 . IDENT_9 ) + STRING_1 ) , org . apache . flink . streaming . api . IDENT_3 . IDENT_4 . IDENT_10 . METHOD_5 ( 0 ) ) ; IDENT_6 . close ( ) ; } catch ( java . lang . Throwable t ) { error . set ( t ) ; } } } ; IDENT_2 . start ( ) ; java . net . IDENT_11 IDENT_12 = server . accept ( ) ; java . io . IDENT_13 IDENT_14 = new java . io . METHOD_6 ( new java . io . METHOD_7 ( IDENT_12 . METHOD_8 ( ) ) ) ; java . lang . String value = IDENT_14 . METHOD_9 ( ) ; IDENT_2 . join ( ) ; server . close ( ) ; if ( ( error . get ( ) ) != null ) { java . lang . Throwable t = error . get ( ) ; t . printStackTrace ( ) ; org . junit . Assert . fail ( ( STRING_2 + ( t . getMessage ( ) ) ) ) ; } "<AssertPlaceHolder>" ; } getMessage ( ) { return message ; }
org . junit . Assert . assertEquals ( org . apache . flink . streaming . api . IDENT_3 . IDENT_4 . IDENT_7 . IDENT_9 , value )