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 2016/08/10 13:51:53 UTC
lens git commit: LENS-1272 : Check-style fixes after LENS-1265
Repository: lens
Updated Branches:
refs/heads/master a0b3f818f -> 603cd0fd0
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/603cd0fd
Tree: http://git-wip-us.apache.org/repos/asf/lens/tree/603cd0fd
Diff: http://git-wip-us.apache.org/repos/asf/lens/diff/603cd0fd
Branch: refs/heads/master
Commit: 603cd0fd0d8dd5fa978c9bdd625a6c9ed76d05bc
Parents: a0b3f81
Author: Lavkesh Lahngir <la...@linux.com>
Authored: Wed Aug 10 19:21:43 2016 +0530
Committer: Amareshwari Sriramadasu <am...@apache.org>
Committed: Wed Aug 10 19:21:43 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/603cd0fd/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/603cd0fd/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