METHOD_0 ( ) { final long IDENT_0 = java . lang . System . currentTimeMillis ( ) ; org . apache . flink . runtime . IDENT_1 . IDENT_2 IDENT_3 = org . apache . flink . runtime . IDENT_4 . IDENT_5 . METHOD_1 ( new org . apache . flink . runtime . IDENT_1 . METHOD_2 ( ) ) ; org . apache . flink . runtime . IDENT_4 . IDENT_6 IDENT_7 = new org . apache . flink . runtime . IDENT_4 . METHOD_3 ( new org . apache . flink . api . common . METHOD_4 ( ) , INT_0 , INT_0 , 0 , Integer . MAX_VALUE , IDENT_8 . IDENT_9 , new org . apache . flink . runtime . IDENT_1 . IDENT_2 [ ] { IDENT_3 } , new org . apache . flink . runtime . IDENT_1 . IDENT_2 [ ] { IDENT_3 } , new org . apache . flink . runtime . IDENT_1 . IDENT_2 [ ] { IDENT_3 } , new org . apache . flink . runtime . IDENT_4 . METHOD_5 ( ) , new org . apache . flink . runtime . IDENT_4 . METHOD_6 ( 1 ) , new org . apache . flink . runtime . state . IDENT_10 . METHOD_7 ( ) , org . apache . flink . runtime . concurrent . IDENT_11 . METHOD_8 ( ) , org . apache . flink . runtime . state . IDENT_12 . IDENT_13 ) ; org . apache . flink . runtime . IDENT_4 . IDENT_14 IDENT_15 = mock ( org . apache . flink . runtime . IDENT_4 . IDENT_14 . class ) ; IDENT_7 . METHOD_9 ( IDENT_15 ) ; when ( IDENT_15 . METHOD_10 ( METHOD_11 ( ) , METHOD_11 ( ) , any ( org . apache . flink . runtime . IDENT_4 . IDENT_16 . class ) ) ) . thenReturn ( mock ( org . apache . flink . runtime . IDENT_4 . IDENT_17 . class ) ) ; "<AssertPlaceHolder>" ; verify ( IDENT_15 , times ( 1 ) ) . METHOD_10 ( eq ( 1L ) , eq ( IDENT_0 ) , eq ( org . apache . flink . runtime . IDENT_4 . IDENT_16 . METHOD_12 ( IDENT_8 . IDENT_9 ) ) ) ; } METHOD_13 ( long , boolean ) { return METHOD_13 ( IDENT_0 , IDENT_18 , null , IDENT_19 , false ) . METHOD_14 ( ) ; }
org . junit . Assert . assertTrue ( IDENT_7 . METHOD_13 ( IDENT_0 , false ) )