handler test error

apache · Mar 8, 2024 · 020ab5b · 020ab5b
1 parent 153bdab
commit 020ab5b
Show file tree

Hide file tree

Showing 3 changed files with 3 additions and 3 deletions.
diff --git a/...csv/src/main/java/org/apache/inlong/sort/formats/csv/CsvRowDataDeserializationSchema.java b/...csv/src/main/java/org/apache/inlong/sort/formats/csv/CsvRowDataDeserializationSchema.java
@@ -243,7 +243,7 @@ public RowData deserializeInternal(@Nullable byte[] message) throws Exception {
  }
  return rowData;
  } catch (Throwable t) {
- failureHandler.onParsingMsgFailure(message, new RuntimeException(
+ failureHandler.onParsingMsgFailure(text, new RuntimeException(
  String.format("Could not properly deserialize csv. Text=[{}].", text), t));
  }
  return null;

diff --git a/...n/src/main/java/org/apache/inlong/sort/formats/json/JsonRowDataDeserializationSchema.java b/...n/src/main/java/org/apache/inlong/sort/formats/json/JsonRowDataDeserializationSchema.java
@@ -113,7 +113,7 @@ public RowData deserializeInternal(@Nullable byte[] message) throws Exception {
  try {
  rowData = (RowData) runtimeConverter.convert(jsonStr);
  } catch (Throwable t) {
- failureHandler.onParsingMsgFailure(message, new RuntimeException(
+ failureHandler.onParsingMsgFailure(jsonStr, new RuntimeException(
  String.format("Could not properly deserialize json. Text=[%s].", jsonStr), t));
  }
  return rowData;

diff --git a/...ta-kv/src/main/java/org/apache/inlong/sort/formats/kv/KvRowDataDeserializationSchema.java b/...ta-kv/src/main/java/org/apache/inlong/sort/formats/kv/KvRowDataDeserializationSchema.java
@@ -171,7 +171,7 @@ public RowData deserializeInternal(byte[] bytes) throws Exception {
  }
  return rowData;
  } catch (Throwable t) {
- failureHandler.onParsingMsgFailure(bytes, new RuntimeException(
+ failureHandler.onParsingMsgFailure(text, new RuntimeException(
  String.format("Could not properly deserialize kv. Text=[{}].", text), t));
  }
  return null;