Update externals/kyuubi-flink-sql-engine/src/main/scala/org/apache/ky…

…uubi/engine/flink/result/ResultSet.scala Co-authored-by: cxzl25 <[email protected]>
link3280 · Apr 1, 2023 · 0eafbd7 · 0eafbd7
1 parent ee2c64d
commit 0eafbd7
Showing 1 changed file with 3 additions and 4 deletions.
diff --git a/...ubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/result/ResultSet.scala b/...ubi-flink-sql-engine/src/main/scala/org/apache/kyuubi/engine/flink/result/ResultSet.scala
@@ -70,12 +70,11 @@ object ResultSet {
   }
 
   def fromJobId(jobID: JobID): ResultSet = {
-    var data: Array[Row] = null;
-    if (jobID != null) {
-      data = Array(Row.of(jobID.toString));
+    val data: Array[Row] = if (jobID != null) {
+      Array(Row.of(jobID.toString))
     } else {
       // should not happen
-      data = Array(Row.of("(Empty Job ID)"));
+      Array(Row.of("(Empty Job ID)"))
     }
     builder
       .resultKind(ResultKind.SUCCESS_WITH_CONTENT)