You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lens.apache.org by am...@apache.org on 2014/11/19 13:33:38 UTC
incubator-lens git commit: LENS-37 : Fixes intermittent test failure
of TestQueryService.testExecuteAsyncTempTable (Rajat Khandelwal via
amareshwari)
Repository: incubator-lens
Updated Branches:
refs/heads/master 7bee6bceb -> 24653bcfb
LENS-37 : Fixes intermittent test failure of TestQueryService.testExecuteAsyncTempTable (Rajat Khandelwal via amareshwari)
Project: http://git-wip-us.apache.org/repos/asf/incubator-lens/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-lens/commit/24653bcf
Tree: http://git-wip-us.apache.org/repos/asf/incubator-lens/tree/24653bcf
Diff: http://git-wip-us.apache.org/repos/asf/incubator-lens/diff/24653bcf
Branch: refs/heads/master
Commit: 24653bcfb7db05bc3219c89e625f5ef9ba7dd32e
Parents: 7bee6bc
Author: Amareshwari Sriramdasu <am...@inmobi.com>
Authored: Wed Nov 19 18:03:30 2014 +0530
Committer: Amareshwari Sriramdasu <am...@inmobi.com>
Committed: Wed Nov 19 18:03:30 2014 +0530
----------------------------------------------------------------------
.../lens/server/query/TestQueryService.java | 39 ++++++++++++++++++--
1 file changed, 36 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-lens/blob/24653bcf/lens-server/src/test/java/org/apache/lens/server/query/TestQueryService.java
----------------------------------------------------------------------
diff --git a/lens-server/src/test/java/org/apache/lens/server/query/TestQueryService.java b/lens-server/src/test/java/org/apache/lens/server/query/TestQueryService.java
index 38e7d89..da1c6b7 100644
--- a/lens-server/src/test/java/org/apache/lens/server/query/TestQueryService.java
+++ b/lens-server/src/test/java/org/apache/lens/server/query/TestQueryService.java
@@ -1075,9 +1075,42 @@ public class TestQueryService extends LensJerseyTest {
// test post execute op
final WebTarget target = target().path("queryapi/queries");
- final FormDataMultiPart mp = new FormDataMultiPart();
+
+ final FormDataMultiPart drop = new FormDataMultiPart();
LensConf conf = new LensConf();
conf.addProperty(LensConfConstants.QUERY_PERSISTENT_RESULT_INDRIVER, "false");
+ drop.bodyPart(new FormDataBodyPart(FormDataContentDisposition.name("sessionid").build(), lensSessionId,
+ MediaType.APPLICATION_XML_TYPE));
+ drop.bodyPart(new FormDataBodyPart(FormDataContentDisposition.name("query").build(),
+ "drop table if exists temp_output"));
+ drop.bodyPart(new FormDataBodyPart(FormDataContentDisposition.name("operation").build(), "execute"));
+ drop.bodyPart(new FormDataBodyPart(FormDataContentDisposition.name("conf").fileName("conf").build(), conf,
+ MediaType.APPLICATION_XML_TYPE));
+ final QueryHandle dropHandle = target.request().post(Entity.entity(drop, MediaType.MULTIPART_FORM_DATA_TYPE),
+ QueryHandle.class);
+
+ Assert.assertNotNull(dropHandle);
+
+ // Get query
+ LensQuery ctx = target.path(dropHandle.toString()).queryParam("sessionid", lensSessionId).request()
+ .get(LensQuery.class);
+ Assert.assertTrue(ctx.getStatus().getStatus().equals(Status.QUEUED)
+ || ctx.getStatus().getStatus().equals(Status.LAUNCHED) || ctx.getStatus().getStatus().equals(Status.RUNNING)
+ || ctx.getStatus().getStatus().equals(Status.SUCCESSFUL));
+
+ // wait till the query finishes
+ QueryStatus stat = ctx.getStatus();
+ while (!stat.isFinished()) {
+ ctx = target.path(dropHandle.toString()).queryParam("sessionid", lensSessionId).request().get(LensQuery.class);
+ stat = ctx.getStatus();
+ Thread.sleep(1000);
+ }
+ Assert.assertEquals(ctx.getStatus().getStatus(), QueryStatus.Status.SUCCESSFUL);
+
+
+ final FormDataMultiPart mp = new FormDataMultiPart();
+ conf = new LensConf();
+ conf.addProperty(LensConfConstants.QUERY_PERSISTENT_RESULT_INDRIVER, "false");
mp.bodyPart(new FormDataBodyPart(FormDataContentDisposition.name("sessionid").build(), lensSessionId,
MediaType.APPLICATION_XML_TYPE));
mp.bodyPart(new FormDataBodyPart(FormDataContentDisposition.name("query").build(),
@@ -1091,14 +1124,14 @@ public class TestQueryService extends LensJerseyTest {
Assert.assertNotNull(handle);
// Get query
- LensQuery ctx = target.path(handle.toString()).queryParam("sessionid", lensSessionId).request()
+ ctx = target.path(handle.toString()).queryParam("sessionid", lensSessionId).request()
.get(LensQuery.class);
Assert.assertTrue(ctx.getStatus().getStatus().equals(Status.QUEUED)
|| ctx.getStatus().getStatus().equals(Status.LAUNCHED) || ctx.getStatus().getStatus().equals(Status.RUNNING)
|| ctx.getStatus().getStatus().equals(Status.SUCCESSFUL));
// wait till the query finishes
- QueryStatus stat = ctx.getStatus();
+ stat = ctx.getStatus();
while (!stat.isFinished()) {
ctx = target.path(handle.toString()).queryParam("sessionid", lensSessionId).request().get(LensQuery.class);
stat = ctx.getStatus();