You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@seatunnel.apache.org by ki...@apache.org on 2022/04/08 02:40:28 UTC
[incubator-seatunnel] branch dev updated: [Bug] [connetor] When outputting data to doris, a ClassCastException was encountered. (#1674)
This is an automated email from the ASF dual-hosted git repository.
kirs 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 ce041951 [Bug] [connetor] When outputting data to doris, a ClassCastException was encountered. (#1674)
ce041951 is described below
commit ce041951e7820c14e9620cbe946dab93ebf76ae6
Author: realdengziqi <42...@users.noreply.github.com>
AuthorDate: Fri Apr 8 10:40:22 2022 +0800
[Bug] [connetor] When outputting data to doris, a ClassCastException was encountered. (#1674)
---
.../java/org/apache/seatunnel/flink/doris/sink/DorisOutputFormat.java | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisOutputFormat.java b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisOutputFormat.java
index 1d054861..e3a19d52 100644
--- a/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisOutputFormat.java
+++ b/seatunnel-connectors/seatunnel-connectors-flink/seatunnel-connector-flink-doris/src/main/java/org/apache/seatunnel/flink/doris/sink/DorisOutputFormat.java
@@ -207,7 +207,7 @@ public class DorisOutputFormat<T> extends RichOutputFormat<T> {
result = OBJECT_MAPPER.writeValueAsString(batch);
}
} else {
- result = String.join(this.lineDelimiter, (CharSequence) batch);
+ result = String.join(this.lineDelimiter, batch.toArray(new CharSequence[batch.size()]));
}
for (int i = 0; i <= maxRetries; i++) {
try {