[flink] branch master updated: [hotfix][python] Fix typo in PyFlink's JsonRowDeserializationSchema

[hxb]

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

hxb 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 84e5c63d3c7 [hotfix][python] Fix typo in PyFlink's 
JsonRowDeserializationSchema
84e5c63d3c7 is described below

commit 84e5c63d3c7151925bb976e8d3aba43361c76e65
Author: Steven van Rossum <stevenvanros...@gmail.com>
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()