METHOD_0 ( ) { int IDENT_0 = 5 ; int IDENT_1 = 1 ; for ( int IDENT_2 = 0 ; IDENT_2 < IDENT_0 ; IDENT_2 ++ ) { try { org . apache . flink . streaming . api . IDENT_3 . IDENT_4 IDENT_5 = org . apache . flink . streaming . api . IDENT_3 . IDENT_4 . METHOD_1 ( ) ; org . apache . flink . test . streaming . runtime . IDENT_6 . IDENT_7 = new boolean [ IDENT_8 ] ; org . apache . flink . streaming . api . IDENT_9 . IDENT_10 < java . lang . Boolean > source = IDENT_5 . METHOD_2 ( java . util . Collections . METHOD_3 ( ( ( IDENT_8 ) * 2 ) , false ) ) . map ( org . apache . flink . test . streaming . runtime . IDENT_6 . IDENT_11 ) . name ( STRING_0 ) ; org . apache . flink . streaming . api . IDENT_9 . IDENT_12 < java . lang . Boolean > IDENT_13 = source . METHOD_4 ( ( INT_0 * IDENT_1 ) ) ; org . apache . flink . streaming . api . IDENT_9 . IDENT_10 < java . lang . Boolean > IDENT_14 = IDENT_13 . METHOD_5 ( new org . apache . flink . test . streaming . runtime . IDENT_6 . METHOD_6 ( ) ) . map ( org . apache . flink . test . streaming . runtime . IDENT_6 . IDENT_11 ) ; IDENT_13 . map ( org . apache . flink . test . streaming . runtime . IDENT_6 . IDENT_11 ) . METHOD_7 ( new org . apache . flink . test . streaming . runtime . util . METHOD_8 ( ) ) ; IDENT_13 . METHOD_9 ( IDENT_14 ) . METHOD_7 ( new org . apache . flink . test . streaming . runtime . util . METHOD_8 ( ) ) ; IDENT_5 . execute ( ) ; for ( boolean IDENT_15 : org . apache . flink . test . streaming . runtime . IDENT_6 . IDENT_7 ) { "<AssertPlaceHolder>" ; } break ; } catch ( java . lang . Throwable t ) { org . apache . flink . test . streaming . runtime . IDENT_6 . LOG . info ( ( ( ( ( STRING_1 + ( IDENT_2 + 1 ) ) + "/" ) + IDENT_0 ) + STRING_2 ) , t ) ; if ( IDENT_2 >= ( IDENT_0 - 1 ) ) { throw t ; } else { IDENT_1 OP_0 2 ; } } } } execute ( ) { return execute ( org . apache . flink . streaming . api . IDENT_3 . IDENT_4 . IDENT_16 ) ; }
org . junit . Assert . assertTrue ( IDENT_15 )