METHOD_0 ( ) { org . apache . flink . util . IDENT_0 < java . lang . Integer > IDENT_1 = new org . apache . flink . util . IDENT_0 < java . lang . Integer > ( STRING_0 ) { } ; org . apache . flink . streaming . api . IDENT_2 . IDENT_3 . IDENT_4 < java . lang . Integer , org . apache . flink . streaming . api . IDENT_2 . IDENT_5 . IDENT_6 > IDENT_7 = org . apache . flink . streaming . runtime . IDENT_8 . IDENT_2 . IDENT_9 . METHOD_1 ( ) ; org . apache . flink . streaming . api . IDENT_2 . IDENT_10 . IDENT_11 < java . lang . Integer , org . apache . flink . streaming . api . IDENT_2 . IDENT_5 . IDENT_6 > IDENT_12 = org . apache . flink . streaming . runtime . IDENT_8 . IDENT_2 . IDENT_9 . METHOD_2 ( ) ; org . apache . flink . streaming . runtime . IDENT_8 . IDENT_2 . IDENT_13 . IDENT_14 < java . lang . IDENT_15 < java . lang . Integer > , java . lang . IDENT_16 , java . lang . Integer , org . apache . flink . streaming . api . IDENT_2 . IDENT_5 . IDENT_6 > IDENT_17 = org . apache . flink . streaming . runtime . IDENT_8 . IDENT_2 . IDENT_9 . METHOD_3 ( ) ; org . apache . flink . streaming . util . IDENT_18 < java . lang . Integer , java . lang . IDENT_16 > IDENT_19 = METHOD_4 ( IDENT_7 , METHOD_2 , 0L , METHOD_3 , IDENT_1 ) ; IDENT_19 . METHOD_5 ( ) ; when ( IDENT_7 . METHOD_6 ( METHOD_7 ( ) , METHOD_8 ( ) , org . apache . flink . streaming . runtime . IDENT_8 . IDENT_2 . IDENT_9 . METHOD_9 ( ) ) ) . thenReturn ( java . util . Collections . < org . apache . flink . streaming . api . IDENT_2 . IDENT_5 . IDENT_6 > emptyList ( ) ) ; IDENT_19 . METHOD_10 ( 0 ) ; IDENT_19 . METHOD_11 ( new org . apache . flink . streaming . runtime . IDENT_20 . METHOD_12 ( 0 , INT_0 ) ) ; verify ( IDENT_7 , times ( 1 ) ) . METHOD_6 ( eq ( 0 ) , eq ( INT_0 ) , org . apache . flink . streaming . runtime . IDENT_8 . IDENT_2 . IDENT_9 . METHOD_9 ( ) ) ; "<AssertPlaceHolder>" ; } METHOD_13 ( org . apache . flink . util . IDENT_0 ) { if ( IDENT_21 ) { throw new java . lang . METHOD_14 ( ( STRING_1 + STRING_2 ) ) ; } IDENT_22 = METHOD_15 ( METHOD_16 ( IDENT_22 ) ) ; IDENT_22 = new org . apache . flink . util . IDENT_0 < IDENT_23 > ( IDENT_22 . getId ( ) , IDENT_22 . METHOD_17 ( ) ) ; org . apache . flink . api . common . IDENT_24 . IDENT_25 < ? > type = IDENT_26 . get ( IDENT_22 ) ; if ( ( type != null ) && ( ! ( type . equals ( IDENT_22 . METHOD_17 ( ) ) ) ) ) { throw new java . lang . METHOD_14 ( ( STRING_3 + ( STRING_4 + STRING_5 ) ) ) ; } IDENT_26 . put ( IDENT_22 , IDENT_22 . METHOD_17 ( ) ) ; org . apache . flink . streaming . api . IDENT_27 . IDENT_28 < IDENT_23 > IDENT_29 = new org . apache . flink . streaming . api . IDENT_27 . METHOD_18 ( this . METHOD_19 ( ) , IDENT_22 ) ; return new org . apache . flink . streaming . api . IDENT_30 . METHOD_20 ( this . METHOD_21 ( ) , IDENT_29 ) ; }
org . junit . Assert . assertTrue ( ( ( ( IDENT_19 . METHOD_13 ( IDENT_1 ) ) == null ) || ( IDENT_19 . METHOD_13 ( IDENT_1 ) . isEmpty ( ) ) ) )