METHOD_0 ( ) { org . apache . flink . streaming . IDENT_0 . redis . common . container . IDENT_1 IDENT_2 = org . apache . flink . streaming . IDENT_0 . redis . common . container . IDENT_3 . build ( IDENT_4 ) ; redis . IDENT_5 . IDENT_6 . IDENT_7 IDENT_6 = null ; try { IDENT_6 = IDENT_8 . getResource ( ) ; IDENT_2 . set ( org . apache . flink . streaming . IDENT_0 . redis . IDENT_9 . IDENT_10 , org . apache . flink . streaming . IDENT_0 . redis . IDENT_9 . IDENT_11 ) ; "<AssertPlaceHolder>" ; } finally { if ( IDENT_6 != null ) { IDENT_6 . close ( ) ; } } } set ( java . lang . String , java . lang . String ) { try { IDENT_12 . set ( key , value ) ; } catch ( java . lang . Exception e ) { if ( org . apache . flink . streaming . IDENT_0 . redis . common . container . IDENT_13 . LOG . METHOD_1 ( ) ) { org . apache . flink . streaming . IDENT_0 . redis . common . container . IDENT_13 . LOG . error ( STRING_0 , key , e . getMessage ( ) ) ; } throw e ; } }
org . junit . Assert . assertEquals ( org . apache . flink . streaming . IDENT_0 . redis . IDENT_9 . IDENT_11 , IDENT_6 . get ( org . apache . flink . streaming . IDENT_0 . redis . IDENT_9 . IDENT_10 ) )