handle deserialize

baomingyu · Mar 8, 2024 · 756dae3 · 756dae3
1 parent 69d84b8
commit 756dae3
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/.../format-common/src/main/java/org/apache/inlong/sort/formats/inlongmsg/FailureHandler.java b/.../format-common/src/main/java/org/apache/inlong/sort/formats/inlongmsg/FailureHandler.java
@@ -34,7 +34,7 @@ default boolean isIgnoreFailure() {
     };
 
     /**
-     * This method is called when there is a failure occurred while parsing not InLongMsg.
+     * This method is called when there is a failure occurred while parsing non-InLong message.
      *
      * @param msg the msg byte
      * @param exception the thrown exception

diff --git a/...t-common/src/main/java/org/apache/inlong/sort/formats/inlongmsg/IgnoreFailureHandler.java b/...t-common/src/main/java/org/apache/inlong/sort/formats/inlongmsg/IgnoreFailureHandler.java
@@ -29,7 +29,7 @@ public class IgnoreFailureHandler implements FailureHandler {
 
     @Override
     public void onParsingMsgFailure(Object msg, Exception exception) {
-        LOG.error("Could not properly serialize msg=[{}].", msg, exception);
+        LOG.error("Could not properly deserialize msg=[{}].", msg, exception);
     };
 
     @Override