Address review comments: close planner when exception occurs in convertToBeamRel(RelNode, QueryParameters)

Author: damccorm

sdks/java/extensions/sql/src/main/java/org/apache/beam/sdk/extensions/sql/impl/CalciteQueryPlanner.java

@@ -320,12 +320,22 @@ public RelNode parseToRel(String sqlStatement, QueryParameters queryParameters)
   @Override
   public BeamRelNode convertToBeamRel(RelNode relNode, QueryParameters queryParameters)
       throws SqlConversionException {
-    if (queryParameters.getKind() == Kind.POSITIONAL) {
-      relNode =
-          bindParameters(
-              relNode, new ParameterBinder(relNode.getCluster().getRexBuilder(), queryParameters));
+    boolean success = false;
+    try {
+      if (queryParameters.getKind() == Kind.POSITIONAL) {
+        relNode =
+            bindParameters(
+                relNode,
+                new ParameterBinder(relNode.getCluster().getRexBuilder(), queryParameters));
+      }
+      BeamRelNode result = convertToBeamRel(relNode, (RelCollation) null);
+      success = true;
+      return result;
+    } finally {
+      if (!success) {
+        planner.close();
+      }
     }
-    return convertToBeamRel(relNode, (RelCollation) null);
   }
 
   private BeamRelNode convertToBeamRel(RelNode relNode, @Nullable RelCollation collation)