METHOD_0 ( ) { final java . util . concurrent . IDENT_0 exec = java . util . concurrent . IDENT_1 . METHOD_1 ( 2 ) ; final org . apache . druid . query . IDENT_2 . IDENT_3 . IDENT_4 IDENT_5 = new org . apache . druid . query . IDENT_2 . IDENT_3 . METHOD_2 ( new org . apache . druid . query . filter . METHOD_3 ( "foo" , "1" , null ) , null ) ; final java . util . List < java . util . concurrent . IDENT_6 < ? > > IDENT_7 = new java . util . ArrayList ( ) ; for ( int i = 0 ; i < 2 ; i ++ ) { final org . apache . druid . data . input . IDENT_8 row = new org . apache . druid . data . input . METHOD_4 ( 0 , com . google . common . collect . ImmutableMap . of ( "foo" , java . lang . String . valueOf ( i ) ) ) ; IDENT_7 . add ( exec . METHOD_5 ( new java . lang . METHOD_6 ( ) { @ org . apache . druid . query . IDENT_2 . IDENT_3 . Override public void run ( ) { IDENT_5 . METHOD_7 ( null ) ; while ( ! ( java . lang . Thread . METHOD_8 ( ) ) ) { IDENT_5 . METHOD_9 ( row ) ; } } } ) ) ; } IDENT_9 . expect ( java . util . concurrent . IDENT_10 . class ) ; IDENT_9 . METHOD_10 ( org . hamcrest . CoreMatchers . < java . lang . IllegalStateException > METHOD_11 ( org . apache . druid . query . IDENT_2 . IDENT_3 . IllegalStateException . class ) ) ; IDENT_9 . METHOD_10 ( org . junit . internal . matchers . IDENT_11 . METHOD_12 ( org . hamcrest . CoreMatchers . METHOD_13 ( STRING_0 ) ) ) ; try { for ( java . util . concurrent . IDENT_6 < ? > future : IDENT_7 ) { future . get ( ) ; } } finally { exec . METHOD_14 ( ) ; } "<AssertPlaceHolder>" ; } METHOD_14 ( ) { return delegate . METHOD_14 ( ) ; }
org . junit . Assert . assertTrue ( false )