Improved region check for bq interpreter

apache · Sep 9, 2024 · b268de2 · b268de2
1 parent 4d36db8
commit b268de2
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/bigquery/pom.xml b/bigquery/pom.xml
@@ -76,6 +76,10 @@
       <artifactId>guava</artifactId>
       <version>${guava.version}</version>
     </dependency>
+    <dependency>
+      <groupId>org.apache.commons</groupId>
+      <artifactId>commons-lang3</artifactId>
+    </dependency>
 
   </dependencies>
 

diff --git a/bigquery/src/main/java/org/apache/zeppelin/bigquery/BigQueryInterpreter.java b/bigquery/src/main/java/org/apache/zeppelin/bigquery/BigQueryInterpreter.java
@@ -37,6 +37,7 @@
 import com.google.api.services.bigquery.model.TableRow;
 import com.google.common.base.Function;
 
+import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
@@ -278,7 +279,7 @@ public static Iterator<GetQueryResultsResponse> run(final String queryString,
       GetQueryResults getRequest = service.jobs().getQueryResults(
           projectId,
           jobId);
-      if (region != null) {
+      if (StringUtils.isNotBlank(region)) {
         getRequest = getRequest.setLocation(region);
       }
       return getPages(getRequest);