METHOD_0 ( ) { io . cdap . cdap . IDENT_0 . id . IDENT_1 IDENT_2 = new io . cdap . cdap . IDENT_0 . id . METHOD_1 ( STRING_0 , STRING_1 , io . cdap . cdap . IDENT_0 . IDENT_3 . IDENT_4 , "test" , io . cdap . cdap . common . app . IDENT_5 . METHOD_2 ( ) . getId ( ) ) ; io . cdap . cdap . app . runtime . spark . IDENT_6 . IDENT_7 service = new io . cdap . cdap . app . runtime . spark . IDENT_6 . METHOD_3 ( io . cdap . cdap . app . runtime . spark . IDENT_6 . IDENT_8 . IDENT_9 , java . net . IDENT_10 . METHOD_4 ( ) . METHOD_5 ( ) , IDENT_2 , null ) ; service . METHOD_6 ( ) ; try { final io . cdap . cdap . app . runtime . spark . IDENT_6 . IDENT_11 client = new io . cdap . cdap . app . runtime . spark . IDENT_6 . METHOD_7 ( service . METHOD_8 ( ) , IDENT_2 ) ; for ( int i = 0 ; i < 5 ; i ++ ) { "<AssertPlaceHolder>" ; TimeUnit . IDENT_12 . sleep ( 50 ) ; } com . google . common . util . concurrent . IDENT_13 < com . google . common . util . concurrent . IDENT_14 . IDENT_15 > IDENT_16 = service . METHOD_9 ( ) ; io . cdap . cdap . common . utils . IDENT_17 . METHOD_10 ( IDENT_18 . IDENT_19 , new java . util . concurrent . IDENT_20 < io . cdap . cdap . app . runtime . spark . IDENT_6 . IDENT_18 > ( ) { @ io . cdap . cdap . app . runtime . spark . IDENT_6 . Override public io . cdap . cdap . app . runtime . spark . IDENT_6 . IDENT_18 call ( ) throws io . cdap . cdap . app . runtime . spark . IDENT_6 . Exception { return client . METHOD_11 ( null ) ; } } , 10 , TimeUnit . IDENT_21 , 100 , TimeUnit . IDENT_12 ) ; client . METHOD_12 ( null ) ; IDENT_16 . get ( 5 , TimeUnit . IDENT_21 ) ; } finally { service . METHOD_13 ( ) ; } } METHOD_11 ( io . cdap . cdap . internal . app . runtime . IDENT_22 . IDENT_23 ) { java . net . IDENT_24 IDENT_25 = METHOD_14 ( STRING_2 ) ; try { IDENT_25 . METHOD_15 ( STRING_3 ) ; METHOD_16 ( IDENT_26 , IDENT_25 ) ; METHOD_17 ( IDENT_25 ) ; try ( java . io . IDENT_27 reader = new java . io . METHOD_18 ( IDENT_25 . METHOD_19 ( ) , com . google . common . base . IDENT_28 . UTF_8 ) ) { return io . cdap . cdap . app . runtime . spark . IDENT_6 . METHOD_7 . IDENT_29 . METHOD_20 ( reader , io . cdap . cdap . app . runtime . spark . IDENT_6 . IDENT_18 . class ) ; } } finally { IDENT_25 . METHOD_21 ( ) ; } }
org . junit . Assert . assertNull ( client . METHOD_11 ( null ) )