METHOD_0 ( ) { IDENT_0 . METHOD_1 ( true ) ; when ( IDENT_1 . METHOD_2 ( ) ) . thenReturn ( new int [ ] { 0 , 10 } ) ; when ( IDENT_2 . METHOD_3 ( eq ( IDENT_0 . METHOD_4 ( ) ) , eq ( IDENT_3 . IDENT_4 . IDENT_5 ) , eq ( new java . util . ArrayList < java . lang . String > ( ) ) , eq ( ( ( java . lang . String ) ( null ) ) ) , eq ( IDENT_6 ) , eq ( IDENT_0 ) , eq ( ( ( org . pentaho . di . core . logging . IDENT_7 ) ( null ) ) ) ) ) . thenReturn ( IDENT_1 ) ; "<AssertPlaceHolder>" ; verify ( result ) . METHOD_5 ( true ) ; verify ( result ) . METHOD_6 ( 10 ) ; verify ( result ) . METHOD_7 ( false ) ; } execute ( org . pentaho . di . core . Result , int ) { if ( ! ( validate ( ) ) ) { result . METHOD_7 ( false ) ; return result ; } try { java . util . List < java . lang . String > IDENT_8 = METHOD_8 ( ) ; METHOD_9 ( STRING_0 ) ; if ( log . METHOD_10 ( ) ) { METHOD_11 ( IDENT_8 . toString ( ) ) ; } java . lang . IDENT_9 IDENT_10 = new java . lang . METHOD_12 ( IDENT_8 ) ; java . util . Map < java . lang . String , java . lang . String > IDENT_11 = IDENT_10 . METHOD_13 ( ) ; java . lang . String [ ] IDENT_12 = METHOD_14 ( ) ; for ( java . lang . String IDENT_13 : IDENT_12 ) { IDENT_11 . put ( IDENT_13 , METHOD_15 ( IDENT_13 ) ) ; } IDENT_14 = IDENT_10 . start ( ) ; java . lang . String [ ] IDENT_15 = new java . lang . String [ ] { STRING_1 } ; final java . util . concurrent . atomic . IDENT_16 IDENT_17 = new java . util . concurrent . atomic . METHOD_16 ( false ) ; org . pentaho . di . job . IDENT_18 . spark . IDENT_19 IDENT_20 = new org . pentaho . di . job . IDENT_18 . spark . METHOD_17 ( log , IDENT_14 . METHOD_18 ( ) , IDENT_15 , IDENT_17 ) ; org . pentaho . di . job . IDENT_18 . spark . METHOD_17 IDENT_21 = new org . pentaho . di . job . IDENT_18 . spark . METHOD_17 ( log , IDENT_14 . METHOD_19 ( ) , IDENT_15 , IDENT_17 ) ; if ( ! ( IDENT_22 ) ) { org . pentaho . di . job . IDENT_18 . spark . METHOD_17 . IDENT_23 cb = new org . pentaho . di . job . IDENT_18 . spark . METHOD_17 . METHOD_20 ( ) { @ org . pentaho . di . job . IDENT_18 . spark . Override public void METHOD_21 ( java . lang . String pattern ) { log . METHOD_22 ( STRING_2 ) ; IDENT_17 . set ( true ) ; IDENT_14 . METHOD_23 ( ) ; } } ; IDENT_20 . METHOD_24 ( cb ) ; IDENT_21 . METHOD_24 ( cb ) ; } java . lang . Thread IDENT_24 = new java . lang . Thread ( IDENT_20 ) ; IDENT_24 . start ( ) ; java . lang . Thread IDENT_25 = new java . lang . Thread ( IDENT_21 ) ; IDENT_25 . start ( ) ; final java . util . concurrent . atomic . METHOD_16 IDENT_26 = new java . util . concurrent . atomic . METHOD_16 ( false ) ; new java . lang . Thread ( new java . lang . METHOD_25 ( ) { @ org . pentaho . di . job . IDENT_18 . spark . Override public void run ( ) { while ( ( ! ( METHOD_26 ( ) . METHOD_27 ( ) ) ) && ( ! ( IDENT_26 . get ( ) ) ) ) { try { java . lang . Thread . sleep ( INT_0 ) ; } catch ( java . lang . IDENT_27 e ) { e . printStackTrace ( ) ; } } IDENT_14 . METHOD_23 ( ) ; } } ) . start ( ) ; IDENT_14 . METHOD_28 ( ) ; IDENT_26 . set ( true ) ; METHOD_29 ( IDENT_14 , IDENT_24 , IDENT_25 ) ; if ( log . METHOD_10 ( ) ) { METHOD_11 ( STRING_3 ) ; } int IDENT_28 ; if ( IDENT_22 ) { IDENT_28 = IDENT_14 . METHOD_30 ( ) ; } else { IDENT_28 = ( IDENT_17 . get ( ) ) ? 0 : IDENT_14 . METHOD_30 ( ) ; } result . METHOD_31 ( IDENT_28 ) ; if ( IDENT_28 != 0 ) { if ( log . METHOD_10 ( ) ) { METHOD_11 ( org . pentaho . di . IDENT_29 . IDENT_30 . getString ( org . pentaho . di . job . IDENT_18 . spark . IDENT_31 . IDENT_32 , STRING_4 , result . METHOD_32 ( ) ) ) ; } result . METHOD_6 ( 1 ) ; } result . METHOD_7 ( ( IDENT_28 == 0 ) ) ; } catch ( java . lang . Exception e ) { result . METHOD_6 ( 1 ) ; METHOD_33 ( org . pentaho . di . IDENT_29 . IDENT_30 . getString ( org . pentaho . di . job . IDENT_18 . spark . IDENT_31 . IDENT_32 , STRING_5 , e . getMessage ( ) ) ) ; METHOD_33 ( org . pentaho . di . core . IDENT_33 . METHOD_34 ( e ) ) ; result . METHOD_7 ( false ) ; } return result ; }
org . junit . Assert . assertEquals ( result , IDENT_0 . execute ( result , 0 ) )