delete unused option

vinlee19 · Jul 1, 2024 · 4c1e881 · 4c1e881
1 parent b8ac0a8
commit 4c1e881
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 6 deletions.
diff --git a/...doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java b/...doris-connector/src/main/java/org/apache/doris/flink/sink/batch/DorisBatchStreamLoad.java
@@ -268,9 +268,6 @@ public void run() {
 
         /** execute stream load. */
         public void load(String label, BatchRecordBuffer buffer) throws IOException {
-            if (enableGroupCommit) {
-                label = null;
-            }
             refreshLoadUrl(buffer.getDatabase(), buffer.getTable());
             ByteBuffer data = buffer.getData();
             ByteArrayEntity entity =

diff --git a/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java b/flink-doris-connector/src/main/java/org/apache/doris/flink/sink/writer/DorisStreamLoad.java
@@ -293,9 +293,6 @@ public RespContent stopLoad() throws IOException {
      * @throws IOException
      */
     public void startLoad(String label, boolean isResume) throws IOException {
-        if (enableGroupCommit) {
-            label = null;
-        }
         loadBatchFirstRecord = !isResume;
         HttpPutBuilder putBuilder = new HttpPutBuilder();
         recordStream.startInput(isResume);