@@ -157,22 +157,22 @@ public void testExecuteQueryAsyncWithListener() throws TajoException, IOExceptio
157157 final AtomicBoolean success = new AtomicBoolean (false );
158158 final List <ResultSet > resultContainer = Lists .newArrayList ();
159159
160- future .addListener (future1 -> {
160+ future .addListener (queryFuture -> {
161161 try {
162- ResultSet result = future1 .get ();
162+ ResultSet result = queryFuture .get ();
163163 resultContainer .add (result ); // for better error handling, it should be verified outside this future.
164164
165- assertTrue (future1 .isDone ());
166- assertEquals (QueryState .COMPLETED , future1 .state ());
167- assertTrue (future1 .isSuccessful ());
168- assertFalse (future1 .isFailed ());
169- assertFalse (future1 .isKilled ());
170- assertTrue (1.0f == future1 .progress ());
171- assertEquals ("default" , future1 .queue ());
172-
173- assertTrue (future1 .submitTime () > 0 );
174- assertTrue (future1 .startTime () > 0 );
175- assertTrue (future1 .finishTime () > 0 );
165+ assertTrue (queryFuture .isDone ());
166+ assertEquals (QueryState .COMPLETED , queryFuture .state ());
167+ assertTrue (queryFuture .isSuccessful ());
168+ assertFalse (queryFuture .isFailed ());
169+ assertFalse (queryFuture .isKilled ());
170+ assertTrue (1.0f == queryFuture .progress ());
171+ assertEquals ("default" , queryFuture .queue ());
172+
173+ assertTrue (queryFuture .submitTime () > 0 );
174+ assertTrue (queryFuture .startTime () > 0 );
175+ assertTrue (queryFuture .finishTime () > 0 );
176176
177177 success .set (true );
178178
0 commit comments