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 <[email protected]>
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 <[email protected]>
---
.../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(
