METHOD_0 ( ) { runner . setProperty ( IDENT_0 . IDENT_1 , STRING_0 ) ; runner . setProperty ( IDENT_0 . IDENT_2 , STRING_1 ) ; runner . setProperty ( IDENT_0 . IDENT_3 , STRING_2 ) ; processor . IDENT_4 = mock ( org . apache . hadoop . security . IDENT_5 . class ) ; runner . run ( ) ; "<AssertPlaceHolder>" ; } run ( ) { try { final org . apache . nifi . remote . client . IDENT_6 client = new org . apache . nifi . remote . client . IDENT_6 . Builder ( ) . METHOD_1 ( IDENT_7 ) . build ( ) ; try { while ( ! ( METHOD_2 ( ) ) ) { final org . apache . nifi . remote . IDENT_8 transaction = client . METHOD_3 ( IDENT_9 . IDENT_10 ) ; org . apache . nifi . remote . protocol . IDENT_11 IDENT_12 = transaction . METHOD_4 ( ) ; if ( IDENT_12 == null ) { transaction . METHOD_5 ( ) ; transaction . METHOD_6 ( ) ; try { java . lang . Thread . sleep ( INT_0 ) ; } catch ( java . lang . IDENT_13 e ) { } continue ; } final java . util . List < org . apache . nifi . spark . IDENT_14 > IDENT_15 = new java . util . ArrayList ( ) ; do { final java . io . InputStream IDENT_16 = IDENT_12 . METHOD_7 ( ) ; final byte [ ] data = new byte [ ( ( int ) ( IDENT_12 . METHOD_8 ( ) ) ) ] ; org . apache . nifi . stream . io . IDENT_17 . METHOD_9 ( IDENT_16 , data ) ; final java . util . Map < java . lang . String , java . lang . String > attributes = IDENT_12 . METHOD_10 ( ) ; final org . apache . nifi . spark . IDENT_14 IDENT_14 = new org . apache . nifi . spark . METHOD_11 ( data , attributes ) ; IDENT_15 . add ( IDENT_14 ) ; IDENT_12 = transaction . METHOD_4 ( ) ; } while ( IDENT_12 != null ) ; transaction . METHOD_5 ( ) ; store ( IDENT_15 . iterator ( ) ) ; transaction . METHOD_6 ( ) ; } } finally { try { client . close ( ) ; } catch ( final java . io . IOException IDENT_18 ) { METHOD_12 ( STRING_3 , IDENT_18 ) ; } } } catch ( final java . io . IOException IDENT_18 ) { METHOD_13 ( STRING_4 , IDENT_18 ) ; } }
org . junit . Assert . assertNull ( processor . IDENT_4 )