METHOD_0 ( ) { org . apache . flink . streaming . api . IDENT_0 . IDENT_1 IDENT_2 = org . apache . flink . streaming . api . IDENT_0 . IDENT_1 . METHOD_1 ( ) ; IDENT_2 . METHOD_2 ( IDENT_3 ) ; IDENT_2 . METHOD_3 ( 1 ) ; org . apache . flink . streaming . api . IDENT_4 . IDENT_5 < java . lang . String > source = IDENT_2 . METHOD_4 ( new org . apache . flink . test . streaming . runtime . IDENT_6 . METHOD_5 ( ) ) ; source . transform ( STRING_0 , IDENT_7 . IDENT_8 , new org . apache . flink . test . streaming . runtime . IDENT_6 . METHOD_6 ( org . apache . flink . streaming . api . IDENT_9 . IDENT_10 . IDENT_11 ) ) ; boolean IDENT_12 = false ; try { IDENT_2 . execute ( STRING_1 ) ; } catch ( org . apache . flink . runtime . client . IDENT_13 e ) { if ( ( e . METHOD_7 ( ) ) instanceof org . apache . flink . streaming . runtime . IDENT_14 . IDENT_15 ) { org . apache . flink . streaming . runtime . IDENT_14 . IDENT_15 IDENT_16 = ( ( org . apache . flink . streaming . runtime . IDENT_14 . IDENT_15 ) ( e . METHOD_7 ( ) ) ) ; if ( ( IDENT_16 . METHOD_7 ( ) ) instanceof java . lang . RuntimeException ) { java . lang . RuntimeException IDENT_17 = ( ( java . lang . RuntimeException ) ( IDENT_16 . METHOD_7 ( ) ) ) ; if ( IDENT_17 . getMessage ( ) . equals ( STRING_2 ) ) { IDENT_12 = true ; } else { throw e ; } } else { throw e ; } } else { throw e ; } } "<AssertPlaceHolder>" ; } equals ( java . lang . Object ) { if ( ( this ) == o ) { return true ; } if ( ( o == null ) || ( ( getClass ( ) ) != ( o . getClass ( ) ) ) ) { return false ; } org . apache . flink . table . utils . IDENT_18 . IDENT_19 IDENT_20 = ( ( org . apache . flink . table . utils . IDENT_18 . IDENT_19 ) ( o ) ) ; return ( ( IDENT_21 ) == ( IDENT_20 . IDENT_21 ) ) && ( java . util . IDENT_22 . equals ( string , IDENT_20 . string ) ) ; }
org . junit . Assert . assertTrue ( IDENT_12 )