[incubator-seatunnel] branch dev updated: [hotfix][spark] Fix STRING type reverse conversion error (#2315)

[lidongdai]

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

lidongdai pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new 3173636de [hotfix][spark] Fix STRING type reverse conversion error 
(#2315)
3173636de is described below

commit 3173636ded925c33df7541555227ccdeffe10696
Author: Zongwen Li <zongwen.li.t...@gmail.com>
AuthorDate: Mon Aug 1 00:04:43 2022 +0800

    [hotfix][spark] Fix STRING type reverse conversion error (#2315)
---
 .../seatunnel/translation/spark/serialization/InternalRowConverter.java | 2 ++
 1 file changed, 2 insertions(+)

diff --git 
a/seatunnel-translation/seatunnel-translation-spark/src/main/java/org/apache/seatunnel/translation/spark/serialization/InternalRowConverter.java
 
b/seatunnel-translation/seatunnel-translation-spark/src/main/java/org/apache/seatunnel/translation/spark/serialization/InternalRowConverter.java
index bcd3d7887..ad165a638 100644
--- 
a/seatunnel-translation/seatunnel-translation-spark/src/main/java/org/apache/seatunnel/translation/spark/serialization/InternalRowConverter.java
+++ 
b/seatunnel-translation/seatunnel-translation-spark/src/main/java/org/apache/seatunnel/translation/spark/serialization/InternalRowConverter.java
@@ -162,6 +162,8 @@ public final class InternalRowConverter extends 
RowConverter<InternalRow> {
                 return ((Timestamp) field).toLocalDateTime();
             case MAP:
                 return convertMap((Map<?, ?>) field, (MapType<?, ?>) dataType, 
InternalRowConverter::reconvert);
+            case STRING:
+                return field.toString();
             default:
                 return field;
         }