From f893f26267497570154d63c77aaebd9048e92c02 Mon Sep 17 00:00:00 2001 From: zhouyao <yao.zhou@marketingforce.com> Date: Mon, 29 May 2023 16:30:19 +0800 Subject: [PATCH] [BUG][Doris] Add a jobId to the doris label to distinguish between tasks --- .../connectors/doris/sink/writer/DorisSinkStateSerializer.java | 1 + 1 file changed, 1 insertion(+) diff --git a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisSinkStateSerializer.java b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisSinkStateSerializer.java index 213b1c785f5..6f442117b95 100644 --- a/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisSinkStateSerializer.java +++ b/seatunnel-connectors-v2/connector-doris/src/main/java/org/apache/seatunnel/connectors/doris/sink/writer/DorisSinkStateSerializer.java @@ -32,6 +32,7 @@ public byte[] serialize(DorisSinkState dorisSinkState) throws IOException { try (final ByteArrayOutputStream baos = new ByteArrayOutputStream(); final DataOutputStream out = new DataOutputStream(baos)) { out.writeUTF(dorisSinkState.getLabelPrefix()); + out.writeLong(dorisSinkState.getCheckpointId()); out.flush(); return baos.toByteArray(); }