METHOD_0 ( ) { final org . apache . flink . runtime . IDENT_0 . IDENT_1 IDENT_2 = METHOD_1 ( ) ; final org . apache . flink . runtime . IDENT_0 . IDENT_3 IDENT_4 = IDENT_2 . METHOD_2 ( ) ; final org . apache . flink . runtime . IDENT_5 . utils . IDENT_6 IDENT_7 = new org . apache . flink . runtime . IDENT_5 . utils . METHOD_3 ( ) ; final org . apache . flink . runtime . IDENT_5 . IDENT_8 . IDENT_9 IDENT_10 = new org . apache . flink . runtime . IDENT_5 . IDENT_8 . METHOD_4 ( ) ; final java . util . concurrent . IDENT_11 < org . apache . flink . runtime . IDENT_12 . IDENT_13 > IDENT_14 = new java . util . concurrent . METHOD_5 ( ) ; final java . util . concurrent . METHOD_5 < org . apache . flink . runtime . IDENT_12 . IDENT_13 > IDENT_15 = new java . util . concurrent . METHOD_5 ( ) ; final org . apache . flink . runtime . IDENT_5 . IDENT_16 IDENT_17 = new org . apache . flink . runtime . IDENT_5 . METHOD_6 ( ( org . apache . flink . runtime . IDENT_12 . IDENT_13 IDENT_18 ) -> { IDENT_14 . METHOD_7 ( IDENT_18 ) ; return new org . apache . flink . runtime . IDENT_5 . METHOD_5 < > ( ) ; } ) ; IDENT_17 . METHOD_8 ( IDENT_15 :: METHOD_7 ) ; IDENT_10 . METHOD_9 ( ) . METHOD_10 ( ( org . apache . flink . runtime . IDENT_12 . IDENT_19 IDENT_20 ) -> IDENT_15 . METHOD_7 ( IDENT_20 . METHOD_11 ( ) ) ) ; org . apache . flink . runtime . IDENT_5 . IDENT_21 IDENT_22 = org . apache . flink . runtime . IDENT_5 . IDENT_23 . METHOD_12 ( new org . apache . flink . api . common . METHOD_13 ( ) , IDENT_17 , new org . apache . flink . runtime . IDENT_5 . IDENT_24 . METHOD_14 ( ) , IDENT_2 ) ; IDENT_22 . start ( IDENT_25 . METHOD_15 ( ) ) ; org . apache . flink . runtime . IDENT_5 . IDENT_26 IDENT_27 = IDENT_22 . METHOD_16 ( IDENT_4 ) ; org . apache . flink . runtime . IDENT_5 . IDENT_28 IDENT_29 = IDENT_27 . METHOD_17 ( ) [ 0 ] ; final org . apache . flink . runtime . IDENT_5 . IDENT_30 IDENT_31 = IDENT_29 . METHOD_18 ( ) ; IDENT_7 . METHOD_19 ( ( IDENT_32 ) -> { if ( IDENT_31 . METHOD_20 ( ) . equals ( IDENT_32 ) ) { IDENT_31 . METHOD_21 ( ) ; } } ) ; IDENT_14 . METHOD_22 ( ( org . apache . flink . runtime . IDENT_12 . IDENT_13 IDENT_18 ) -> { final org . apache . flink . runtime . IDENT_12 . IDENT_33 . IDENT_34 IDENT_35 = org . apache . flink . runtime . IDENT_5 . IDENT_36 . METHOD_23 ( IDENT_10 , IDENT_7 , IDENT_18 ) ; IDENT_17 . METHOD_7 ( IDENT_18 , IDENT_35 ) ; } , IDENT_25 . METHOD_15 ( ) ) ; final java . util . concurrent . METHOD_5 < java . lang . IDENT_37 > IDENT_38 = IDENT_25 . execute ( ( ) -> IDENT_31 . METHOD_24 ( IDENT_17 , false , IDENT_39 . IDENT_40 , java . util . Collections . METHOD_25 ( ) ) ) ; try { IDENT_38 . get ( ) ; IDENT_25 . execute ( IDENT_31 :: IDENT_41 ) ; } catch ( java . util . concurrent . IDENT_42 IDENT_43 ) { } "<AssertPlaceHolder>" ; } get ( ) { return delegate . get ( ) ; }
org . junit . Assert . assertThat ( IDENT_15 . get ( ) , org . hamcrest . Matchers . is ( org . hamcrest . Matchers . equalTo ( IDENT_14 . get ( ) ) ) )