[INLONG-10317][Sort] Remove redundant code

XiaoYou201 · Jul 1, 2024 · 653f673 · 653f673
1 parent 33ce085
commit 653f673
Showing 1 changed file with 0 additions and 4 deletions.
diff --git a/...a/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaDeserializationSchema.java b/...a/src/main/java/org/apache/inlong/sort/kafka/table/DynamicKafkaDeserializationSchema.java
@@ -49,8 +49,6 @@
  * */
 public class DynamicKafkaDeserializationSchema implements KafkaDeserializationSchema<RowData> {
 
- private static final Logger LOG = LoggerFactory.getLogger(DynamicKafkaDeserializationSchema.class);
-
  private static final long serialVersionUID = 1L;
 
  private final @Nullable DeserializationSchema<RowData> keyDeserialization;
@@ -140,7 +138,6 @@ public void deserialize(ConsumerRecord<byte[], byte[]> record, Collector<RowData
  if (keyDeserialization == null && !hasMetadata) {
  valueDeserialization.deserialize(record.value(),
  sourceExactlyMetric == null ? collector : new MetricsCollector<>(collector, sourceExactlyMetric));
- LOG.info("-------no hasMetadata------");
  return;
  }
  // buffer key(s)
@@ -154,7 +151,6 @@ public void deserialize(ConsumerRecord<byte[], byte[]> record, Collector<RowData
  MetricsCollector<RowData> metricsCollector = new MetricsCollector<>(collector, sourceExactlyMetric);
  outputCollector.outputCollector = metricsCollector;
  } else {
- LOG.info("-------origin collector------");
  outputCollector.outputCollector = collector;
  }
  if (record.value() == null && upsertMode) {