[inlong] branch release-1.3.0 updated: [INLONG-5737][Sort] Fix InLongMsg with inner format raw deserialize throw NullPointException (#5738)

[do...@apache.org]

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

dockerzhang pushed a commit to branch release-1.3.0
in repository https://gitbox.apache.org/repos/asf/inlong.git


The following commit(s) were added to refs/heads/release-1.3.0 by this push:
     new 8afa3a7e1 [INLONG-5737][Sort] Fix InLongMsg with inner format raw deserialize throw NullPointException (#5738)
8afa3a7e1 is described below

commit 8afa3a7e1cf7ea2fa4bc64c6aabecb118f364402
Author: thesumery <10...@users.noreply.github.com>
AuthorDate: Tue Aug 30 14:53:04 2022 +0800

    [INLONG-5737][Sort] Fix InLongMsg with inner format raw deserialize throw NullPointException (#5738)
    
    Co-authored-by: thesumery <15...@qq.com>
---
 .../sort/formats/inlongmsg/InLongMsgDeserializationSchema.java       | 5 +++++
 1 file changed, 5 insertions(+)

diff --git a/inlong-sort/sort-formats/format-inlongmsg-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/InLongMsgDeserializationSchema.java b/inlong-sort/sort-formats/format-inlongmsg-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/InLongMsgDeserializationSchema.java
index e9c45afc9..ba41a7447 100644
--- a/inlong-sort/sort-formats/format-inlongmsg-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/InLongMsgDeserializationSchema.java
+++ b/inlong-sort/sort-formats/format-inlongmsg-base/src/main/java/org/apache/inlong/sort/formats/inlongmsg/InLongMsgDeserializationSchema.java
@@ -61,6 +61,11 @@ public class InLongMsgDeserializationSchema implements DeserializationSchema<Row
         this.ignoreErrors = ignoreErrors;
     }
 
+    @Override
+    public void open(InitializationContext context) throws Exception {
+        deserializationSchema.open(context);
+    }
+
     @Override
     public RowData deserialize(byte[] bytes) throws IOException {
         throw new RuntimeException(