This is an automated email from the ASF dual-hosted git repository.

twalthr pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/master by this push:
     new 39bf636b514 [hotfix][table] Fix tryParseJson() docs to say NULL 
instead of throws an error
39bf636b514 is described below

commit 39bf636b5140868d744cc651001e5421c8e9a53c
Author: Ramin Gharib <[email protected]>
AuthorDate: Mon Sep 7 15:01:23 2026 +0200

    [hotfix][table] Fix tryParseJson() docs to say NULL instead of throws an 
error
    
    This closes #29124.
---
 docs/data/sql_functions.yml                                           | 2 +-
 flink-python/pyflink/table/expression.py                              | 4 ++--
 .../java/org/apache/flink/table/api/internal/BaseExpressions.java     | 4 ++--
 3 files changed, 5 insertions(+), 5 deletions(-)

diff --git a/docs/data/sql_functions.yml b/docs/data/sql_functions.yml
index 8dc465da407..d25223c5f20 100644
--- a/docs/data/sql_functions.yml
+++ b/docs/data/sql_functions.yml
@@ -1352,7 +1352,7 @@ variant:
   - sql: TRY_PARSE_JSON(json_string[, allow_duplicate_keys])
     table: STRING.tryParseJson([allowDuplicateKeys])
     description: |
-      Try to parse a JSON string into a Variant if possible. If the JSON 
string is invalid, return 
+      Try to parse a JSON string into a Variant if possible. If the JSON 
string is invalid, return
       NULL. To throw an error instead of returning NULL, use the `PARSE_JSON` 
function.
 
       If there are duplicate keys in the input JSON string, when 
`allowDuplicateKeys` is true, the 
diff --git a/flink-python/pyflink/table/expression.py 
b/flink-python/pyflink/table/expression.py
index be21605124a..5212de11f86 100644
--- a/flink-python/pyflink/table/expression.py
+++ b/flink-python/pyflink/table/expression.py
@@ -2303,8 +2303,8 @@ class Expression(Generic[T]):
         None is returned. To throw an error instead, use 
:func:`~Expression.parse_json`.
 
         If there are duplicate keys in the input, allow_duplicate_keys 
controls whether the
-        parser keeps the last occurrence of each duplicated key (True) or 
throws an error
-        (False). The default value of allow_duplicate_keys is False.
+        parser keeps the last occurrence of each duplicated key (True) or 
returns
+        None (False). The default value of allow_duplicate_keys is False.
         """
         if allow_duplicate_keys is None:
             return _unary_op("tryParseJson")(self)
diff --git 
a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/BaseExpressions.java
 
b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/BaseExpressions.java
index 536105ea6bc..3aa6923461e 100644
--- 
a/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/BaseExpressions.java
+++ 
b/flink-table/flink-table-api-java/src/main/java/org/apache/flink/table/api/internal/BaseExpressions.java
@@ -1411,8 +1411,8 @@ public abstract class BaseExpressions<InType, OutType> {
      * #parseJson(boolean)}.
      *
      * <p>If there are duplicate keys in the input, {@code allowDuplicateKeys} 
controls whether the
-     * parser keeps the last occurrence of each duplicated key ({@code true}) 
or throws an error
-     * ({@code false}).
+     * parser keeps the last occurrence of each duplicated key ({@code true}) 
or returns {@code
+     * NULL} ({@code false}).
      */
     public OutType tryParseJson(boolean allowDuplicateKeys) {
         return toApiSpecificExpression(

Reply via email to