Elgato_dark/zeppelin
1
0
Fork 0
mirror of https://github.com/apache/zeppelin synced 2026-05-24 09:38:26 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

pushing BQ Exception to logs and Interpreter error output

Browse source
This commit is contained in:
Babu Prasad Elumalai 2016-07-30 03:41:10 +00:00
parent d3c2316a4f
commit ffed80182e
1 changed files with 10 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

13
bigquery/src/main/java/org/apache/zeppelin/bigquery/BigQueryInterpreter.java
View file

@ -245,7 +245,13 @@ public class BigQueryInterpreter extends Interpreter {
String projId = getProperty(PROJECT_ID);
long wTime = Long.parseLong(getProperty(WAIT_TIME));
long maxRows = Long.parseLong(getProperty(MAX_ROWS));
Iterator<GetQueryResultsResponse> pages = run(sql, projId, wTime, maxRows);
Iterator<GetQueryResultsResponse> pages;
try {
pages = run(sql, projId, wTime, maxRows);
} catch ( IOException ex ) {
logger.error(ex.getMessage());
return new InterpreterResult(Code.ERROR, ex.getMessage());
}
try {
while (pages.hasNext()) {
finalmessage.append(printRows(pages.next()));
@ -258,7 +264,8 @@ public class BigQueryInterpreter extends Interpreter {
//Function to run the SQL on bigQuery service
public static Iterator<GetQueryResultsResponse> run(final String queryString,
final String projId, final long wTime, final long maxRows) {
final String projId, final long wTime, final long maxRows)
throws IOException {
try {
QueryResponse query = service.jobs().query(
projId,
@ -271,7 +278,7 @@ public class BigQueryInterpreter extends Interpreter {
jobId);
return getPages(getRequest);
} catch (IOException ex) {
return null;
throw ex;
}
}