diff --git a/flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/StandardConvertletTable.java b/flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/StandardConvertletTable.java
index 6122b731f5982..777a43a2d3bae 100644
--- a/flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/StandardConvertletTable.java
+++ b/flink-table/flink-table-planner/src/main/java/org/apache/calcite/sql2rel/StandardConvertletTable.java
@@ -707,8 +707,8 @@ public RexNode convertJsonQueryFunction(
                 cx,
                 fun,
                 call,
-                (SqlNode[] nodes) -> SqlJsonQueryFunction.hasExplicitTypeSpec(nodes),
-                (SqlCall c) -> SqlJsonQueryFunction.removeTypeSpecOperands(c));
+                operands -> SqlJsonQueryFunction.hasExplicitTypeSpec(operands),
+                SqlJsonQueryFunction::removeTypeSpecOperands);
     }
 
     public RexNode convertJsonReturningFunction(