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(