You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lens.apache.org by pu...@apache.org on 2016/10/25 10:25:07 UTC
[09/31] lens git commit: LENS-1272 : Check-style fixes after LENS-1265
LENS-1272 : Check-style fixes after LENS-1265
Project: http://git-wip-us.apache.org/repos/asf/lens/repo
Commit: http://git-wip-us.apache.org/repos/asf/lens/commit/d37e8499
Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/d37e8499
Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/d37e8499
Branch: refs/heads/master
Commit: d37e84994042622b7e68a5c564d3cb31fed5c45f
Parents: ebf018f
Author: Lavkesh Lahngir <la...@linux.com>
Authored: Wed Aug 10 19:21:43 2016 +0530
Committer: Archana H <ar...@apache.org>
Committed: Wed Aug 17 13:40:49 2016 +0530
----------------------------------------------------------------------
.../main/java/org/apache/lens/server/scheduler/SchedulerDAO.java | 3 ++-
.../org/apache/lens/server/scheduler/SchedulerServiceImpl.java | 3 ++-
2 files changed, 4 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/lens/blob/d37e8499/lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerDAO.java
----------------------------------------------------------------------
diff --git a/lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerDAO.java b/lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerDAO.java
index 6a4c77b..966a64e 100644
--- a/lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerDAO.java
+++ b/lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerDAO.java
@@ -665,7 +665,8 @@ public class SchedulerDAO {
"CREATE TABLE IF NOT EXISTS " + JOB_INSTANCE_RUN_TABLE + "( " + COLUMN_ID + " VARCHAR(255) NOT NULL, "
+ COLUMN_RUN_ID + " INT NOT NULL, " + COLUMN_SESSION_HANDLE + " VARCHAR(255), " + COLUMN_START_TIME
+ " BIGINT, " + COLUMN_END_TIME + " BIGINT, " + COLUMN_RESULT_PATH + " TEXT, " + COLUMN_QUERY_HANDLE
- + " VARCHAR(255), " + COLUMN_STATUS + " VARCHAR(20), " + " PRIMARY KEY ( " + COLUMN_ID + ", " + COLUMN_RUN_ID
+ + " VARCHAR(255), " + COLUMN_STATUS + " VARCHAR(20), " + " PRIMARY KEY ( " + COLUMN_ID + ", "
+ + COLUMN_RUN_ID
+ ")" + ")";
runner.update(createSQL);
}
http://git-wip-us.apache.org/repos/asf/lens/blob/d37e8499/lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerServiceImpl.java
----------------------------------------------------------------------
diff --git a/lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerServiceImpl.java b/lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerServiceImpl.java
index 28d7e27..74b337c 100644
--- a/lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerServiceImpl.java
+++ b/lens-server/src/main/java/org/apache/lens/server/scheduler/SchedulerServiceImpl.java
@@ -97,8 +97,9 @@ public class SchedulerServiceImpl extends BaseLensService implements SchedulerSe
private void doesSessionBelongToUser(LensSessionHandle sessionHandle, String user) throws LensException {
LensSessionImpl session = getSession(sessionHandle);
- if (!session.getLoggedInUser().equals(user))
+ if (!session.getLoggedInUser().equals(user)) {
throw new LensException("Logged in user " + session.getLoggedInUser() + " is not same as " + user);
+ }
}
@Override