askhatri commented on code in PR #384:
URL: https://github.com/apache/incubator-livy/pull/384#discussion_r1099668310
##########
server/src/main/scala/org/apache/livy/server/SessionServlet.scala:
##########
@@ -131,13 +131,18 @@ abstract class SessionServlet[S <: Session, R <:
RecoveryMetadata](
if (tooManySessions) {
BadRequest(ResponseMessage("Rejected, too many sessions are being
created!"))
} else {
- val session = sessionManager.register(createSession(request))
- // Because it may take some time to establish the session, update the
last activity
- // time before returning the session info to the client.
- session.recordActivity()
- Created(clientSessionView(session, request),
- headers = Map("Location" ->
- (getRequestPathInfo(request) + url(getSession, "id" ->
session.id.toString))))
+ try {
+ val session = sessionManager.register(createSession(request))
+ // Because it may take some time to establish the session, update
the last activity
+ // time before returning the session info to the client.
+ session.recordActivity()
+ Created(clientSessionView(session, request),
+ headers = Map("Location" ->
+ (getRequestPathInfo(request) + url(getSession, "id" ->
session.id.toString))))
+ } catch {
+ case e: IllegalArgumentException =>
+ BadRequest(ResponseMessage("Rejected, Invalid ttl field: " +
e.getMessage))
Review Comment:
I have updated the code as requested.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
