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

hxb pushed a commit to branch release-1.16
in repository https://gitbox.apache.org/repos/asf/flink.git


The following commit(s) were added to refs/heads/release-1.16 by this push:
     new 4ed1ef3caf8 [hotfix][python] Fix typo in PyFlink's 
JsonRowDeserializationSchema
4ed1ef3caf8 is described below

commit 4ed1ef3caf8fb42bf1d2f153d69f0de690df3c45
Author: Steven van Rossum <[email protected]>
AuthorDate: Thu Sep 8 18:19:01 2022 +0800

    [hotfix][python] Fix typo in PyFlink's JsonRowDeserializationSchema
    
    This closes #20788.
---
 flink-python/pyflink/datastream/formats/json.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/flink-python/pyflink/datastream/formats/json.py 
b/flink-python/pyflink/datastream/formats/json.py
index 4cc216e28cd..167b2a3e625 100644
--- a/flink-python/pyflink/datastream/formats/json.py
+++ b/flink-python/pyflink/datastream/formats/json.py
@@ -98,7 +98,7 @@ class JsonRowDeserializationSchema(DeserializationSchema):
             j_builder = JBuilder(self._type_info.get_java_type_info())
 
             if self._fail_on_missing_field:
-                j_builder = j_builder.fialOnMissingField()
+                j_builder = j_builder.failOnMissingField()
 
             if self._ignore_parse_errors:
                 j_builder = j_builder.ignoreParseErrors()

Reply via email to