METHOD_0 ( ) { java . lang . String IDENT_0 = STRING_0 ; java . lang . String IDENT_1 = STRING_1 ; com . IDENT_2 . nifi . v2 . spark . IDENT_3 IDENT_4 = new com . IDENT_2 . nifi . v2 . spark . METHOD_1 ( IDENT_0 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_6 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_7 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_8 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_9 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_10 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_11 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_12 ) ; java . lang . Thread IDENT_13 = new java . lang . Thread ( IDENT_4 ) ; com . IDENT_2 . nifi . v2 . spark . METHOD_1 IDENT_14 = new com . IDENT_2 . nifi . v2 . spark . METHOD_1 ( IDENT_1 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_6 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_7 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_8 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_9 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_10 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_11 , com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_12 ) ; java . lang . Thread IDENT_15 = new java . lang . Thread ( IDENT_14 ) ; IDENT_13 . start ( ) ; IDENT_15 . start ( ) ; IDENT_13 . join ( ) ; IDENT_15 . join ( ) ; boolean IDENT_16 = com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_12 . METHOD_2 ( IDENT_0 ) ; boolean IDENT_17 = com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_12 . METHOD_2 ( IDENT_1 ) ; com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_12 . METHOD_3 ( IDENT_0 ) ; com . IDENT_2 . nifi . v2 . spark . IDENT_5 . IDENT_12 . METHOD_3 ( IDENT_1 ) ; "<AssertPlaceHolder>" ; } METHOD_3 ( java . lang . String ) { java . lang . Boolean IDENT_18 = ! ( METHOD_2 ( IDENT_19 ) ) ; if ( ! IDENT_18 ) { try { MOD_0 ( IDENT_20 ) { if ( IDENT_20 . containsKey ( IDENT_19 ) ) { IDENT_18 = client . METHOD_3 ( METHOD_4 ( IDENT_19 ) ) ; if ( IDENT_18 ) { IDENT_20 . remove ( IDENT_19 ) ; METHOD_5 ( ) . info ( STRING_2 , new java . lang . Object [ ] { METHOD_4 ( IDENT_19 ) , IDENT_21 } ) ; } } } } catch ( java . lang . Exception ex ) { METHOD_5 ( ) . trace ( ex . getMessage ( ) , ex ) ; } } return IDENT_18 ; }
org . junit . Assert . assertTrue ( ( IDENT_16 && IDENT_17 ) )