METHOD_0 ( ) { final org . apache . flink . streaming . IDENT_0 . IDENT_1 < java . lang . Long > iterator = new org . apache . flink . streaming . IDENT_0 . METHOD_1 ( org . apache . flink . api . common . IDENT_2 . base . IDENT_3 . INSTANCE ) ; new java . lang . Thread ( ) { @ org . apache . flink . streaming . IDENT_0 . Override public void run ( ) { try { java . lang . Thread . sleep ( 100 ) ; } catch ( java . lang . IDENT_4 IDENT_5 ) { } iterator . METHOD_2 ( new java . lang . Exception ( "test" ) ) ; } } . start ( ) ; try { iterator . hasNext ( ) ; } catch ( java . lang . Exception e ) { "<AssertPlaceHolder>" ; } } METHOD_3 ( ) { return IDENT_6 ; }
org . junit . Assert . assertTrue ( e . METHOD_3 ( ) . getMessage ( ) . contains ( "test" ) )