doris sender remove

apache · Nov 15, 2023 · ed416c9 · ed416c9
1 parent 1d367e6
commit ed416c9
Showing 1 changed file with 5 additions and 5 deletions.
diff --git a/...g-stream/src/main/java/com/xiaomi/mone/log/stream/job/extension/MessageSenderFactory.java b/...g-stream/src/main/java/com/xiaomi/mone/log/stream/job/extension/MessageSenderFactory.java
@@ -30,7 +30,7 @@ public static MessageSender getMessageSender(SinkJobConfig sinkJobConfig) {
             case ELASTICSEARCH:
                 return getEsMessageSender(sinkJobConfig, mqMessageProduct);
             case DORIS:
-                return getDorisMessageSender(sinkJobConfig, mqMessageProduct);
+//                return getDorisMessageSender(sinkJobConfig, mqMessageProduct);
             default:
                 return null;
         }
@@ -44,8 +44,8 @@ private static MessageSender getEsMessageSender(SinkJobConfig sinkJobConfig, MqM
         return esMessageSender;
     }
 
-    private static MessageSender getDorisMessageSender(SinkJobConfig sinkJobConfig, MqMessageProduct mqMessageProduct) {
-        List<String> keyListSlice = IndexUtils.getKeyListSlice(sinkJobConfig.getKeyList());
-        return new DorisMessageSender(sinkJobConfig.getIndex(), mqMessageProduct, sinkJobConfig.getStorageInfo(), keyListSlice);
-    }
+//    private static MessageSender getDorisMessageSender(SinkJobConfig sinkJobConfig, MqMessageProduct mqMessageProduct) {
+//        List<String> keyListSlice = IndexUtils.getKeyListSlice(sinkJobConfig.getKeyList());
+//        return new DorisMessageSender(sinkJobConfig.getIndex(), mqMessageProduct, sinkJobConfig.getStorageInfo(), keyListSlice);
+//    }
 }